Home
last modified time | relevance | path

Searched refs:scheduler (Results 1 – 25 of 235) sorted by relevance

12345678910

/ohos5.0/base/request/request/services/src/manage/
H A Dtask_manager.rs38 use crate::manage::scheduler::state::Handler;
39 use crate::manage::scheduler::Scheduler;
61 pub(crate) scheduler: Scheduler,
221 .scheduler in handle_state_event()
224 .scheduler in handle_state_event()
227 self.scheduler in handle_state_event()
258 self.scheduler in handle_task_event()
279 self.scheduler in handle_task_event()
306 self.scheduler.clear_timeout_tasks(); in clear_timeout_tasks()
310 self.scheduler.dump_tasks(); in log_all_task_info()
[all …]
H A Dmod.rs28 pub(crate) mod scheduler; module
170 manager.scheduler.reschedule(); in ut_manager_task_state_and_reason()
304 manager.scheduler.resort_scheduled = false; in ut_manager_reschedule()
310 manager.scheduler.resort_scheduled = false; in ut_manager_reschedule()
318 manager.scheduler.resort_scheduled = false; in ut_manager_reschedule()
324 manager.scheduler.resort_scheduled = false; in ut_manager_reschedule()
330 manager.scheduler.resort_scheduled = false; in ut_manager_reschedule()
/ohos5.0/base/msdp/device_status/rust/modules/scheduler/sys/src/
H A Dlib.rs31 mod scheduler; module
35 pub use scheduler::IEpollHandler;
36 pub use scheduler::{
49 use scheduler::Scheduler;
61 scheduler: Arc<Scheduler>, field
69 let scheduler = Arc::new(Scheduler::new()); in new() localVariable
73 scheduler, in new()
213 self.scheduler.add_epoll_handler(handler) in add_epoll_handler()
221 self.scheduler.remove_epoll_handler(handler) in remove_epoll_handler()
/ohos5.0/foundation/ability/ability_lite/frameworks/ability_lite/src/
H A Dability_scheduler.cpp29 AbilityScheduler::AbilityScheduler(AbilityEventHandler &eventHandler, Scheduler &scheduler) in AbilityScheduler() argument
30 : eventHandler_(eventHandler), scheduler_(scheduler) in AbilityScheduler()
36 auto scheduler = static_cast<AbilityScheduler *>(option.args); in AmsCallback() local
37 if (scheduler == nullptr) { in AmsCallback()
69 scheduler->PerformAppInit(appInfo); in AmsCallback()
84 scheduler->PerformTransactAbilityState(want, state, token, abilityType); in AmsCallback()
95 scheduler->PerformConnectAbility(want, token); in AmsCallback()
106 scheduler->PerformDisconnectAbility(want, token); in AmsCallback()
110 scheduler->PerformAppExit(); in AmsCallback()
122 scheduler->PerformDumpAbility(want, token); in AmsCallback()
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/
H A Ddps.cpp28 std::shared_ptr<SchedulerManager> scheduler; member
44 g_dpsInfo.scheduler = std::make_shared<SchedulerManager>(); in DPS_Initialize()
47 JUDEG(DP_NULL_POINTER, g_dpsInfo.scheduler != nullptr); in DPS_Initialize()
49 EXEC(g_dpsInfo.scheduler->Initialize()); in DPS_Initialize()
94 if (g_dpsInfo.scheduler) { in DPS_GetSchedulerManager()
95 return g_dpsInfo.scheduler; in DPS_GetSchedulerManager()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dworker.rs125 pub(crate) scheduler: Arc<MultiThreadScheduler>,
146 self.scheduler.wake_up_rand_one_if_last_search(); in run()
156 if !inner.is_searching && self.scheduler.is_waked_by_last_search(self.index) { in run()
169 self.scheduler.dequeue(inner, worker_ctx) in get_task()
186 self.scheduler.turn_to_sleep(inner, self.index); in park_timeout()
193 self.scheduler.turn_from_sleep(&self.index); in park_timeout()
197 if self.scheduler.is_parked(&self.index) { in park_timeout()
220 while !self.scheduler.has_no_work() {} in release()
259 self.is_cancel = worker.scheduler.is_cancel(); in check_cancel()
H A Dcurrent_thread.rs41 pub(crate) scheduler: Arc<CurrentThreadScheduler>,
240 scheduler: Default::default(), in new()
255 let scheduler = Arc::downgrade(&self.scheduler); in spawn() localVariable
256 let (task, handle) = Task::create_task(builder, scheduler, task, VirtualTableType::Ylong); in spawn()
258 let mut queue = self.scheduler.inner.lock().unwrap(); in spawn()
261 self.scheduler.count.fetch_add(1, AcqRel); in spawn()
263 let parker_list = self.scheduler.parker_list.lock().unwrap(); in spawn()
275 let mut parker_list = self.scheduler.parker_list.lock().unwrap(); in block_on()
294 while let Some(task) = self.scheduler.pop() { in block_on()
406 assert_eq!(spawner.scheduler.inner.lock().unwrap().len(), 0); in ut_current_thread_block_on()
/ohos5.0/foundation/ability/ability_runtime/test/unittest/app_running_record_test/
H A Dchild_process_record_test.cpp189 sptr<IChildScheduler> scheduler; variable
190 childRecord->SetScheduler(scheduler);
206 sptr<IChildScheduler> scheduler; variable
207 childRecord->SetScheduler(scheduler);
208 EXPECT_EQ(childRecord->GetScheduler(), scheduler);
240 sptr<IChildScheduler> scheduler; variable
241 childRecord->SetScheduler(scheduler);
276 sptr<IChildScheduler> scheduler; variable
277 childRecord->SetScheduler(scheduler);
294 sptr<IChildScheduler> scheduler; variable
[all …]
/ohos5.0/foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/
H A Dwifi_direct_executor_factory.h34 … WifiDirectScheduler &scheduler, std::shared_ptr<WifiDirectProcessor> &processor, bool active)>;
36 …<WifiDirectExecutor> NewExecutor(const std::string &remoteDeviceId, WifiDirectScheduler &scheduler, in NewExecutor() argument
40 std::make_shared<WifiDirectExecutor>(remoteDeviceId, scheduler, processor, active) : in NewExecutor()
41 executorGenerator_(remoteDeviceId, scheduler, processor, active); in NewExecutor()
H A Dwifi_direct_scheduler_factory.h40 void Register(const std::shared_ptr<WifiDirectScheduler> &scheduler) in Register() argument
42 scheduler_ = scheduler; in Register()
/ohos5.0/foundation/resourceschedule/work_scheduler/
H A DREADME.md14 …me performance, such as data learning when the device is idle, the work scheduler can be used. Whe…
53 2. The api of work scheduler for starting, stopping and querying.
57 …function startWork(work: WorkInfo): void; | work scheduler application …
58 …function stopWork(work: WorkInfo, needCancel?: boolean): void; | work scheduler cancel …
67 3. Callback api of work scheduler
76 When an application needs to perform tasks with low real-time performance, work scheduler can be us…
80 Adhere to the following constraints and rules when using work scheduler:
83 …ontrol on the work scheduler according to the bundle activity of the application, and limit the ex…
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_deep_test.cpp213 errCode = scheduler.AddSendTaskIntoSchedule(task, inPrio); in CreateBufferThenAddIntoScheduler()
232 SendTaskScheduler scheduler; variable
233 scheduler.Initialize();
284 errCode = scheduler.ScheduleOutSendTask(outTask, outTaskInfo, totalLength);
288 scheduler.FinalizeLastScheduleTask();
290 errCode = scheduler.ScheduleOutSendTask(outTask, outTaskInfo, totalLength);
294 scheduler.FinalizeLastScheduleTask();
300 scheduler.FinalizeLastScheduleTask();
306 scheduler.FinalizeLastScheduleTask();
312 scheduler.FinalizeLastScheduleTask();
[all …]
/ohos5.0/foundation/communication/dsoftbus/core/broadcast/
H A Dbroadcast.gni16 broadcast_inc = [ "$dsoftbus_root_path/core/broadcast/scheduler/interface" ]
29 "$dsoftbus_root_path/core/broadcast/scheduler/include",
33 "$dsoftbus_root_path/core/broadcast/scheduler/src/broadcast_scheduler.c",
36 …broadcast_src += [ "$dsoftbus_root_path/core/broadcast/scheduler/src/broadcast_scheduler_virtual.c…
/ohos5.0/foundation/ability/ability_runtime/test/fuzztest/dataabilitymanager_fuzzer/
H A Ddataabilitymanager_fuzzer.cpp83 sptr<IAbilityScheduler> scheduler; in DoSomethingInterestingWithMyAPI() local
84 dataAbilityManager->Release(scheduler, client, boolParam); in DoSomethingInterestingWithMyAPI()
85 dataAbilityManager->ContainsDataAbility(scheduler); in DoSomethingInterestingWithMyAPI()
86 dataAbilityManager->AttachAbilityThread(scheduler, token); in DoSomethingInterestingWithMyAPI()
94 dataAbilityManager->GetAbilityRecordByScheduler(scheduler); in DoSomethingInterestingWithMyAPI()
/ohos5.0/foundation/arkui/ace_engine/frameworks/core/animation/
H A Dkeyframe_animation.h105 auto scheduler = weakScheduler.Upgrade(); in RunAsync() local
106 if (scheduler == nullptr) { in RunAsync()
111 scheduler->OpenImplicitAnimation(option, Curves::EASE, finishCallback); in RunAsync()
120 scheduler->AddKeyFrame( in RunAsync()
136 return scheduler->CloseImplicitAnimation(); in RunAsync()
H A Dinterpolator.h66 auto scheduler = weakScheduler.Upgrade();
67 if (scheduler == nullptr) {
76 return scheduler->Animate(
H A Dscheduler.cpp38 auto scheduler = weak.Upgrade(); in Start() local
39 CHECK_NULL_VOID(scheduler); in Start()
40 scheduler->OnFrame(nanoTimestamp); in Start()
/ohos5.0/foundation/ability/ability_runtime/services/abilitymgr/include/
H A Ddata_ability_manager.h40 …int Release(const sptr<IAbilityScheduler> &scheduler, const sptr<IRemoteObject> &client, bool isNo…
41 …int AttachAbilityThread(const sptr<IAbilityScheduler> &scheduler, const sptr<IRemoteObject> &token…
48 …d::shared_ptr<AbilityRecord> GetAbilityRecordByScheduler(const sptr<IAbilityScheduler> &scheduler);
52 bool ContainsDataAbility(const sptr<IAbilityScheduler> &scheduler);
/ohos5.0/foundation/systemabilitymgr/samgr/test/fuzztest/samgrdumper_fuzzer/
H A Dsamgrdumper_fuzzer.cpp60 …std::shared_ptr<SystemAbilityStateScheduler> scheduler = std::make_shared<SystemAbilityStateSchedu… in SamgrDumperFuzzTest() local
62 SystemAbilityManagerDumper::FfrtDumpProc(scheduler, fd, args); in SamgrDumperFuzzTest()
63 SystemAbilityManagerDumper::Dump(scheduler, args, result); in SamgrDumperFuzzTest()
72 SystemAbilityManagerDumper::GetFfrtDumpInfoProc(scheduler, args, result); in SamgrDumperFuzzTest()
/ohos5.0/foundation/ability/ability_runtime/services/abilitymgr/src/
H A Ddata_ability_manager.cpp95 auto scheduler = dataAbilityRecord->GetScheduler(); in Acquire() local
96 if (!scheduler) { in Acquire()
118 return scheduler; in Acquire()
126 CHECK_POINTER_AND_RETURN(scheduler, ERR_NULL_OBJECT); in Release()
139 it->second->GetScheduler()->AsObject() == scheduler->AsObject()) { in Release()
181 CHECK_POINTER_AND_RETURN(scheduler, ERR_NULL_OBJECT); in ContainsDataAbility()
186 it->second->GetScheduler()->AsObject() == scheduler->AsObject()) { in ContainsDataAbility()
198 CHECK_POINTER_AND_RETURN(scheduler, ERR_NULL_OBJECT); in AttachAbilityThread()
242 return dataAbilityRecord->Attach(scheduler); in AttachAbilityThread()
425 CHECK_POINTER_AND_RETURN(scheduler, nullptr); in GetAbilityRecordByScheduler()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/data/
H A Dtemplate_data.cpp22 ret = ret && SetValue(node[GET_NAME(scheduler)], scheduler); in Marshal()
29 return ret && GetValue(node, GET_NAME(scheduler), scheduler); in Unmarshal()
32 TemplateNode::TemplateNode(const Template &tpl) : scheduler(tpl.scheduler_) in TemplateNode()
45 return Template(nodes, scheduler); in ToTemplate()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Dmod.rs99 scheduler: Weak<S>, in create_task()
108 let raw = Task::create_raw_task::<T, S>(builder, scheduler, task, virtual_table_type); in create_task()
116 scheduler: Weak<S>, in create_raw_task()
126 scheduler, in create_raw_task()
/ohos5.0/foundation/ability/ability_runtime/test/unittest/ability_record_test/
H A Dability_record_test_call.cpp192 OHOS::sptr<AbilitySchedulerMockFunction> scheduler = new AbilitySchedulerMockFunction(); variable
193 sptr<IRemoteObject> object = scheduler->CallRequestModify();
298 OHOS::sptr<AbilitySchedulerMockFunction> scheduler = new AbilitySchedulerMockFunction(); variable
301 abilityRecord_->SetScheduler(scheduler);
320 OHOS::sptr<AbilitySchedulerMock> scheduler = new AbilitySchedulerMock(); variable
323 abilityRecord_->SetScheduler(scheduler);
/ohos5.0/base/request/request/services/src/manage/events/
H A Ddump.rs19 self.scheduler in query_one_task()
36 .scheduler in query_all_task()
/ohos5.0/foundation/ability/ability_runtime/test/fuzztest/attachabilitythread_fuzzer/
H A Dattachabilitythread_fuzzer.cpp193 sptr<IAbilityScheduler> scheduler = new AbilitySchedulerFuzzTest(); in DoSomethingInterestingWithMyAPI() local
220 connectManager->AttachAbilityThreadLocked(scheduler, serviceToken); in DoSomethingInterestingWithMyAPI()
224 dataManager->AttachAbilityThread(scheduler, dataToken); in DoSomethingInterestingWithMyAPI()
227 if (abilitymgr->AttachAbilityThread(scheduler, token) != 0) { in DoSomethingInterestingWithMyAPI()

12345678910