Method ensure_started

packages/server/src/simulators/session.rs:148–171

(&self)

    }

    pub fn ensure_started(&self) -> Result<(), AppError> {
        loop {
            let mut state = self.inner.state.lock().unwrap();
            match *state {
                SessionState::Ready | SessionState::Streaming => return Ok(()),
                SessionState::Attaching => {
                    drop(self.inner.start_condvar.wait(state).unwrap());
                }
                _ => {
                    *state = SessionState::Attaching;
                    break;
                }
            }
        }

        if let Err(error) = self.inner.native.start() {
            *self.inner.state.lock().unwrap() = SessionState::Failed;
            self.inner.start_condvar.notify_all();
            return Err(error);
        }
        *self.inner.state.lock().unwrap() = SessionState::Ready;
        self.inner.start_condvar.notify_all();
        Ok(())
    }

    pub async fn ensure_started_async(&self) -> Result<(), AppError> {
        let session = self.clone();