Home
last modified time | relevance | path

Searched refs:scheduler (Results 1 - 25 of 110) sorted by relevance

12345

/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()
38 HILOG_ERROR(HILOG_MODULE_APP, "ams call back error, scheduler is null"); 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 in AmsCallback()
[all...]
/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()
/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 std::shared_ptr<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()
H A Dwifi_direct_executor.cpp29 WifiDirectExecutor::WifiDirectExecutor(const std::string &remoteDeviceId, WifiDirectScheduler &scheduler, in WifiDirectExecutor() argument
31 : remoteDeviceId_(remoteDeviceId), scheduler_(scheduler), processor_(processor), active_(active), started_(false) in WifiDirectExecutor()
/foundation/ability/ability_runtime/test/unittest/app_running_record_test/
H A Dchild_process_record_test.cpp189 sptr<IChildScheduler> scheduler; in HWTEST_F() local
190 childRecord->SetScheduler(scheduler); in HWTEST_F()
206 sptr<IChildScheduler> scheduler; in HWTEST_F() local
207 childRecord->SetScheduler(scheduler); in HWTEST_F()
208 EXPECT_EQ(childRecord->GetScheduler(), scheduler); in HWTEST_F()
240 sptr<IChildScheduler> scheduler; in HWTEST_F() local
241 childRecord->SetScheduler(scheduler); in HWTEST_F()
276 sptr<IChildScheduler> scheduler; in HWTEST_F() local
277 childRecord->SetScheduler(scheduler); in HWTEST_F()
294 sptr<IChildScheduler> scheduler; in HWTEST_F() local
[all...]
/foundation/arkui/ace_engine/frameworks/core/animation/
H A Dinterpolator.h21 #include "core/animation/scheduler.h"
66 auto scheduler = weakScheduler.Upgrade(); in RunAsync() local
67 if (scheduler == nullptr) { in RunAsync()
68 LOGE("run async failed, scheduler is null."); in RunAsync()
76 return scheduler->Animate( in RunAsync()
H A Dkeyframe_animation.h105 auto scheduler = weakScheduler.Upgrade(); variable
106 if (scheduler == nullptr) {
107 LOGE("run async failed, scheduler is null!");
111 scheduler->OpenImplicitAnimation(option, Curves::EASE, finishCallback);
120 scheduler->AddKeyFrame(
136 return scheduler->CloseImplicitAnimation();
H A Dscheduler.cpp16 #include "core/animation/scheduler.h"
38 auto scheduler = weak.Upgrade(); in Start()
39 CHECK_NULL_VOID(scheduler); in Start()
40 scheduler->OnFrame(nanoTimestamp); in Start()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_deep_test.cpp200 static int CreateBufferThenAddIntoScheduler(SendTaskScheduler &scheduler, const std::string &dstTarget, Priority inPrio) in CreateBufferThenAddIntoScheduler() argument
213 errCode = scheduler.AddSendTaskIntoSchedule(task, inPrio); in CreateBufferThenAddIntoScheduler()
232 SendTaskScheduler scheduler; in HWTEST_F() local
233 scheduler.Initialize(); in HWTEST_F()
238 int errCode = CreateBufferThenAddIntoScheduler(scheduler, DEVICE_NAME_A, Priority::LOW); in HWTEST_F()
244 errCode = CreateBufferThenAddIntoScheduler(scheduler, DEVICE_NAME_B, Priority::LOW); in HWTEST_F()
250 errCode = CreateBufferThenAddIntoScheduler(scheduler, DEVICE_NAME_B, Priority::NORMAL); in HWTEST_F()
256 errCode = CreateBufferThenAddIntoScheduler(scheduler, DEVICE_NAME_C, Priority::NORMAL); in HWTEST_F()
262 errCode = CreateBufferThenAddIntoScheduler(scheduler, DEVICE_NAME_C, Priority::HIGH); in HWTEST_F()
268 errCode = CreateBufferThenAddIntoScheduler(scheduler, DEVICE_NAME_ in HWTEST_F()
[all...]
/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()
/foundation/ability/ability_runtime/services/abilitymgr/include/
H A Ddata_ability_manager.h40 int Release(const sptr<IAbilityScheduler> &scheduler, const sptr<IRemoteObject> &client, bool isNotHap);
41 int AttachAbilityThread(const sptr<IAbilityScheduler> &scheduler, const sptr<IRemoteObject> &token);
48 std::shared_ptr<AbilityRecord> GetAbilityRecordByScheduler(const sptr<IAbilityScheduler> &scheduler);
52 bool ContainsDataAbility(const sptr<IAbilityScheduler> &scheduler);
/foundation/systemabilitymgr/samgr/test/fuzztest/samgrdumper_fuzzer/
H A Dsamgrdumper_fuzzer.cpp60 std::shared_ptr<SystemAbilityStateScheduler> scheduler = std::make_shared<SystemAbilityStateScheduler>(); 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()
/foundation/ability/ability_runtime/services/abilitymgr/src/data_ability/
H A Ddata_ability_manager.cpp95 auto scheduler = dataAbilityRecord->GetScheduler(); in Acquire() local
96 if (!scheduler) { in Acquire()
118 return scheduler; in Acquire()
122 const sptr<IAbilityScheduler> &scheduler, const sptr<IRemoteObject> &client, bool isNotHap) in Release()
126 CHECK_POINTER_AND_RETURN(scheduler, ERR_NULL_OBJECT); in Release()
139 it->second->GetScheduler()->AsObject() == scheduler->AsObject()) { in Release()
177 bool DataAbilityManager::ContainsDataAbility(const sptr<IAbilityScheduler> &scheduler) in ContainsDataAbility() argument
181 CHECK_POINTER_AND_RETURN(scheduler, ERR_NULL_OBJECT); in ContainsDataAbility()
186 it->second->GetScheduler()->AsObject() == scheduler->AsObject()) { in ContainsDataAbility()
194 int DataAbilityManager::AttachAbilityThread(const sptr<IAbilityScheduler> &scheduler, cons argument
121 Release( const sptr<IAbilityScheduler> &scheduler, const sptr<IRemoteObject> &client, bool isNotHap) Release() argument
421 GetAbilityRecordByScheduler(const sptr<IAbilityScheduler> &scheduler) GetAbilityRecordByScheduler() argument
[all...]
/foundation/ability/ability_runtime/test/unittest/ability_record_test/
H A Dability_record_test_call.cpp192 OHOS::sptr<AbilitySchedulerMockFunction> scheduler = new AbilitySchedulerMockFunction(); in HWTEST_F() local
193 sptr<IRemoteObject> object = scheduler->CallRequestModify(); in HWTEST_F()
298 OHOS::sptr<AbilitySchedulerMockFunction> scheduler = new AbilitySchedulerMockFunction(); in HWTEST_F() local
301 abilityRecord_->SetScheduler(scheduler); in HWTEST_F()
320 OHOS::sptr<AbilitySchedulerMock> scheduler = new AbilitySchedulerMock(); in HWTEST_F() local
323 abilityRecord_->SetScheduler(scheduler); in HWTEST_F()
/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()
/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()
/foundation/ability/ability_runtime/test/fuzztest/releasedataability_fuzzer/
H A Dreleasedataability_fuzzer.cpp50 sptr<IAbilityScheduler> scheduler; in DoSomethingInterestingWithMyAPI() local
62 if (abilitymgr->ReleaseDataAbility(scheduler, token) != 0) { in DoSomethingInterestingWithMyAPI()
/foundation/ability/ability_runtime/test/unittest/call_container_test/
H A Dcall_container_test.cpp155 OHOS::sptr<IAbilityScheduler> scheduler = new AbilitySchedulerMock(); in HWTEST_F() local
156 abilityRecord_->SetScheduler(scheduler); in HWTEST_F()
157 scheduler->CallRequest(); in HWTEST_F()
178 auto scheduler = new AbilitySchedulerMockFunction(); in HWTEST_F() local
179 sptr<IRemoteObject> object = scheduler->CallRequestModify(); in HWTEST_F()
/foundation/communication/dsoftbus/tests/core/connection/wifi_direct_cpp/processor/
H A Dp2p_v1_processor_test.cpp508 WifiDirectScheduler &scheduler = WifiDirectSchedulerFactory::GetInstance().GetScheduler(); in HWTEST_F() local
509 auto ret = scheduler.ConnectDevice(info, callback); in HWTEST_F()
575 WifiDirectScheduler &scheduler = WifiDirectSchedulerFactory::GetInstance().GetScheduler(); in HWTEST_F() local
576 auto ret = scheduler.ConnectDevice(info, callback); in HWTEST_F()
623 WifiDirectScheduler &scheduler = WifiDirectSchedulerFactory::GetInstance().GetScheduler(); in HWTEST_F() local
624 auto ret = scheduler.ConnectDevice(info, callback); in HWTEST_F()
665 WifiDirectScheduler &scheduler = WifiDirectSchedulerFactory::GetInstance().GetScheduler(); in HWTEST_F() local
666 auto ret = scheduler.ConnectDevice(info, callback); in HWTEST_F()
707 WifiDirectScheduler &scheduler = WifiDirectSchedulerFactory::GetInstance().GetScheduler(); in HWTEST_F() local
708 auto ret = scheduler in HWTEST_F()
758 WifiDirectScheduler &scheduler = WifiDirectSchedulerFactory::GetInstance().GetScheduler(); HWTEST_F() local
801 WifiDirectScheduler &scheduler = WifiDirectSchedulerFactory::GetInstance().GetScheduler(); HWTEST_F() local
818 WifiDirectScheduler &scheduler = WifiDirectSchedulerFactory::GetInstance().GetScheduler(); InspectProcessorState() local
983 WifiDirectScheduler &scheduler = WifiDirectSchedulerFactory::GetInstance().GetScheduler(); HWTEST_F() local
1073 WifiDirectScheduler &scheduler = WifiDirectSchedulerFactory::GetInstance().GetScheduler(); HWTEST_F() local
1448 WifiDirectScheduler &scheduler = WifiDirectSchedulerFactory::GetInstance().GetScheduler(); HWTEST_F() local
[all...]
/foundation/ability/ability_runtime/test/fuzztest/abilitymanagerservicethird_fuzzer/
H A Dabilitymanagerservicethird_fuzzer.cpp81 sptr<IAbilityScheduler> scheduler; in DoSomethingInterestingWithMyAPI() local
82 abilityms->GetDataAbilityManager(scheduler); in DoSomethingInterestingWithMyAPI()
/foundation/ability/ability_runtime/test/mock/frameworks_kits_ability_native_test/include/
H A Dmock_ability_manager_service.cpp102 const sptr<IAbilityScheduler>& scheduler, const sptr<IRemoteObject>& token) in AttachAbilityThread()
104 abilityScheduler_ = scheduler; in AttachAbilityThread()
101 AttachAbilityThread( const sptr<IAbilityScheduler>& scheduler, const sptr<IRemoteObject>& token) AttachAbilityThread() argument
/foundation/ability/ability_runtime/test/fuzztest/abilitychildprocessrecord_fuzzer/
H A Dabilitychildprocessrecord_fuzzer.cpp67 sptr<IChildScheduler> scheduler; in DoSomethingInterestingWithMyAPI() local
68 childRecord->SetScheduler(scheduler); in DoSomethingInterestingWithMyAPI()
/foundation/distributeddatamgr/data_share/interfaces/inner_api/common/include/
H A Ddatashare_template.h44 const std::string &scheduler) : predicates_(predicates), scheduler_(scheduler) {} in Template()
47 /** Specifies the scheduler sql of the template. */
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dexecutor_pool.h59 std::shared_ptr<Executor> scheduler; in ~ExecutorPool() local
62 scheduler = std::move(scheduler_); in ~ExecutorPool()
64 if (scheduler != nullptr) { in ~ExecutorPool()
65 scheduler->Stop(true); in ~ExecutorPool()

Completed in 11 milliseconds

12345