Searched defs:TaskManagerTx (Results 1 – 8 of 8) sorted by relevance
| /base/request/request/services/src/manage/ |
| D | account.rs | 41 pub(crate) fn update_accounts(task_manager: TaskManagerTx) { in update_accounts()
130 pub(crate) fn registry_account_subscribe(task_manager: TaskManagerTx) { in registry_account_subscribe()
246 type TaskManagerTx; typedef
260 task_manager: Box<TaskManagerTx>, in RegistryAccountSubscriber()
261 on_accounts_changed: fn(&i32, task_manager: &TaskManagerTx), in RegistryAccountSubscriber()
|
| D | task_manager.rs | 74 ) -> TaskManagerTx { in init()
125 tx: TaskManagerTx, in new()
326 pub struct TaskManagerTx { struct
330 impl TaskManagerTx { implementation
412 async fn restore_all_tasks(tx: TaskManagerTx) { in restore_all_tasks()
417 async fn clear_timeout_tasks(tx: TaskManagerTx) { in clear_timeout_tasks()
424 async fn log_all_task_info(tx: TaskManagerTx) { in log_all_task_info()
|
| D | app_state.rs | 30 pub(crate) fn init(client_manager: ClientManagerEntry, task_manager: TaskManagerTx) { in init()
|
| /base/request/request/services/src/manage/scheduler/queue/ |
| D | running_task.rs | 37 pub(crate) fn new(task: Arc<RequestTask>, tx: TaskManagerTx, keeper: SAKeeper) -> Self { in new()
|
| D | mod.rs | 56 tx: TaskManagerTx, in new()
|
| /base/request/request/services/src/service/ |
| D | stub.rs | 42 task_manager: TaskManagerTx, in new()
|
| /base/request/request/services/src/service/notification_bar/ |
| D | task_handle.rs | 138 pub(crate) fn subscribe_notification_bar(task_manager: TaskManagerTx) { in subscribe_notification_bar()
|
| /base/request/request/services/src/manage/scheduler/ |
| D | mod.rs | 68 tx: TaskManagerTx, in init()
|