Home
last modified time | relevance | path

Searched refs:task_manager (Results 1 – 25 of 48) sorted by relevance

12

/ohos5.0/base/request/request/services/src/manage/
H A Daccount.rs21 use crate::manage::task_manager::TaskManagerTx;
52 task_manager: TaskManagerTx, field
59 task_manager, in new()
93 self.task_manager in drop()
142 Box::new(task_manager.clone()), in registry_account_subscribe()
144 |_new_id, _old_id, task_manager| update_accounts(task_manager.clone()), in registry_account_subscribe()
161 Box::new(task_manager.clone()), in registry_account_subscribe()
162 |_id, task_manager| update_accounts(task_manager.clone()), in registry_account_subscribe()
181 |id, task_manager| { in registry_account_subscribe()
202 |_id, task_manager| update_accounts(task_manager.clone()), in registry_account_subscribe()
[all …]
H A Dapp_state.rs17 use super::task_manager::TaskManagerTx;
23 task_manager: TaskManagerTx, field
30 pub(crate) fn init(client_manager: ClientManagerEntry, task_manager: TaskManagerTx) { in init()
35 task_manager, in init()
58 .task_manager in app_state_change_callback()
65 .task_manager in app_state_change_callback()
81 .task_manager in process_died_callback()
H A Dnetwork.rs24 use super::task_manager::TaskManagerTx;
61 |task_manager| { in register_network_change()
62 task_manager.inner.send_event(TaskManagerEvent::network()); in register_network_change()
64 |task_manager| { in register_network_change()
65 task_manager.inner.send_event(TaskManagerEvent::network()); in register_network_change()
159 task_manager: Box<NetworkTaskManagerTx>, in RegisterNetworkChange()
H A Dmod.rs24 pub(crate) use task_manager::TaskManager;
29 pub(crate) mod task_manager; module
45 use crate::manage::task_manager::{TaskManagerRx, TaskManagerTx};
53 fn task_manager() -> TaskManager { in task_manager() function
79 let mut manager = task_manager(); in ut_manager_task_state_and_reason()
196 let mut manager = task_manager(); in ut_manager_state_change_error()
284 let mut manager = task_manager(); in ut_manager_reschedule()
/ohos5.0/base/request/request/services/include/
H A Daccount.h36 … 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_…
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_…
H A Dnetwork.h33 …questNetCallbackStub(rust::box<NetworkInner> network, rust::box<NetworkTaskManagerTx> task_manager,
34 rust::fn<void(const NetworkTaskManagerTx &task_manager)> notifyTaskManagerOnline,
35 rust::fn<void(const NetworkTaskManagerTx &task_manager)> notifyTaskManagerOffline);
48 rust::fn<void(const NetworkTaskManagerTx &task_manager)> notifyTaskManagerOnline_;
49 rust::fn<void(const NetworkTaskManagerTx &task_manager)> notifyTaskManagerOffline_;
65 rust::box<NetworkTaskManagerTx> task_manager,
66 rust::fn<void(const NetworkTaskManagerTx &task_manager)> notifyTaskManagerOnline,
67 rust::fn<void(const NetworkTaskManagerTx &task_manager)> notifyTaskManagerOffline);
/ohos5.0/base/request/request/services/src/
H A Dability.rs31 use crate::manage::task_manager::TaskManagerTx;
54 task_manager: Mutex<Option<TaskManagerTx>>, field
63 task_manager: Mutex::new(None), in new()
91 let task_manager = TaskManager::init(runcount_manager.clone(), client_manger.clone()); in init() localVariable
93 *self.task_manager.lock().unwrap() = Some(task_manager.clone()); in init()
97 AppStateListener::init(client_manger.clone(), task_manager.clone()); in init()
112 task_manager, in init()
161 if let Some(task_manager) = self.task_manager.lock().unwrap().as_ref() { in on_device_level_changed()
162 task_manager.send_event(TaskManagerEvent::Device(level)); in on_device_level_changed()
/ohos5.0/base/request/request/services/src/cxx/
H A Daccount.cpp28 …erWrapper::SubscriberWrapper(OS_ACCOUNT_SUBSCRIBE_TYPE type, rust::box<TaskManagerTx> task_manager, in SubscriberWrapper() argument
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()
33 task_manager_ = task_manager.into_raw(); in SubscriberWrapper()
55 int RegistryAccountSubscriber(OS_ACCOUNT_SUBSCRIBE_TYPE type, rust::box<TaskManagerTx> task_manager, in RegistryAccountSubscriber() argument
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()
60 …std::make_shared<SubscriberWrapper>(type, std::move(task_manager), on_accounts_changed, on_account… in RegistryAccountSubscriber()
H A Dnetwork.cpp45 rust::box<NetworkInner> network, rust::box<NetworkTaskManagerTx> task_manager, in RequestNetCallbackStub() argument
46 rust::fn<void(const NetworkTaskManagerTx &task_manager)> notifyTaskManagerOnline, in RequestNetCallbackStub()
47 rust::fn<void(const NetworkTaskManagerTx &task_manager)> notifyTaskManagerOffline in RequestNetCallbackStub()
52 task_manager_ = task_manager.into_raw(); in RequestNetCallbackStub()
186 rust::box<NetworkTaskManagerTx> task_manager, in RegisterNetworkChange() argument
187 rust::fn<void(const NetworkTaskManagerTx &task_manager)> notifyTaskManagerOnline, in RegisterNetworkChange()
188 rust::fn<void(const NetworkTaskManagerTx &task_manager)> notifyTaskManagerOffline) in RegisterNetworkChange()
192 … std::move(notifier), std::move(task_manager), notifyTaskManagerOnline, notifyTaskManagerOffline); in RegisterNetworkChange()
/ohos5.0/base/request/request/services/src/manage/scheduler/state/
H A Dmod.rs23 use crate::manage::task_manager::TaskManagerTx;
34 task_manager: TaskManagerTx, field
38 pub(crate) fn new(task_manager: TaskManagerTx) -> Self { in new()
42 task_manager, in new()
105 let task_manager = self.task_manager.clone(); in update_background() localVariable
110 task_manager.trigger_background_timeout(uid); in update_background()
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/
H A DBUILD.gn36 "src/base/task_manager/task_group/base_task_group.cpp",
37 "src/base/task_manager/task_group/delayed_task_group.cpp",
38 "src/base/task_manager/task_group/task_group.cpp",
39 "src/base/task_manager/task_manager.cpp",
40 "src/base/task_manager/task_registry.cpp",
41 "src/base/task_manager/thread_pool.cpp",
42 "src/base/task_manager/thread_utils.cpp",
128 …{multimedia_camera_framework_path}/services/deferred_processing_service/include/base/task_manager",
129 …_camera_framework_path}/services/deferred_processing_service/include/base/task_manager/task_group",
/ohos5.0/foundation/multimedia/camera_framework/frameworks/native/camera/
H A DBUILD.gn42 …{multimedia_camera_framework_path}/services/deferred_processing_service/include/base/task_manager",
43 …_camera_framework_path}/services/deferred_processing_service/include/base/task_manager/task_group",
76 …"${multimedia_camera_framework_path}/services/deferred_processing_service/src/base/task_manager/ta…
77 …"${multimedia_camera_framework_path}/services/deferred_processing_service/src/base/task_manager/ta…
78 …"${multimedia_camera_framework_path}/services/deferred_processing_service/src/base/task_manager/ta…
79 …amera_framework_path}/services/deferred_processing_service/src/base/task_manager/task_manager.cpp",
80 …"${multimedia_camera_framework_path}/services/deferred_processing_service/src/base/task_manager/ta…
81 …"${multimedia_camera_framework_path}/services/deferred_processing_service/src/base/task_manager/th…
82 …"${multimedia_camera_framework_path}/services/deferred_processing_service/src/base/task_manager/th…
/ohos5.0/foundation/multimedia/camera_framework/frameworks/native/camera/test/unittest/
H A DBUILD.gn32 …{multimedia_camera_framework_path}/services/deferred_processing_service/include/base/task_manager",
33 …_camera_framework_path}/services/deferred_processing_service/include/base/task_manager/task_group",
116 …{multimedia_camera_framework_path}/services/deferred_processing_service/include/base/task_manager",
117 …_camera_framework_path}/services/deferred_processing_service/include/base/task_manager/task_group",
210 …{multimedia_camera_framework_path}/services/deferred_processing_service/include/base/task_manager",
211 …_camera_framework_path}/services/deferred_processing_service/include/base/task_manager/task_group",
259 …"${multimedia_camera_framework_path}/services/deferred_processing_service/src/base/task_manager/ta…
260 …amera_framework_path}/services/deferred_processing_service/src/base/task_manager/task_manager.cpp",
261 …"${multimedia_camera_framework_path}/services/deferred_processing_service/src/base/task_manager/ta…
262 …"${multimedia_camera_framework_path}/services/deferred_processing_service/src/base/task_manager/th…
[all …]
/ohos5.0/base/request/request/services/src/service/
H A Dstub.rs27 use crate::manage::task_manager::TaskManagerTx;
32 pub(crate) task_manager: Mutex<TaskManagerTx>,
42 task_manager: TaskManagerTx, in new()
48 task_manager: Mutex::new(task_manager), in new()
/ohos5.0/base/request/request/services/src/manage/scheduler/
H A Dmod.rs30 use crate::manage::task_manager::TaskManagerTx;
62 task_manager: TaskManagerTx, field
86 task_manager: tx, in init()
371 let task_manager = self.task_manager.clone(); in schedule_if_not_scheduled() localVariable
372 task_manager.send_event(TaskManagerEvent::Reschedule); in schedule_if_not_scheduled()
/ohos5.0/base/request/request/services/src/service/command/
H A Ddump.rs64 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()
H A Dtouch.rs38 let info = self.task_manager.lock().unwrap().touch(uid, task_id, token); in touch()
H A Dshow.rs43 let info = self.task_manager.lock().unwrap().show(uid, task_id); in show()
H A Dstop.rs39 if !self.task_manager.lock().unwrap().send_event(event) { in stop()
H A Dresume.rs50 if !self.task_manager.lock().unwrap().send_event(event) { in resume()
H A Dstart.rs47 if !self.task_manager.lock().unwrap().send_event(event) { in start()
/ohos5.0/foundation/systemabilitymgr/samgr_lite/samgr/source/
H A DBUILD.gn34 "task_manager.c",
62 "task_manager.c",
/ohos5.0/foundation/multimedia/camera_framework/frameworks/native/camera/test/moduletest/
H A DBUILD.gn33 …{multimedia_camera_framework_path}/services/deferred_processing_service/include/base/task_manager",
34 …_camera_framework_path}/services/deferred_processing_service/include/base/task_manager/task_group",
/ohos5.0/foundation/multimedia/camera_framework/test/fuzztest/cameradevice_fuzzer/
H A DBUILD.gn37 …{multimedia_camera_framework_path}/services/deferred_processing_service/include/base/task_manager",
38 …_camera_framework_path}/services/deferred_processing_service/include/base/task_manager/task_group",
/ohos5.0/foundation/multimedia/camera_framework/test/fuzztest/deferredprocessingstub_fuzzer/
H A DBUILD.gn36 …{multimedia_camera_framework_path}/services/deferred_processing_service/include/base/task_manager",
37 …_camera_framework_path}/services/deferred_processing_service/include/base/task_manager/task_group",

12