| /ohos5.0/base/request/request/services/include/ |
| H A D | account.h | 33 struct TaskManagerTx;
36 … explicit SubscriberWrapper(OS_ACCOUNT_SUBSCRIBE_TYPE type, rust::box<TaskManagerTx> task_manager,
37 rust::fn<void(const int &id, const TaskManagerTx &task_manager)> on_accounts_changed,
38 …rust::fn<void(const int &newId, const int &oldId, const TaskManagerTx &task_manager)> on_accounts_…
46 TaskManagerTx *task_manager_;
47 rust::fn<void(const int &id, const TaskManagerTx &task_manager)> on_accounts_changed_;
48 …rust::fn<void(const int &newId, const int &oldId, const TaskManagerTx &task_manager)> on_accounts_…
51 int RegistryAccountSubscriber(OS_ACCOUNT_SUBSCRIBE_TYPE type, rust::box<TaskManagerTx> task_manager,
52 rust::fn<void(const int &id, const TaskManagerTx &task_manager)> on_accounts_changed,
53 …rust::fn<void(const int &newId, const int &oldId, const TaskManagerTx &task_manager)> on_accounts_…
|
| /ohos5.0/base/request/request/services/src/cxx/ |
| H A D | account.cpp | 28 SubscriberWrapper::SubscriberWrapper(OS_ACCOUNT_SUBSCRIBE_TYPE type, rust::box<TaskManagerTx> task_… in SubscriberWrapper()
29 rust::fn<void(const int &id, const TaskManagerTx &task_manager)> on_accounts_changed, in SubscriberWrapper()
30 …rust::fn<void(const int &newId, const int &oldId, const TaskManagerTx &task_manager)> on_accounts_… in SubscriberWrapper()
40 rust::box<TaskManagerTx>::from_raw(task_manager_); in ~SubscriberWrapper()
55 int RegistryAccountSubscriber(OS_ACCOUNT_SUBSCRIBE_TYPE type, rust::box<TaskManagerTx> task_manager, in RegistryAccountSubscriber()
56 rust::fn<void(const int &id, const TaskManagerTx &task_manager)> on_accounts_changed, in RegistryAccountSubscriber()
57 …rust::fn<void(const int &newId, const int &oldId, const TaskManagerTx &task_manager)> on_accounts_… in RegistryAccountSubscriber()
|
| /ohos5.0/base/request/request/services/src/manage/ |
| H A D | account.rs | 21 use crate::manage::task_manager::TaskManagerTx;
33 static mut TASK_MANAGER_TX: Option<TaskManagerTx> = None;
41 pub(crate) fn update_accounts(task_manager: TaskManagerTx) { in update_accounts() argument
52 task_manager: TaskManagerTx,
56 fn new(task_manager: TaskManagerTx) -> Self { in new()
130 pub(crate) fn registry_account_subscribe(task_manager: TaskManagerTx) { in registry_account_subscribe() argument
246 type TaskManagerTx; typedef
260 task_manager: Box<TaskManagerTx>, in RegistryAccountSubscriber() argument
261 on_accounts_changed: fn(&i32, task_manager: &TaskManagerTx), in RegistryAccountSubscriber() argument
285 let task_manager = TaskManagerTx { tx }; in ut_account_check_oh()
[all …]
|
| H A D | task_manager.rs | 73 ) -> TaskManagerTx { in init() argument
77 let tx = TaskManagerTx::new(tx); in init()
124 tx: TaskManagerTx, in new() argument
347 pub struct TaskManagerTx { struct
351 impl TaskManagerTx { implementation
433 async fn restore_all_tasks(tx: TaskManagerTx) { in restore_all_tasks() argument
438 async fn clear_timeout_tasks(tx: TaskManagerTx) { in clear_timeout_tasks() argument
445 async fn log_all_task_info(tx: TaskManagerTx) { in log_all_task_info() argument
|
| H A D | app_state.rs | 17 use super::task_manager::TaskManagerTx;
23 task_manager: TaskManagerTx,
30 pub(crate) fn init(client_manager: ClientManagerEntry, task_manager: TaskManagerTx) { in init() argument
|
| H A D | network_manager.rs | 21 use super::task_manager::TaskManagerTx;
26 pub(crate) tx: Option<TaskManagerTx>,
|
| H A D | network.rs | 24 use super::task_manager::TaskManagerTx;
94 inner: TaskManagerTx,
|
| H A D | mod.rs | 45 use crate::manage::task_manager::{TaskManagerRx, TaskManagerTx};
55 let task_manager_tx = TaskManagerTx::new(tx); in task_manager()
|
| H A D | notifier.rs | 100 use crate::manage::task_manager::{TaskManagerRx, TaskManagerTx};
112 let task_manager_tx = TaskManagerTx::new(tx); in init_manager()
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/queue/ |
| H A D | running_task.rs | 21 use crate::manage::task_manager::TaskManagerTx;
30 tx: TaskManagerTx,
36 pub(crate) fn new(task: Arc<RequestTask>, tx: TaskManagerTx, keeper: SAKeeper) -> Self { in new() argument
|
| H A D | keeper.rs | 21 use crate::manage::task_manager::TaskManagerTx;
37 pub(crate) fn new(tx: TaskManagerTx) -> Self { in new()
|
| H A D | mod.rs | 33 use crate::manage::task_manager::TaskManagerTx;
47 tx: TaskManagerTx,
56 tx: TaskManagerTx, in new() argument
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/state/ |
| H A D | mod.rs | 23 use crate::manage::task_manager::TaskManagerTx;
34 task_manager: TaskManagerTx,
38 pub(crate) fn new(task_manager: TaskManagerTx) -> Self { in new()
|
| /ohos5.0/base/request/request/services/src/ |
| H A D | ability.rs | 31 use crate::manage::task_manager::TaskManagerTx;
54 task_manager: Mutex<Option<TaskManagerTx>>,
|
| /ohos5.0/base/request/request/services/src/service/ |
| H A D | stub.rs | 27 use crate::manage::task_manager::TaskManagerTx;
32 pub(crate) task_manager: Mutex<TaskManagerTx>,
42 task_manager: TaskManagerTx, in new() argument
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/ |
| H A D | mod.rs | 30 use crate::manage::task_manager::TaskManagerTx;
62 task_manager: TaskManagerTx,
67 tx: TaskManagerTx, in init() argument
|
| /ohos5.0/base/request/request/services/src/manage/events/ |
| H A D | mod.rs | 235 use crate::manage::task_manager::TaskManagerTx;
244 static TASK_MANGER: Lazy<TaskManagerTx> =
|
| /ohos5.0/base/request/request/services/src/task/ |
| H A D | download.rs | 281 use crate::manage::task_manager::TaskManagerTx;
298 static TASK_MANGER: Lazy<TaskManagerTx> = Lazy::new(|| { in build_task()
|