Home
last modified time | relevance | path

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

/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()
67 int32_t DSchedContinueSinkStartState::DoContinuePullReqTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinuePullReqTask() argument
70 if (dContinue == nullptr || event == nullptr) { in DoContinuePullReqTask()
71 HILOGE("dContinue or event is null"); in DoContinuePullReqTask()
75 int32_t ret = dContinue->ExecuteContinueReq(syncContinueData); in DoContinuePullReqTask()
82 int32_t DSchedContinueSinkStartState::DoContinueAbilityTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueAbilityTask() argument
85 if (dContinue == nullptr || event == nullptr) { in DoContinueAbilityTask()
86 HILOGE("dContinue or event is null"); in DoContinueAbilityTask()
89 return dContinue in DoContinueAbilityTask()
92 DoContinueErrorTask(std::shared_ptr<DSchedContinue> dContinue, const AppExecFwk::InnerEvent::Pointer &event) DoContinueErrorTask() argument
107 DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, const AppExecFwk::InnerEvent::Pointer &event) DoContinueEndTask() argument
[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()
69 HILOGE("dContinue or event is null"); 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()
84 HILOGE("dContinue or event is null"); in DoContinueErrorTask()
88 int32_t ret = dContinue in DoContinueErrorTask()
95 DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, const AppExecFwk::InnerEvent::Pointer &event) DoContinueEndTask() argument
[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 int32_t DSchedContinueSinkWaitEndState::DoNotifyCompleteTask(std::shared_ptr<DSchedContinue> dContinue, in DoNotifyCompleteTask() argument
68 if (dContinue == nullptr || event == nullptr) { in DoNotifyCompleteTask()
69 HILOGE("dContinue or event is null"); 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()
84 HILOGE("dContinue or event is null"); in DoContinueEndTask()
88 int32_t ret = dContinue in DoContinueEndTask()
[all...]
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()
68 HILOGE("dContinue or event is null"); in DoContinueEndTask()
72 int32_t ret = dContinue->ExecuteContinueEnd(*syncContinueData); in DoContinueEndTask()
/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()
67 int32_t DSchedContinueSourceStartState::DoContinuePushReqTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinuePushReqTask() argument
70 if (dContinue == nullptr || event == nullptr) { in DoContinuePushReqTask()
71 HILOGE("dContinue or event is null"); in DoContinuePushReqTask()
75 int32_t ret = dContinue->ExecuteContinueReq(syncContinueData); in DoContinuePushReqTask()
82 int32_t DSchedContinueSourceStartState::DoContinueAbilityTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueAbilityTask() argument
85 if (dContinue == nullptr || event == nullptr) { in DoContinueAbilityTask()
86 HILOGE("dContinue or event is null"); in DoContinueAbilityTask()
90 int32_t ret = dContinue in DoContinueAbilityTask()
97 DoContinueErrorTask(std::shared_ptr<DSchedContinue> dContinue, const AppExecFwk::InnerEvent::Pointer &event) DoContinueErrorTask() argument
112 DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, const AppExecFwk::InnerEvent::Pointer &event) DoContinueEndTask() argument
[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()
70 HILOGE("dContinue or event is null"); 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()
85 HILOGE("dContinue or event is null"); in DoContinueErrorTask()
89 int32_t ret = dContinue in DoContinueErrorTask()
96 DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, const AppExecFwk::InnerEvent::Pointer &event) DoContinueEndTask() argument
[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()
69 HILOGE("dContinue or event is null"); 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()
84 HILOGE("dContinue or event is null"); in DoContinueEndTask()
88 int32_t ret = dContinue in DoContinueEndTask()
[all...]
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()
67 HILOGE("dContinue or event is null"); in DoContinueEndTask()
71 int32_t ret = dContinue->ExecuteContinueEnd(*syncContinueData); in DoContinueEndTask()
/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 using DSchedStateFunc = 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 using DSchedStateFunc = 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 using DSchedStateFunc = 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 using DSchedStateFunc = int32_t (DSchedContinueEndState::*)(std::shared_ptr<DSchedContinue> dContinue,
/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 using DSchedStateFunc = 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 using 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 using DSchedStateFunc = 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 using DSchedStateFunc = int32_t (DSchedContinueSinkEndState::*)(std::shared_ptr<DSchedContinue> dContinue,
/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()
/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.cpp409 auto dContinue = GetDSchedContinueByWant(want, missionId); in HandleStartContinuation() local
410 if (dContinue != nullptr) { in HandleStartContinuation()
411 dContinue->OnStartContinuation(want, callerUid, status, accessToken); in HandleStartContinuation()
474 auto dContinue = GetDSchedContinueByDevId(devId, missionId); in HandleNotifyCompleteContinuation() local
475 if (dContinue != nullptr) { in HandleNotifyCompleteContinuation()
476 if (dContinue->GetContinueInfo().sinkBundleName_ != callerBundleName) { in HandleNotifyCompleteContinuation()
480 dContinue->OnNotifyComplete(missionId, isSuccess); in HandleNotifyCompleteContinuation()
481 HILOGI("end, continue info: %{public}s.", dContinue->GetContinueInfo().toString().c_str()); in HandleNotifyCompleteContinuation()
733 HILOGE("dContinue is null"); in GetContinueInfo()
H A Ddsched_continue.cpp207 auto dContinue = std::shared_ptr<DSchedContinue>(shared_from_this()); in Init() local
208 stateMachine_ = std::make_shared<DSchedContinueStateMachine>(dContinue); in Init()
/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/continue/
H A Ddsched_continue_state_test.cpp52 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); in SetUp() local
53 std::shared_ptr<DSchedContinueStateMachine> stateMachine = std::make_shared<DSchedContinueStateMachine>(dContinue); in SetUp()
65 std::shared_ptr<DSchedContinue> dContinue = std::make_shared<DSchedContinue>(subServiceType, direction, in CreateObject() local
67 dContinue->Init(); in CreateObject()
68 return dContinue; in CreateObject()
92 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); in SetUp() local
93 std::shared_ptr<DSchedContinueStateMachine> stateMachine = std::make_shared<DSchedContinueStateMachine>(dContinue); in SetUp()
105 std::shared_ptr<DSchedContinue> dContinue = std::make_shared<DSchedContinue>(subServiceType, direction, in CreateObject() local
107 dContinue->Init(); in CreateObject()
108 return dContinue; in CreateObject()
132 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); SetUp() local
145 std::shared_ptr<DSchedContinue> dContinue = std::make_shared<DSchedContinue>(subServiceType, direction, CreateObject() local
172 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); SetUp() local
186 std::shared_ptr<DSchedContinue> dContinue = std::make_shared<DSchedContinue>(subServiceType, direction, CreateObject() local
213 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); SetUp() local
229 std::shared_ptr<DSchedContinue> dContinue = std::make_shared<DSchedContinue>(subServiceType, direction, CreateObject() local
256 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); SetUp() local
270 std::shared_ptr<DSchedContinue> dContinue = std::make_shared<DSchedContinue>(subServiceType, direction, CreateObject() local
297 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); SetUp() local
311 std::shared_ptr<DSchedContinue> dContinue = std::make_shared<DSchedContinue>(subServiceType, direction, CreateObject() local
338 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); SetUp() local
352 std::shared_ptr<DSchedContinue> dContinue = std::make_shared<DSchedContinue>(subServiceType, direction, CreateObject() local
379 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); SetUp() local
391 std::shared_ptr<DSchedContinue> dContinue = std::make_shared<DSchedContinue>(subServiceType, direction, CreateObject() local
[all...]
H A Ddsched_continue_manager_test.cpp89 std::shared_ptr<DSchedContinue> dContinue = std::make_shared<DSchedContinue>(subServiceType, direction, in CreateObject() local
91 dContinue->Init(); in CreateObject()
92 return dContinue; in CreateObject()
318 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); in HWTEST_F() local
321 DSchedContinueManager::GetInstance().continues_[info] = dContinue; in HWTEST_F()
548 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); in HWTEST_F() local
550 DSchedContinueManager::GetInstance().continues_[info] = dContinue; in HWTEST_F()
/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);
/foundation/ability/dmsfwk/services/dtbschedmgr/src/
H A Ddistributed_sched_stub.cpp693 auto dContinue = DSchedContinueManager::GetInstance().GetDSchedContinueByDevId(devId, sessionId); in NotifyCompleteContinuationInner() local
694 if (dContinue != nullptr) { in NotifyCompleteContinuationInner()

Completed in 14 milliseconds