Home
last modified time | relevance | path

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

/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/continue/state/sink_state/
H A Ddsched_continue_sink_start_state.cpp40 int32_t DSchedContinueSinkStartState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute() argument
54 int32_t ret = (this->*memberFunc)(dContinue, event); in Execute()
70 if (dContinue == nullptr || event == nullptr) { in DoContinuePullReqTask()
75 int32_t ret = dContinue->ExecuteContinueReq(syncContinueData); in DoContinuePullReqTask()
85 if (dContinue == nullptr || event == nullptr) { in DoContinueAbilityTask()
89 return dContinue->ExecuteContinueReply(); in DoContinueAbilityTask()
95 if (dContinue == nullptr || event == nullptr) { in DoContinueErrorTask()
100 int32_t ret = dContinue->ExecuteContinueError(*syncContinueData); in DoContinueErrorTask()
107 int32_t DSchedContinueSinkStartState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask() argument
110 if (dContinue == nullptr || event == nullptr) { in DoContinueEndTask()
[all …]
H A Ddsched_continue_data_state.cpp39 int32_t DSchedContinueDataState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute() argument
53 int32_t ret = (this->*memberFunc)(dContinue, event); in Execute()
65 int32_t DSchedContinueDataState::DoContinueDataTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueDataTask() argument
68 if (dContinue == nullptr || event == nullptr) { in DoContinueDataTask()
73 int32_t ret = dContinue->ExecuteContinueData(syncContinueData); in DoContinueDataTask()
80 int32_t DSchedContinueDataState::DoContinueErrorTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueErrorTask() argument
83 if (dContinue == nullptr || event == nullptr) { in DoContinueErrorTask()
88 int32_t ret = dContinue->ExecuteContinueError(*syncContinueData); in DoContinueErrorTask()
95 int32_t DSchedContinueDataState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask() argument
98 if (dContinue == nullptr || event == nullptr) { in DoContinueEndTask()
[all …]
H A Ddsched_continue_sink_wait_end_state.cpp38 int32_t DSchedContinueSinkWaitEndState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute() argument
52 int32_t ret = (this->*memberFunc)(dContinue, event); in Execute()
65 …2_t DSchedContinueSinkWaitEndState::DoNotifyCompleteTask(std::shared_ptr<DSchedContinue> dContinue, in DoNotifyCompleteTask() argument
68 if (dContinue == nullptr || event == nullptr) { in DoNotifyCompleteTask()
73 int32_t ret = dContinue->ExecuteNotifyComplete(*syncContinueData); in DoNotifyCompleteTask()
80 int32_t DSchedContinueSinkWaitEndState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask() argument
83 if (dContinue == nullptr || event == nullptr) { in DoContinueEndTask()
88 int32_t ret = dContinue->ExecuteContinueError(*syncContinueData); in DoContinueEndTask()
H A Ddsched_continue_sink_end_state.cpp37 int32_t DSchedContinueSinkEndState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute() argument
51 int32_t ret = (this->*memberFunc)(dContinue, event); in Execute()
64 int32_t DSchedContinueSinkEndState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask() argument
67 if (dContinue == nullptr || event == nullptr) { in DoContinueEndTask()
72 int32_t ret = dContinue->ExecuteContinueEnd(*syncContinueData); in DoContinueEndTask()
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/continue/state/source_state/
H A Ddsched_continue_source_start_state.cpp40 int32_t DSchedContinueSourceStartState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute() argument
54 int32_t ret = (this->*memberFunc)(dContinue, event); in Execute()
70 if (dContinue == nullptr || event == nullptr) { in DoContinuePushReqTask()
75 int32_t ret = dContinue->ExecuteContinueReq(syncContinueData); in DoContinuePushReqTask()
85 if (dContinue == nullptr || event == nullptr) { in DoContinueAbilityTask()
90 int32_t ret = dContinue->ExecuteContinueAbility(*syncContinueData); in DoContinueAbilityTask()
100 if (dContinue == nullptr || event == nullptr) { in DoContinueErrorTask()
105 int32_t ret = dContinue->ExecuteContinueError(*syncContinueData); in DoContinueErrorTask()
112 int32_t DSchedContinueSourceStartState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask() argument
115 if (dContinue == nullptr || event == nullptr) { in DoContinueEndTask()
[all …]
H A Ddsched_continue_ability_state.cpp39 int32_t DSchedContinueAbilityState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute() argument
53 int32_t ret = (this->*memberFunc)(dContinue, event); in Execute()
66 int32_t DSchedContinueAbilityState::DoContinueSendTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueSendTask() argument
69 if (dContinue == nullptr || event == nullptr) { in DoContinueSendTask()
74 int32_t ret = dContinue->ExecuteContinueSend(syncContinueData); in DoContinueSendTask()
81 int32_t DSchedContinueAbilityState::DoContinueErrorTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueErrorTask() argument
84 if (dContinue == nullptr || event == nullptr) { in DoContinueErrorTask()
89 int32_t ret = dContinue->ExecuteContinueError(*syncContinueData); in DoContinueErrorTask()
96 int32_t DSchedContinueAbilityState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask() argument
99 if (dContinue == nullptr || event == nullptr) { in DoContinueEndTask()
[all …]
H A Ddsched_continue_source_wait_end_state.cpp38 int32_t DSchedContinueWaitEndState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute() argument
52 int32_t ret = (this->*memberFunc)(dContinue, event); in Execute()
65 int32_t DSchedContinueWaitEndState::DoNotifyCompleteTask(std::shared_ptr<DSchedContinue> dContinue, in DoNotifyCompleteTask() argument
68 if (dContinue == nullptr || event == nullptr) { in DoNotifyCompleteTask()
73 int32_t ret = dContinue->ExecuteNotifyComplete(*syncContinueData); in DoNotifyCompleteTask()
80 int32_t DSchedContinueWaitEndState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask() argument
83 if (dContinue == nullptr || event == nullptr) { in DoContinueEndTask()
88 int32_t ret = dContinue->ExecuteContinueError(*syncContinueData); in DoContinueEndTask()
H A Ddsched_continue_source_end_state.cpp37 int32_t DSchedContinueEndState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute() argument
51 int32_t ret = (this->*memberFunc)(dContinue, event); in Execute()
63 int32_t DSchedContinueEndState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask() argument
66 if (dContinue == nullptr || event == nullptr) { in DoContinueEndTask()
71 int32_t ret = dContinue->ExecuteContinueEnd(*syncContinueData); in DoContinueEndTask()
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/include/continue/state/sink_state/
H A Ddsched_continue_sink_start_state.h29 int32_t Execute(std::shared_ptr<DSchedContinue> dContinue,
34 int32_t DoContinuePullReqTask(std::shared_ptr<DSchedContinue> dContinue,
36 int32_t DoContinueAbilityTask(std::shared_ptr<DSchedContinue> dContinue,
38 int32_t DoContinueErrorTask(std::shared_ptr<DSchedContinue> dContinue,
40 int32_t DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue,
44 …hedStateFunc = int32_t (DSchedContinueSinkStartState::*)(std::shared_ptr<DSchedContinue> dContinue,
H A Ddsched_continue_data_state.h29 int32_t Execute(std::shared_ptr<DSchedContinue> dContinue,
34 int32_t DoContinueDataTask(std::shared_ptr<DSchedContinue> dContinue,
36 int32_t DoContinueErrorTask(std::shared_ptr<DSchedContinue> dContinue,
38 int32_t DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue,
42 …g DSchedStateFunc = int32_t (DSchedContinueDataState::*)(std::shared_ptr<DSchedContinue> dContinue,
H A Ddsched_continue_sink_wait_end_state.h29 int32_t Execute(std::shared_ptr<DSchedContinue> dContinue,
34 int32_t DoNotifyCompleteTask(std::shared_ptr<DSchedContinue> dContinue,
36 int32_t DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue,
40 …dStateFunc = int32_t (DSchedContinueSinkWaitEndState::*)(std::shared_ptr<DSchedContinue> dContinue,
H A Ddsched_continue_sink_end_state.h29 int32_t Execute(std::shared_ptr<DSchedContinue> dContinue,
34 int32_t DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue,
38 …SchedStateFunc = int32_t (DSchedContinueSinkEndState::*)(std::shared_ptr<DSchedContinue> dContinue,
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/include/continue/state/source_state/
H A Ddsched_continue_source_start_state.h29 int32_t Execute(std::shared_ptr<DSchedContinue> dContinue,
34 int32_t DoContinueAbilityTask(std::shared_ptr<DSchedContinue> dContinue,
36 int32_t DoContinuePushReqTask(std::shared_ptr<DSchedContinue> dContinue,
38 int32_t DoContinueErrorTask(std::shared_ptr<DSchedContinue> dContinue,
40 int32_t DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue,
44 …dStateFunc = int32_t (DSchedContinueSourceStartState::*)(std::shared_ptr<DSchedContinue> dContinue,
H A Ddsched_continue_ability_state.h29 int32_t Execute(std::shared_ptr<DSchedContinue> dContinue,
34 int32_t DoContinueSendTask(std::shared_ptr<DSchedContinue> dContinue,
36 int32_t DoContinueErrorTask(std::shared_ptr<DSchedContinue> dContinue,
38 int32_t DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue,
42 …SchedStateFunc = int32_t (DSchedContinueAbilityState::*)(std::shared_ptr<DSchedContinue> dContinue,
H A Ddsched_continue_source_wait_end_state.h29 int32_t Execute(std::shared_ptr<DSchedContinue> dContinue,
34 int32_t DoNotifyCompleteTask(std::shared_ptr<DSchedContinue> dContinue,
36 int32_t DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue,
40 …SchedStateFunc = int32_t (DSchedContinueWaitEndState::*)(std::shared_ptr<DSchedContinue> dContinue,
H A Ddsched_continue_source_end_state.h29 int32_t Execute(std::shared_ptr<DSchedContinue> dContinue,
34 int32_t DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue,
38 …ng DSchedStateFunc = int32_t (DSchedContinueEndState::*)(std::shared_ptr<DSchedContinue> dContinue,
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/continue/
H A Ddsched_continue_state_test.cpp67 dContinue->Init(); in CreateObject()
68 return dContinue; in CreateObject()
107 dContinue->Init(); in CreateObject()
108 return dContinue; in CreateObject()
147 dContinue->Init(); in CreateObject()
148 return dContinue; in CreateObject()
188 dContinue->Init(); in CreateObject()
189 return dContinue; in CreateObject()
232 return dContinue; in CreateObject()
273 return dContinue; in CreateObject()
[all …]
H A Ddsched_continue_manager_test.cpp85 …std::shared_ptr<DSchedContinue> dContinue = std::make_shared<DSchedContinue>(subServiceType, direc… in CreateObject() local
87 dContinue->Init(); in CreateObject()
88 return dContinue; in CreateObject()
294 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); variable
297 DSchedContinueManager::GetInstance().continues_[info] = dContinue;
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/continue/state/
H A Ddsched_continue_state_machine.cpp34 DSchedContinueStateMachine::DSchedContinueStateMachine(std::shared_ptr<DSchedContinue> dContinue) in DSchedContinueStateMachine() argument
35 : dContinue_(dContinue) in DSchedContinueStateMachine()
45 std::shared_ptr<DSchedContinue> dContinue = dContinue_.lock(); in Execute() local
46 if (dContinue == nullptr || currentState_ == nullptr) { in Execute()
52 int32_t ret = state->Execute(dContinue, event); in Execute()
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/continue/
H A Ddsched_continue_event_handler.cpp44 std::shared_ptr<DSchedContinue> dContinue = dschedContinue_.lock(); in ProcessEvent() local
45 if (dContinue == nullptr) { in ProcessEvent()
49 dContinue->ProcessEvent(event); in ProcessEvent()
H A Ddsched_continue_manager.cpp410 auto dContinue = GetDSchedContinueByWant(want, missionId); in HandleStartContinuation() local
411 if (dContinue != nullptr) { in HandleStartContinuation()
412 dContinue->OnStartContinuation(want, callerUid, status, accessToken); in HandleStartContinuation()
475 auto dContinue = GetDSchedContinueByDevId(devId, missionId); in HandleNotifyCompleteContinuation() local
476 if (dContinue != nullptr) { in HandleNotifyCompleteContinuation()
477 if (dContinue->GetContinueInfo().sinkBundleName_ != callerBundleName) { in HandleNotifyCompleteContinuation()
481 dContinue->OnNotifyComplete(missionId, isSuccess); in HandleNotifyCompleteContinuation()
482 HILOGI("end, continue info: %{public}s.", dContinue->GetContinueInfo().toString().c_str()); in HandleNotifyCompleteContinuation()
H A Ddsched_continue.cpp206 auto dContinue = std::shared_ptr<DSchedContinue>(shared_from_this()); in Init() local
207 stateMachine_ = std::make_shared<DSchedContinueStateMachine>(dContinue); in Init()
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/include/continue/state/
H A Ddsched_continue_state.h46 virtual int32_t Execute(std::shared_ptr<DSchedContinue> dContinue,
H A Ddsched_continue_state_machine.h26 explicit DSchedContinueStateMachine(std::shared_ptr<DSchedContinue> dContinue);
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/
H A Ddistributed_sched_stub.cpp668 … auto dContinue = DSchedContinueManager::GetInstance().GetDSchedContinueByDevId(devId, sessionId); variable
669 if (dContinue != nullptr) {