| /foundation/ability/ability_runtime/frameworks/native/ability/native/continuation/distributed/ |
| H A D | reverse_continuation_scheduler_primary.cpp | 25 : continuationHandler_(continuationHandler), mainHandler_(mainHandler) in ReverseContinuationSchedulerPrimary()
81 continuationHandler = continuationHandler_.lock(); in HandlerNotifyReplicaTerminated()
93 continuationHandler = continuationHandler_.lock(); in HandlerContinuationBack()
|
| H A D | reverse_continuation_scheduler_primary_stage.cpp | 26 : continuationHandler_(continuationHandler), mainHandler_(mainHandler) in ReverseContinuationSchedulerPrimaryStage()
83 std::shared_ptr<IReverseContinuationSchedulerPrimaryHandler> continuationHandler = continuationHandler_.lock(); in HandlerNotifyReplicaTerminated()
94 std::shared_ptr<IReverseContinuationSchedulerPrimaryHandler> continuationHandler = continuationHandler_.lock(); in HandlerContinuationBack()
|
| H A D | continuation_manager_stage.cpp | 79 continuationHandler_ = continuationHandler; in Init()
109 auto task = [continuationHandlerWeak = continuationHandler_, continueTokenWeak, deviceId, versionCode]() { in HandleContinueAbilityWithStack()
274 std::shared_ptr<ContinuationHandlerStage> continuationHandler = continuationHandler_.lock(); in ReverseContinueAbility()
276 TAG_LOGE(AAFwkTag::CONTINUATION, "continuationHandler_ is nullptr"); in ReverseContinueAbility()
415 std::shared_ptr<ContinuationHandlerStage> continuationHandler = continuationHandler_.lock(); in HandleContinueAbility()
424 auto task = [continuationHandlerWeak = continuationHandler_, continueTokeWeak, deviceId]() { in HandleContinueAbility()
|
| H A D | continuation_manager.cpp | 78 continuationHandler_ = continuationHandler; in Init()
105 std::shared_ptr<ContinuationHandler> continuationHandler = continuationHandler_.lock(); in HandleContinueAbilityWithStack()
270 std::shared_ptr<ContinuationHandler> continuationHandler = continuationHandler_.lock(); in ReverseContinueAbility()
273 "continuationHandler_ is nullptr"); in ReverseContinueAbility()
410 std::shared_ptr<ContinuationHandler> continuationHandler = continuationHandler_.lock(); in HandleContinueAbility()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/ |
| H A D | distributed_sched_continuation.cpp | 36 continuationHandler_ = std::make_shared<ContinuationHandler>(runner, shared_from_this(), contCallback);
in Init()
52 if (continuationHandler_ == nullptr) {
in PushAbilityToken()
59 ret = continuationHandler_->SendEvent(sessionId, 0, CONTINUATION_DELAY_TIME);
in PushAbilityToken()
89 if (continuationHandler_ != nullptr) {
in PopAbilityToken()
90 continuationHandler_->RemoveEvent(sessionId);
in PopAbilityToken()
107 if (continuationHandler_ == nullptr) {
in SetTimeOut()
111 continuationHandler_->SendEvent(missionId, 0, timeout);
in SetTimeOut()
116 if (continuationHandler_ == nullptr) {
in RemoveTimeOut()
120 continuationHandler_->RemoveEvent(missionId);
in RemoveTimeOut()
158 if (continuationHandler_ in PushCallback()
[all...] |
| /foundation/ability/dmsfwk/services/dtbabilitymgr/test/unittest/ |
| H A D | distributed_ability_manager_service_test.cpp | 72 if (dtbabilitymgrService_ != nullptr && dtbabilitymgrService_->continuationHandler_ != nullptr) { in TearDownTestCase()
73 dtbabilitymgrService_->continuationHandler_->submit(caseDoneNotifyTask); in TearDownTestCase()
627 if (dtbabilitymgrService_->continuationHandler_ == nullptr) { in HWTEST_F()
628 dtbabilitymgrService_->continuationHandler_ = std::make_shared<ffrt::queue>("ContinuationMgr"); in HWTEST_F()
698 * @tc.desc: test HandleDeviceConnect when continuationHandler_ == nullptr.
706 dtbabilitymgrService_->continuationHandler_ = nullptr; in HWTEST_F()
730 if (dtbabilitymgrService_->continuationHandler_ == nullptr) { in HWTEST_F()
731 dtbabilitymgrService_->continuationHandler_ = std::make_shared<ffrt::queue>("ContinuationMgr"); in HWTEST_F()
742 * @tc.desc: test HandleDeviceDisconnect when continuationHandler_ != nullptr.
751 * @tc.steps: step1. test HandleUpdateConnectStatus when continuationHandler_ i in HWTEST_F()
[all...] |
| /foundation/ability/dmsfwk/services/dtbabilitymgr/src/ |
| H A D | distributed_ability_manager_service.cpp | 70 if (continuationHandler_ == nullptr) { in OnStart()
71 continuationHandler_ = std::make_shared<ffrt::queue>("ContinuationMgr"); in OnStart()
490 if (continuationHandler_ == nullptr) { in HandleDisconnectAbility()
502 continuationHandler_->submit(func); in HandleDisconnectAbility()
586 if (continuationHandler_ == nullptr) { in HandleDeviceConnect()
587 HILOGE("continuationHandler_ is nullptr"); in HandleDeviceConnect()
599 continuationHandler_->submit(func); in HandleDeviceConnect()
606 if (continuationHandler_ == nullptr) { in HandleDeviceDisconnect()
607 HILOGE("continuationHandler_ is nullptr"); in HandleDeviceDisconnect()
619 continuationHandler_ in HandleDeviceDisconnect()
[all...] |
| /foundation/ability/ability_runtime/interfaces/kits/native/ability/native/continuation/distributed/ |
| H A D | reverse_continuation_scheduler_primary.h | 49 std::weak_ptr<IReverseContinuationSchedulerPrimaryHandler> continuationHandler_; member in OHOS::AppExecFwk::ReverseContinuationSchedulerPrimary
|
| H A D | reverse_continuation_scheduler_primary_stage.h | 49 std::weak_ptr<IReverseContinuationSchedulerPrimaryHandler> continuationHandler_; member in OHOS::AppExecFwk::ReverseContinuationSchedulerPrimaryStage
|
| H A D | continuation_manager_stage.h | 209 std::weak_ptr<ContinuationHandlerStage> continuationHandler_; member in OHOS::AppExecFwk::ContinuationManagerStage
|
| H A D | continuation_manager.h | 121 std::weak_ptr<ContinuationHandler> continuationHandler_; member in OHOS::AppExecFwk::ContinuationManager
|
| /foundation/bundlemanager/app_domain_verify/services/include/manager/rdb/ |
| H A D | app_domain_verify_rdb_data_manager.h | 62 std::shared_ptr<ffrt::queue> continuationHandler_; member in OHOS::AppDomainVerify::AppDomainVerifyRdbDataManager
|
| /foundation/bundlemanager/app_domain_verify/services/src/manager/rdb/ |
| H A D | app_domain_verify_rdb_data_manager.cpp | 203 if (continuationHandler_ == nullptr) { in DelayCloseRdbStore()
204 continuationHandler_ = std::make_shared<ffrt::queue>("RdbContinuationMgr"); in DelayCloseRdbStore()
218 continuationHandler_->submit(func); in DelayCloseRdbStore()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/include/ |
| H A D | distributed_sched_continuation.h | 76 std::shared_ptr<ContinuationHandler> continuationHandler_;
member in OHOS::DistributedSchedule::DSchedContinuation
|
| /foundation/ability/dmsfwk/services/dtbabilitymgr/include/ |
| H A D | distributed_ability_manager_service.h | 93 std::shared_ptr<ffrt::queue> continuationHandler_; member in OHOS::DistributedSchedule::DistributedAbilityManagerService
|
| /foundation/ability/ability_runtime/frameworks/native/ability/native/ |
| H A D | ui_ability.cpp | 91 continuationHandler_ = in Init()
93 if (!continuationManager_->Init(shared_from_this(), GetToken(), GetAbilityInfo(), continuationHandler_)) { in Init()
96 std::weak_ptr<AppExecFwk::ContinuationHandlerStage> continuationHandler = continuationHandler_; in Init()
102 continuationHandler_->SetPrimaryStub(primary); in Init()
103 continuationHandler_->SetAbilityInfo(abilityInfo_); in Init()
|
| H A D | ability.cpp | 114 continuationHandler_ = std::make_shared<ContinuationHandler>(continuationManager, ability); in Init()
115 if (!continuationManager_->Init(shared_from_this(), GetToken(), GetAbilityInfo(), continuationHandler_)) { in Init()
118 std::weak_ptr<ContinuationHandler> continuationHandler = continuationHandler_; in Init()
124 continuationHandler_->SetPrimaryStub(primary); in Init()
125 continuationHandler_->SetAbilityInfo(abilityInfo_); in Init()
983 std::weak_ptr<IReverseContinuationSchedulerReplicaHandler> ReplicaHandler = continuationHandler_; in HandleCreateAsContinuation()
|
| /foundation/bundlemanager/app_domain_verify/test/unittest/services/app_domain_verify_rdb_test/ |
| H A D | app_domain_verify_rdb_data_manager_test.cpp | 493 appDomainVerifyRdbDataManager->continuationHandler_ = nullptr; in HWTEST_F()
495 EXPECT_NE(appDomainVerifyRdbDataManager->continuationHandler_, nullptr); in HWTEST_F()
|
| /foundation/ability/ability_runtime/interfaces/kits/native/ability/native/ |
| H A D | ui_ability.h | 358 std::shared_ptr<AppExecFwk::ContinuationHandlerStage> continuationHandler_ = nullptr; member in OHOS::AbilityRuntime::UIAbility
|
| H A D | ability.h | 1350 std::shared_ptr<ContinuationHandler> continuationHandler_ = nullptr; member in OHOS::AppExecFwk::Ability
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/ |
| H A D | distributed_sched_continuation_test.cpp | 735 dschedContinuation_->continuationHandler_ = nullptr;
in HWTEST_F()
776 EXPECT_NE(dschedContinuation_->continuationHandler_, nullptr);
in HWTEST_F()
795 EXPECT_NE(dschedContinuation_->continuationHandler_, nullptr);
in HWTEST_F()
|