/foundation/ability/dmsfwk/services/dtbschedmgr/src/continue/ |
H A D | dsched_continue_manager.cpp | 115 int32_t DSchedContinueManager::ContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId, in ContinueMission() argument 118 if (srcDeviceId.empty() || dstDeviceId.empty() || callback == nullptr) { in ContinueMission() 119 HILOGE("srcDeviceId or dstDeviceId or callback is null!"); in ContinueMission() 128 if (localDevId != srcDeviceId && localDevId != dstDeviceId) { in ContinueMission() 130 GetAnonymStr(srcDeviceId).c_str(), GetAnonymStr(dstDeviceId).c_str(), GetAnonymStr(localDevId).c_str()); in ContinueMission() 134 localDevId == srcDeviceId ? dstDeviceId : srcDeviceId) == nullptr) { in ContinueMission() 136 GetAnonymStr(localDevId).c_str(), GetAnonymStr(srcDeviceId).c_str(), GetAnonymStr(dstDeviceId).c_str()); in ContinueMission() 140 auto func = [this, srcDeviceId, dstDeviceId, missionId, callback, wantParams]() { in ContinueMission() 141 HandleContinueMission(srcDeviceId, dstDeviceI in ContinueMission() 151 HandleContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId, int32_t missionId, const sptr<IRemoteObject>& callback, const OHOS::AAFwk::WantParams& wantParams) HandleContinueMission() argument 183 std::string srcDeviceId = continueInfo.sourceDeviceId_; ContinueMission() local 234 std::string srcDeviceId = continueInfo.sourceDeviceId_; HandleContinueMission() local 422 std::string srcDeviceId; GetDSchedContinueByWant() local 687 CheckContinuationLimit(const std::string& srcDeviceId, const std::string& dstDeviceId, int32_t &direction) CheckContinuationLimit() argument 723 GetContinueInfo(std::string &srcDeviceId, std::string &dstDeviceId) GetContinueInfo() argument [all...] |
/foundation/ability/ability_runtime/test/unittest/remote_mission_listener_proxy_test/ |
H A D | remote_on_listener_proxy_test.cpp | 64 std::string srcDeviceId = ""; in HWTEST_F() local 69 proxy_->OnCallback(continueState, srcDeviceId, bundleName, continueType, srcBundleName); in HWTEST_F() 86 std::string srcDeviceId = "test"; in HWTEST_F() local 91 proxy_->OnCallback(continueState, srcDeviceId, bundleName, continueType, srcBundleName); in HWTEST_F()
|
H A D | remote_on_listener_stub_mock.h | 48 virtual void OnCallback(const uint32_t ContinueState, const std::string &srcDeviceId, in OnCallback() argument
|
/foundation/ability/ability_runtime/services/abilitymgr/src/ |
H A D | remote_on_listener_stub.cpp | 52 std::string srcDeviceId = data.ReadString(); in OnCallbackInner() local 56 OnCallback(continueState, srcDeviceId, bundleName, continueType, srcBundleName); in OnCallbackInner()
|
H A D | remote_on_listener_proxy.cpp | 23 void RemoteOnListenerProxy::OnCallback(const uint32_t continueState, const std::string &srcDeviceId, in OnCallback() argument 37 if (!data.WriteString(srcDeviceId)) { in OnCallback() 38 TAG_LOGE(AAFwkTag::ABILITYMGR, "NotifyOnsChanged Write srcDeviceId failed"); in OnCallback()
|
/foundation/ability/dmsfwk/services/dtbschedmgr/include/continue/ |
H A D | dsched_continue_manager.h | 42 int32_t ContinueMission(const std::string &srcDeviceId, const std::string &dstDeviceId, 58 int32_t GetContinueInfo(std::string &srcDeviceId, std::string &dstDeviceId); 65 void HandleContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId, int32_t missionId, 81 int32_t CheckContinuationLimit(const std::string& srcDeviceId, const std::string& dstDeviceId, int32_t &direction);
|
/foundation/systemabilitymgr/samgr/test/fuzztest/samgrcoverage_fuzzer/ |
H A D | samgrcoverage_fuzzer.cpp | 121 string srcDeviceId = "srcDeviceId"; in FuzzRemoveSystemProcess() local 125 abilityItem.callbackMap[srcDeviceId].push_back(make_pair(callbackOne, SAID)); in FuzzRemoveSystemProcess() 127 saMgr->CleanCallbackForLoadFailed(SAID, name, srcDeviceId, callbackOne); in FuzzRemoveSystemProcess() 139 string srcDeviceId = "srcDeviceId"; in FuzzNotifySystemAbilityLoaded() local 141 saMgr->LoadSystemAbilityFromRpc(srcDeviceId, systemAbilityId, callback); in FuzzNotifySystemAbilityLoaded()
|
/foundation/systemabilitymgr/samgr/services/samgr/native/test/unittest/src/ |
H A D | system_ability_mgr_stub_load_test.cpp | 677 string srcDeviceId; in HWTEST_F() local 679 saMgr->SendCheckLoadedMsg(SAID, name, srcDeviceId, callback); in HWTEST_F() 693 string srcDeviceId; in HWTEST_F() local 695 saMgr->SendCheckLoadedMsg(SAID, name, srcDeviceId, callback); in HWTEST_F() 717 string srcDeviceId; in HWTEST_F() local 721 saMgr->SendCheckLoadedMsg(SAID, name, srcDeviceId, callback); in HWTEST_F() 741 string srcDeviceId; in HWTEST_F() local 746 saMgr->CleanCallbackForLoadFailed(SAID, name, srcDeviceId, callback); in HWTEST_F() 766 string srcDeviceId = "srcDeviceId"; in HWTEST_F() local 790 string srcDeviceId = "srcDeviceId"; HWTEST_F() local 818 string srcDeviceId = "srcDeviceId"; HWTEST_F() local 893 string srcDeviceId; HWTEST_F() local 911 string srcDeviceId; HWTEST_F() local 933 string srcDeviceId; HWTEST_F() local 961 string srcDeviceId = "srcDeviceId"; HWTEST_F() local 983 string srcDeviceId = "srcDeviceId"; HWTEST_F() local 998 string srcDeviceId = "srcDeviceId"; HWTEST_F() local [all...] |
/foundation/ability/ability_runtime/test/fuzztest/continuemission_fuzzer/ |
H A D | continuemission_fuzzer.cpp | 43 std::string srcDeviceId(data, size); in DoSomethingInterestingWithMyAPI() 53 abilitymgr->ContinueMission(srcDeviceId, dstDeviceId, missionId, callback, *wantParams); in DoSomethingInterestingWithMyAPI()
|
/foundation/ability/ability_runtime/interfaces/inner_api/ability_manager/include/ |
H A D | dms_continueInfo.h | 32 std::string srcDeviceId;
member
|
H A D | remote_on_listener_interface.h | 36 virtual void OnCallback(const uint32_t ContinueState, const std::string &srcDeviceId,
|
H A D | remote_on_listener_proxy.h | 37 virtual void OnCallback(const uint32_t continueState, const std::string &srcDeviceId,
|
/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/mission/ |
H A D | dms_continue_manager_test.h | 35 void OnCallback(const uint32_t ContinueState, const std::string& srcDeviceId,
|
/foundation/ability/ability_runtime/test/unittest/remote_mission_listener_stub_test/ |
H A D | mock_remote_on_listener_stub.h | 32 MOCK_METHOD5(OnCallback, void(const uint32_t ContinueState, const std::string &srcDeviceId,
|
/foundation/ability/ability_runtime/test/unittest/frameworks_kits_ability_native_test/ |
H A D | distributed_client_test.cpp | 248 std::string srcDeviceId = "deviceId"; in HWTEST_F() local 252 int32_t result = client->ContinueMission(srcDeviceId, dstDeviceId, missionId, nullptr, wantParams); in HWTEST_F() 266 std::string srcDeviceId = "deviceId"; in HWTEST_F() local 271 int32_t result = client->ContinueMission(srcDeviceId, dstDeviceId, missionId, callback, wantParams); in HWTEST_F() 289 std::string srcDeviceId = "deviceId"; in HWTEST_F() local 295 int32_t result = client->ContinueMission(srcDeviceId, dstDeviceId, missionId, callback, wantParams); in HWTEST_F() 310 std::string srcDeviceId = ""; in HWTEST_F() local 316 continueMissionInfo.srcDeviceId = srcDeviceId; in HWTEST_F() 333 std::string srcDeviceId in HWTEST_F() local 360 std::string srcDeviceId = ""; HWTEST_F() local [all...] |
/foundation/filemanagement/dfs_service/test/unittests/distributed_file_daemon/ |
H A D | daemon_test.cpp | 188 const std::string srcDeviceId = "testSrcDeviceId"; in HWTEST_F() local 197 EXPECT_EQ(daemon_->PrepareSession(srcUri, dstUri, srcDeviceId, listener, fileInfo), in HWTEST_F()
|
H A D | daemon_manager_impl_test.cpp | 152 const std::string srcDeviceId = "testSrcDeviceId"; in HWTEST_F() local 165 auto res = distributedDaemonManagerImpl_->PrepareSession(srcUri, dstUri, srcDeviceId, listener, fileInfo); in HWTEST_F()
|
H A D | daemon_service_proxy_test.cpp | 116 const std::string srcDeviceId = "testSrcDeviceId"; in HWTEST_F() local 122 int ret = proxy_->PrepareSession(srcUri, dstUri, srcDeviceId, listener, fileInfo); in HWTEST_F()
|
/foundation/filemanagement/dfs_service/frameworks/native/distributed_file_inner/src/ |
H A D | distributed_file_daemon_manager_impl.cpp | 78 const std::string &srcDeviceId, in PrepareSession() 87 return distributedFileDaemonProxy->PrepareSession(srcUri, dstUri, srcDeviceId, listener, info); in PrepareSession() 76 PrepareSession(const std::string &srcUri, const std::string &dstUri, const std::string &srcDeviceId, const sptr<IRemoteObject> &listener, HmdfsInfo &info) PrepareSession() argument
|
/foundation/ability/dmsfwk/services/dtbschedmgr/include/ |
H A D | distributed_sched_service.h | 80 std::string srcDeviceId; member 108 void DurationStart(const std::string srcDeviceId, const std::string dstDeviceId); 117 int32_t ContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId, 119 int32_t ProcessContinueLocalMission(const std::string& srcDeviceId, const std::string& dstDeviceId, 122 int32_t ProcessContinueRemoteMission(const std::string& srcDeviceId, const std::string& dstDeviceId, 125 int32_t ContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId, 269 int32_t ContinueRemoteMission(const std::string& srcDeviceId, const std::string& dstDeviceId, int32_t missionId, 271 int32_t ContinueRemoteMission(const std::string& srcDeviceId, const std::string& dstDeviceId,
|
/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/ |
H A D | distributed_sched_continuation_test.cpp | 532 std::string srcDeviceId = "123456";
in HWTEST_F() local 538 srcDeviceId, dstDeviceid, missionId, callback, wantParams);
in HWTEST_F() 555 std::string srcDeviceId;
in HWTEST_F() local 556 DtbschedmgrDeviceInfoStorage::GetInstance().GetLocalDeviceId(srcDeviceId);
in HWTEST_F() 562 srcDeviceId, dstDeviceid, missionId, callback, wantParams);
in HWTEST_F() 1006 * @tc.desc: test ContinueMission when srcDeviceId is empty.
1050 * @tc.desc: test ContinueMission when srcDeviceId == localDevId.
1058 std::string srcDeviceId;
in HWTEST_F() local 1059 DtbschedmgrDeviceInfoStorage::GetInstance().GetLocalDeviceId(srcDeviceId);
in HWTEST_F() 1060 int32_t ret = DistributedSchedService::GetInstance().ContinueMission(srcDeviceId,
in HWTEST_F() 1562 std::string srcDeviceId; HWTEST_F() local 1581 std::string srcDeviceId; HWTEST_F() local 1618 std::string srcDeviceId; HWTEST_F() local [all...] |
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/include/ipc/ |
H A D | distributed_file_daemon_manager.h | 42 const std::string &srcDeviceId,
|
/foundation/filemanagement/dfs_service/test/unittests/distributed_file_inner/include/ |
H A D | i_daemon_mock.h | 41 const std::string &srcDeviceId, const sptr<IRemoteObject> &listener, HmdfsInfo &fileInfo));
|
/foundation/ability/ability_runtime/frameworks/js/napi/mission_manager/ |
H A D | distributed_mission_manager.h | 105 void OnCallback(const uint32_t continueState, const std::string &srcDeviceId, 161 std::string srcDeviceId; member 178 std::string srcDeviceId; member
|
/foundation/ability/dmsfwk/services/dtbschedmgr/src/ |
H A D | distributed_sched_service.cpp | 426 void DistributedSchedService::DurationStart(const std::string srcDeviceId, const std::string dstDeviceId) in DurationStart() argument 431 DmsContinueTime::GetInstance().SetNetWorkId(srcDeviceId, dstDeviceId); in DurationStart() 970 int32_t DistributedSchedService::ContinueRemoteMission(const std::string& srcDeviceId, const std::string& dstDeviceId, in ContinueRemoteMission() argument 977 sptr<IDistributedSched> remoteDms = GetRemoteDms(srcDeviceId); in ContinueRemoteMission() 992 DmsUE::GetInstance().TriggerDmsContinue(bundleName, abilityName, srcDeviceId, ERR_OK); in ContinueRemoteMission() 994 std::string peerUdid = DtbschedmgrDeviceInfoStorage::GetInstance().GetUdidByNetworkId(srcDeviceId); in ContinueRemoteMission() 997 int32_t result = remoteDms->ContinueMission(srcDeviceId, dstDeviceId, missionId, callback, wantParams); in ContinueRemoteMission() 1002 int32_t DistributedSchedService::ContinueRemoteMission(const std::string& srcDeviceId, const std::string& dstDeviceId, in ContinueRemoteMission() argument 1005 HILOGI("ContinueRemoteMission srcDeviceId: %{public}s. dstDeviceId: %{public}s. bundleName: %{public}s.", in ContinueRemoteMission() 1006 GetAnonymStr(srcDeviceId) in ContinueRemoteMission() 1041 ContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId, int32_t missionId, const sptr<IRemoteObject>& callback, const OHOS::AAFwk::WantParams& wantParams) ContinueMission() argument 1075 ProcessContinueLocalMission(const std::string& srcDeviceId, const std::string& dstDeviceId, const std::string& bundleName, const sptr<IRemoteObject>& callback, const OHOS::AAFwk::WantParams& wantParams) ProcessContinueLocalMission() argument 1103 ProcessContinueRemoteMission(const std::string& srcDeviceId, const std::string& dstDeviceId, const std::string& bundleName, const sptr<IRemoteObject>& callback, const OHOS::AAFwk::WantParams& wantParams) ProcessContinueRemoteMission() argument 1122 ContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId, const std::string& bundleName, const sptr<IRemoteObject>& callback, const OHOS::AAFwk::WantParams& wantParams) ContinueMission() argument 3475 std::string srcDeviceId = ""; NotifyStateChanged() local [all...] |