Method start_refresh_pump

packages/server/src/simulators/session.rs:432–469

(self: &Arc<Self>)

impl SimulatorSessionInner {
    fn start_refresh_pump(self: &Arc<Self>) {
        if self
            .refresh_pump_running
            .compare_exchange(false, true, Ordering::AcqRel, Ordering::Acquire)
            .is_err()
        {
            return;
        }

        let inner = self.clone();
        tokio::spawn(async move {
            let mut next_tick = Instant::now();
            loop {
                if inner.active_frame_subscribers.load(Ordering::Relaxed) == 0 {
                    inner.refresh_pump_running.store(false, Ordering::Release);
                    if inner.active_frame_subscribers.load(Ordering::Relaxed) == 0 {
                        break;
                    }
                    if inner
                        .refresh_pump_running
                        .compare_exchange(false, true, Ordering::AcqRel, Ordering::Acquire)
                        .is_err()
                    {
                        break;
                    }
                }

                inner.request_refresh();
                let refresh_interval = shared_refresh_interval();
                next_tick += refresh_interval;
                let now = Instant::now();
                if next_tick <= now {
                    next_tick = now + refresh_interval;
                }
                sleep_until(next_tick).await;
            }
        });
    }

    fn request_refresh(&self) {
        let now = now_us();