| /foundation/ability/dmsfwk/services/dtbschedmgr/include/continue/state/source_state/ |
| H A D | dsched_continue_source_start_state.h | 29 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 D | dsched_continue_ability_state.h | 29 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 D | dsched_continue_source_wait_end_state.h | 29 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 D | dsched_continue_source_end_state.h | 29 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 D | dsched_continue_sink_start_state.h | 29 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 D | dsched_continue_data_state.h | 29 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 D | dsched_continue_sink_wait_end_state.h | 29 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 D | dsched_continue_sink_end_state.h | 29 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/test/unittest/continue/ |
| H A D | dsched_continue_state_test.h | 40 std::shared_ptr<DSchedContinue> CreateObject();
50 std::shared_ptr<DSchedContinue> CreateObject();
60 std::shared_ptr<DSchedContinue> CreateObject();
70 std::shared_ptr<DSchedContinue> CreateObject();
80 std::shared_ptr<DSchedContinue> CreateObject();
90 std::shared_ptr<DSchedContinue> CreateObject();
100 std::shared_ptr<DSchedContinue> CreateObject();
110 std::shared_ptr<DSchedContinue> CreateObject();
120 std::shared_ptr<DSchedContinue> CreateObject();
|
| H A D | dsched_continue_test.cpp | 80 auto conti = std::make_shared<DSchedContinue>(subType, direction, callback, info); in HWTEST_F()
112 auto conti = std::make_shared<DSchedContinue>(subType, direction, callback, info); in HWTEST_F()
144 auto conti = std::make_shared<DSchedContinue>(subType, direction, callback, info); in HWTEST_F()
189 auto conti = std::make_shared<DSchedContinue>(subType, direction, callback, info); in HWTEST_F()
234 auto conti = std::make_shared<DSchedContinue>(subType, direction, callback, info); in HWTEST_F()
271 auto conti = std::make_shared<DSchedContinue>(subType, direction, callback, info); in HWTEST_F()
320 auto conti = std::make_shared<DSchedContinue>(subType, direction, callback, info); in HWTEST_F()
351 auto conti = std::make_shared<DSchedContinue>(subType, direction, callback, info); in HWTEST_F()
376 auto conti = std::make_shared<DSchedContinue>(subType, direction, callback, info); in HWTEST_F()
411 auto conti = std::make_shared<DSchedContinue>(subTyp in HWTEST_F()
[all...] |
| H A D | dsched_continue_state_test.cpp | 52 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); in SetUp()
59 std::shared_ptr<DSchedContinue> DSchedContinueDataStateTest::CreateObject() in CreateObject()
65 std::shared_ptr<DSchedContinue> dContinue = std::make_shared<DSchedContinue>(subServiceType, direction, in CreateObject()
92 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); in SetUp()
99 std::shared_ptr<DSchedContinue> DSchedContinueSinkEndStateTest::CreateObject() in CreateObject()
105 std::shared_ptr<DSchedContinue> dContinue = std::make_shared<DSchedContinue>(subServiceType, direction, in CreateObject()
132 std::shared_ptr<DSchedContinue> dContinue = CreateObject(); in SetUp()
139 std::shared_ptr<DSchedContinue> DSchedContinueSinkStartStateTes
[all...] |
| /foundation/ability/dmsfwk/services/dtbschedmgr/include/continue/ |
| H A D | dsched_continue_event_handler.h | 25 class DSchedContinue;
29 const std::shared_ptr<DSchedContinue>& dschedContinue);
35 std::weak_ptr<DSchedContinue> dschedContinue_;
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/continue/ |
| H A D | dsched_continue.cpp | 53 const std::string TAG = "DSchedContinue";
83 const std::map<int32_t, int32_t> DSchedContinue::DMS_CONVERT_TO_SDK_ERR_MAP = {
122 DSchedContinue::DSchedContinue(int32_t subServiceType, int32_t direction, const sptr<IRemoteObject>& callback, in DSchedContinue() function in OHOS::DistributedSchedule::DSchedContinue
126 HILOGI("DSchedContinue create"); in DSchedContinue()
134 DSchedContinue::DSchedContinue(std::shared_ptr<DSchedContinueStartCmd> startCmd, int32_t sessionId) in DSchedContinue() function in OHOS::DistributedSchedule::DSchedContinue
136 HILOGI("DSchedContinue create by start command"); in DSchedContinue()
166 DSchedContinue::~DSchedContinue() in ~DSchedContinue()
[all...] |
| H A D | dsched_continue_event_handler.cpp | 28 const std::shared_ptr<DSchedContinue>& dschedContinue) : AppExecFwk::EventHandler(runner), in DSchedContinueEventHandler()
44 std::shared_ptr<DSchedContinue> dContinue = dschedContinue_.lock(); in ProcessEvent()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/include/continue/state/ |
| H A D | dsched_continue_state_machine.h | 23 class DSchedContinue;
26 explicit DSchedContinueStateMachine(std::shared_ptr<DSchedContinue> dContinue);
35 std::weak_ptr<DSchedContinue> dContinue_;
|
| H A D | dsched_continue_state.h | 39 class DSchedContinue;
46 virtual int32_t Execute(std::shared_ptr<DSchedContinue> dContinue,
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/continue/state/sink_state/ |
| H A D | dsched_continue_sink_start_state.cpp | 40 int32_t DSchedContinueSinkStartState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute()
67 int32_t DSchedContinueSinkStartState::DoContinuePullReqTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinuePullReqTask()
82 int32_t DSchedContinueSinkStartState::DoContinueAbilityTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueAbilityTask()
92 int32_t DSchedContinueSinkStartState::DoContinueErrorTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueErrorTask()
107 int32_t DSchedContinueSinkStartState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask()
|
| H A D | dsched_continue_data_state.cpp | 39 int32_t DSchedContinueDataState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute()
65 int32_t DSchedContinueDataState::DoContinueDataTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueDataTask()
80 int32_t DSchedContinueDataState::DoContinueErrorTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueErrorTask()
95 int32_t DSchedContinueDataState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask()
|
| H A D | dsched_continue_sink_wait_end_state.cpp | 38 int32_t DSchedContinueSinkWaitEndState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute()
65 int32_t DSchedContinueSinkWaitEndState::DoNotifyCompleteTask(std::shared_ptr<DSchedContinue> dContinue, in DoNotifyCompleteTask()
80 int32_t DSchedContinueSinkWaitEndState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask()
|
| H A D | dsched_continue_sink_end_state.cpp | 37 int32_t DSchedContinueSinkEndState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute()
64 int32_t DSchedContinueSinkEndState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/continue/state/source_state/ |
| H A D | dsched_continue_source_start_state.cpp | 40 int32_t DSchedContinueSourceStartState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute()
67 int32_t DSchedContinueSourceStartState::DoContinuePushReqTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinuePushReqTask()
82 int32_t DSchedContinueSourceStartState::DoContinueAbilityTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueAbilityTask()
97 int32_t DSchedContinueSourceStartState::DoContinueErrorTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueErrorTask()
112 int32_t DSchedContinueSourceStartState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask()
|
| H A D | dsched_continue_ability_state.cpp | 39 int32_t DSchedContinueAbilityState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute()
66 int32_t DSchedContinueAbilityState::DoContinueSendTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueSendTask()
81 int32_t DSchedContinueAbilityState::DoContinueErrorTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueErrorTask()
96 int32_t DSchedContinueAbilityState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask()
|
| H A D | dsched_continue_source_wait_end_state.cpp | 38 int32_t DSchedContinueWaitEndState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute()
65 int32_t DSchedContinueWaitEndState::DoNotifyCompleteTask(std::shared_ptr<DSchedContinue> dContinue, in DoNotifyCompleteTask()
80 int32_t DSchedContinueWaitEndState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask()
|
| H A D | dsched_continue_source_end_state.cpp | 37 int32_t DSchedContinueEndState::Execute(std::shared_ptr<DSchedContinue> dContinue, in Execute()
63 int32_t DSchedContinueEndState::DoContinueEndTask(std::shared_ptr<DSchedContinue> dContinue, in DoContinueEndTask()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/continue/state/ |
| H A D | dsched_continue_state_machine.cpp | 34 DSchedContinueStateMachine::DSchedContinueStateMachine(std::shared_ptr<DSchedContinue> dContinue) in DSchedContinueStateMachine()
45 std::shared_ptr<DSchedContinue> dContinue = dContinue_.lock(); in Execute()
|