Lines Matching refs:state
76 Mutexed<ExecState>::Locked state(mExecState); in setListener_vb() local
77 if (state->mState == RUNNING) { in setListener_vb()
84 state->mListener = listener; in setListener_vb()
92 Mutexed<ExecState>::Locked state(mExecState); in queue_nb() local
93 if (state->mState != RUNNING) { in queue_nb()
117 Mutexed<ExecState>::Locked state(mExecState); in flush_sm() local
118 if (state->mState != RUNNING) { in flush_sm()
149 Mutexed<ExecState>::Locked state(mExecState); in drain_nb() local
150 if (state->mState != RUNNING) { in drain_nb()
164 Mutexed<ExecState>::Locked state(mExecState); in start() local
165 if (state->mState == RUNNING) { in start()
168 bool needsInit = (state->mState == UNINITIALIZED); in start()
170 state.unlock(); in start()
175 state.lock(); in start()
177 if (!state->mThread.joinable()) { in start()
183 state->mThread = std::thread( in start()
200 state->mState = RUNNING; in start()
212 Mutexed<ExecState>::Locked state(mExecState); in requestExitAndWait() local
213 if (!state->mThread.joinable()) { in requestExitAndWait()
230 Mutexed<ExecState>::Locked state(mExecState); in requestExitAndWait() local
231 if (state->mThread.joinable()) { in requestExitAndWait()
233 state->mThread.join(); in requestExitAndWait()
241 Mutexed<ExecState>::Locked state(mExecState); in stop() local
242 if (state->mState != RUNNING) { in stop()
245 state->mState = STOPPED; in stop()
266 Mutexed<ExecState>::Locked state(mExecState); in reset() local
267 state->mState = UNINITIALIZED; in reset()
315 Mutexed<ExecState>::Locked state(mExecState); in finish() local
316 std::shared_ptr<C2Component::Listener> listener = state->mListener; in finish()
317 state.unlock(); in finish()
394 Mutexed<ExecState>::Locked state(mExecState); in processQueue() local
395 std::shared_ptr<C2Component::Listener> listener = state->mListener; in processQueue()
396 state.unlock(); in processQueue()
405 Mutexed<ExecState>::Locked state(mExecState); in processQueue() local
406 std::shared_ptr<C2Component::Listener> listener = state->mListener; in processQueue()
407 state.unlock(); in processQueue()
423 Mutexed<ExecState>::Locked state(mExecState); in processQueue() local
424 std::shared_ptr<C2Component::Listener> listener = state->mListener; in processQueue()
425 state.unlock(); in processQueue()
433 Mutexed<ExecState>::Locked state(mExecState); in processQueue() local
435 std::shared_ptr<C2Component::Listener> listener = state->mListener; in processQueue()
436 state.unlock(); in processQueue()
453 Mutexed<ExecState>::Locked state(mExecState); in processQueue() local
454 std::shared_ptr<C2Component::Listener> listener = state->mListener; in processQueue()
455 state.unlock(); in processQueue()