| /ohos5.0/base/request/request/services/src/manage/ |
| H A D | task_manager.rs | 153 TaskManagerEvent::Schedule(event) => { in run()
159 TaskManagerEvent::Device(level) => { in run()
348 pub(crate) tx: UnboundedSender<TaskManagerEvent>,
352 pub(crate) fn new(tx: UnboundedSender<TaskManagerEvent>) -> Self { in new()
356 pub(crate) fn send_event(&self, event: TaskManagerEvent) -> bool { in send_event()
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()
410 rx: UnboundedReceiver<TaskManagerEvent>,
414 pub(crate) fn new(rx: UnboundedReceiver<TaskManagerEvent>) -> Self { in new()
[all …]
|
| H A D | mod.rs | 44 use crate::manage::events::{TaskEvent, TaskManagerEvent};
181 assert!(matches!(msg, TaskManagerEvent::Reschedule)); in ut_manager_task_state_and_reason()
185 …TaskManagerEvent::Task(TaskEvent::Completed(info_task_id, info_uid,Mode::BackGround)) if uid == in… in ut_manager_task_state_and_reason()
302 TaskManagerEvent::Reschedule in ut_manager_reschedule()
308 TaskManagerEvent::Reschedule in ut_manager_reschedule()
314 TaskManagerEvent::Reschedule in ut_manager_reschedule()
322 TaskManagerEvent::Reschedule in ut_manager_reschedule()
328 TaskManagerEvent::Reschedule in ut_manager_reschedule()
334 TaskManagerEvent::Reschedule in ut_manager_reschedule()
|
| H A D | account.rs | 20 use crate::manage::events::TaskManagerEvent;
94 .send_event(TaskManagerEvent::Account(AccountEvent::Changed)); in drop()
182 task_manager.send_event(TaskManagerEvent::Account(AccountEvent::Remove(*id))); in registry_account_subscribe()
291 TaskManagerEvent::Account(AccountEvent::Changed) in ut_account_check_oh()
314 TaskManagerEvent::Account(AccountEvent::Changed) in ut_account_update()
|
| H A D | network.rs | 23 use super::events::TaskManagerEvent;
62 task_manager.inner.send_event(TaskManagerEvent::network()); in register_network_change()
65 task_manager.inner.send_event(TaskManagerEvent::network()); in register_network_change()
|
| H A D | notifier.rs | 97 use crate::manage::events::{TaskEvent, TaskManagerEvent};
|
| /ohos5.0/base/request/request/services/src/manage/events/ |
| H A D | mod.rs | 36 pub(crate) enum TaskManagerEvent { enum
47 impl TaskManagerEvent { impl
231 use super::TaskManagerEvent;
266 let (event, rx) = TaskManagerEvent::construct(config); in ut_task_manager_construct()
289 let (event, rx) = TaskManagerEvent::start(uid, task_id); in ut_task_manager_start()
314 let (event, _rx) = TaskManagerEvent::start(uid, task_id); in ut_task_manager_pause_resume()
316 let (event, _rx) = TaskManagerEvent::pause(uid, task_id); in ut_task_manager_pause_resume()
318 let (event, _rx) = TaskManagerEvent::resume(uid, task_id); in ut_task_manager_pause_resume()
341 let (event, _rx) = TaskManagerEvent::start(uid, task_id); in ut_task_manager_stop_resume()
343 let (event, _rx) = TaskManagerEvent::stop(uid, task_id); in ut_task_manager_stop_resume()
[all …]
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/queue/ |
| H A D | keeper.rs | 20 use crate::manage::events::{ScheduleEvent, TaskManagerEvent};
27 tx: UnboundedSender<TaskManagerEvent>,
85 fn count_down(tx: UnboundedSender<TaskManagerEvent>) -> JoinHandle<()> { in count_down()
89 async fn unload_sa(tx: UnboundedSender<TaskManagerEvent>) { in unload_sa() argument
92 let _ = tx.send(TaskManagerEvent::Schedule(ScheduleEvent::Unload)); in unload_sa()
|
| H A D | running_task.rs | 18 use crate::manage::events::{TaskEvent, TaskManagerEvent};
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()
|
| H A D | mod.rs | 30 use crate::manage::events::{TaskEvent, TaskManagerEvent};
191 self.tx.send_event(TaskManagerEvent::Task(TaskEvent::Failed( in reschedule_inner()
|
| /ohos5.0/base/request/request/services/src/service/command/ |
| H A D | dump.rs | 19 use crate::manage::events::TaskManagerEvent;
63 let (event, rx) = TaskManagerEvent::dump_all(); in dump_all_task_info()
100 let (event, rx) = TaskManagerEvent::dump_one(task_id); in dump_one_task_info()
|
| H A D | stop.rs | 18 use crate::manage::events::TaskManagerEvent;
38 let (event, rx) = TaskManagerEvent::stop(uid, task_id); in stop()
|
| H A D | resume.rs | 18 use crate::manage::events::TaskManagerEvent;
49 let (event, rx) = TaskManagerEvent::resume(uid, task_id); in resume()
|
| H A D | start.rs | 18 use crate::manage::events::TaskManagerEvent;
46 let (event, rx) = TaskManagerEvent::start(uid, task_id); in start()
|
| H A D | pause.rs | 18 use crate::manage::events::TaskManagerEvent;
49 let (event, rx) = TaskManagerEvent::pause(uid, task_id); in pause()
|
| H A D | remove.rs | 18 use crate::manage::events::TaskManagerEvent;
51 let (event, rx) = TaskManagerEvent::remove(uid, task_id); in remove()
|
| H A D | subscribe.rs | 18 use crate::manage::events::TaskManagerEvent;
41 let (event, rx) = TaskManagerEvent::subscribe(task_id, token_id); in subscribe()
|
| H A D | construct.rs | 23 use crate::manage::events::TaskManagerEvent;
243 let (event, rx) = TaskManagerEvent::construct(task_config); in construct()
|
| /ohos5.0/base/request/request/services/src/ |
| H A D | ability.rs | 30 use crate::manage::events::TaskManagerEvent;
162 task_manager.send_event(TaskManagerEvent::Device(level)); in on_device_level_changed()
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/ |
| H A D | mod.rs | 24 use super::events::TaskManagerEvent;
372 task_manager.send_event(TaskManagerEvent::Reschedule); in schedule_if_not_scheduled()
|