Searched refs:send_event (Results 1 – 19 of 19) sorted by relevance
267 TASK_MANGER.send_event(event); in ut_task_manager_construct()287 TASK_MANGER.send_event(event); in ut_task_manager_start()290 TASK_MANGER.send_event(event); in ut_task_manager_start()312 TASK_MANGER.send_event(event); in ut_task_manager_pause_resume()315 TASK_MANGER.send_event(event); in ut_task_manager_pause_resume()317 TASK_MANGER.send_event(event); in ut_task_manager_pause_resume()319 TASK_MANGER.send_event(event); in ut_task_manager_pause_resume()339 TASK_MANGER.send_event(event); in ut_task_manager_stop_resume()342 TASK_MANGER.send_event(event); in ut_task_manager_stop_resume()344 TASK_MANGER.send_event(event); in ut_task_manager_stop_resume()[all …]
356 pub(crate) fn send_event(&self, event: TaskManagerEvent) -> bool { in send_event() method372 let _ = self.send_event(TaskManagerEvent::State(StateEvent::ForegroundApp(uid))); in notify_foreground_app_change()376 let _ = self.send_event(TaskManagerEvent::State(StateEvent::Background(uid))); in notify_app_background()380 let _ = self.send_event(TaskManagerEvent::State(StateEvent::BackgroundTimeout(uid))); in trigger_background_timeout()384 let _ = self.send_event(TaskManagerEvent::State(StateEvent::SpecialTerminate(uid))); in notify_special_process_terminate()390 let _ = self.send_event(TaskManagerEvent::Query(event)); in show()397 let _ = self.send_event(TaskManagerEvent::Query(event)); in query()404 let _ = self.send_event(TaskManagerEvent::Query(event)); in touch()435 let _ = tx.send_event(TaskManagerEvent::Schedule(ScheduleEvent::RestoreAllTasks)); in restore_all_tasks()441 let _ = tx.send_event(TaskManagerEvent::Schedule(ScheduleEvent::ClearTimeoutTasks)); in clear_timeout_tasks()[all …]
62 task_manager.inner.send_event(TaskManagerEvent::network()); in register_network_change()65 task_manager.inner.send_event(TaskManagerEvent::network()); in register_network_change()
94 .send_event(TaskManagerEvent::Account(AccountEvent::Changed)); in drop()182 task_manager.send_event(TaskManagerEvent::Account(AccountEvent::Remove(*id))); in registry_account_subscribe()
74 .send_event(TaskManagerEvent::Task(TaskEvent::Completed( in drop()82 .send_event(TaskManagerEvent::Task(TaskEvent::Offline( in drop()89 self.tx.send_event(TaskManagerEvent::Task(TaskEvent::Failed( in drop()99 .send_event(TaskManagerEvent::Task(TaskEvent::Running( in drop()
191 self.tx.send_event(TaskManagerEvent::Task(TaskEvent::Failed( in reschedule_inner()
37 pub(crate) fn send_event(&self, event: RunCountEvent) -> bool { in send_event() method55 self.send_event(event); in subscribe_run_count()62 self.send_event(event); in unsubscribe_run_count()69 self.send_event(event); in notify_run_count()
55 if !self.send_event(event) { in open_channel()71 if !self.send_event(event) { in subscribe()87 if !self.send_event(event) { in unsubscribe()102 self.send_event(event); in notify_task_finished()108 if !self.send_event(event) { in notify_process_terminate()130 let _ = self.send_event(event); in send_response()135 let _ = self.send_event(event); in send_notify_data()
37 pub(crate) fn send_event(&self, event: ClientEvent) -> bool { in send_event() method
64 if !self.task_manager.lock().unwrap().send_event(event) { in dump_all_task_info()101 if !self.task_manager.lock().unwrap().send_event(event) { in dump_one_task_info()
39 if !self.task_manager.lock().unwrap().send_event(event) { in stop()
50 if !self.task_manager.lock().unwrap().send_event(event) { in resume()
47 if !self.task_manager.lock().unwrap().send_event(event) { in start()
50 if !self.task_manager.lock().unwrap().send_event(event) { in pause()
52 if !self.task_manager.lock().unwrap().send_event(event) { in remove()
42 if !self.task_manager.lock().unwrap().send_event(event) { in subscribe()
244 if !self.task_manager.lock().unwrap().send_event(event) { in construct()
162 task_manager.send_event(TaskManagerEvent::Device(level)); in on_device_level_changed()
372 task_manager.send_event(TaskManagerEvent::Reschedule); in schedule_if_not_scheduled()