Searched refs:WorkerStatus (Results 1 – 7 of 7) sorted by relevance
21 use super::WorkerStatus;98 pub status_mutex: Rc<AsyncMutex<WorkerStatus>>,154 status_mutex: Rc::new(AsyncMutex::new(WorkerStatus::Pause)), in from()296 self.status_mutex = Rc::new(AsyncMutex::new(WorkerStatus::Pause)); in prepare()325 if *status != WorkerStatus::Quit { in start()326 *status = WorkerStatus::Running; in start()346 if *status != WorkerStatus::Quit { in stop()347 *status = WorkerStatus::Pause; in stop()372 *self.status_mutex.lock().await = WorkerStatus::Quit; in release_worker()
35 use super::WorkerStatus;348 status_mutex: Rc<AsyncMutex<WorkerStatus>>, in start_pcm_worker() argument361 *status_mutex.lock().await = WorkerStatus::Quit; in start_pcm_worker()378 status_mutex: &Rc<AsyncMutex<WorkerStatus>>, in pcm_worker_loop() argument391 WorkerStatus::Quit => { in pcm_worker_loop()398 WorkerStatus::Pause => { in pcm_worker_loop()401 WorkerStatus::Running => { in pcm_worker_loop()446 WorkerStatus::Quit => { in pcm_worker_loop()453 WorkerStatus::Pause => { in pcm_worker_loop()456 WorkerStatus::Running => match desc_receiver.try_next() { in pcm_worker_loop()[all …]
159 pub enum WorkerStatus { enum
76 class WorkerStatus {82 WorkerStatus() : num_workers_(0), status_(RUN) {} in WorkerStatus() function195 DISALLOW_COPY_AND_ASSIGN(WorkerStatus);218 WorkerStatus *worker_status);402 WorkerStatus *worker_status_;547 WorkerStatus status;
287 WorkerStatus power_spike_status_;289 WorkerStatus continuous_status_;
129 void WorkerStatus::Initialize() { in Initialize()138 void WorkerStatus::Destroy() { in Destroy()146 void WorkerStatus::PauseWorkers() { in PauseWorkers()151 void WorkerStatus::ResumeWorkers() { in ResumeWorkers()156 void WorkerStatus::StopWorkers() { in StopWorkers()161 bool WorkerStatus::ContinueRunning(bool *paused) { in ContinueRunning()189 bool WorkerStatus::ContinueRunningNoPause() { in ContinueRunningNoPause()193 void WorkerStatus::RemoveSelf() { in RemoveSelf()284 WorkerStatus *worker_status) { in InitThread()
459 WorkerStatus fill_status; in InitializePages()1520 WorkerStatus reap_check_status; in JoinThreads()