/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, dstDeviceId, missionId, callback, wantParams); in ContinueMission() 151 void DSchedContinueManager::HandleContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId, in HandleContinueMission() argument 184 std::string dstDeviceId = continueInfo.sinkDeviceId_; ContinueMission() local 235 std::string dstDeviceId = continueInfo.sinkDeviceId_; HandleContinueMission() local 383 std::string dstDeviceId = want.GetElement().GetDeviceID(); StartContinuation() local 428 std::string dstDeviceId = want.GetElement().GetDeviceID(); 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/filemanagement/dfs_service/services/distributedfiledaemon/src/ipc/ |
H A D | daemon_execute.cpp | 140 std::string dstDeviceId = requestSendFileData->dstDeviceId_; in ExecuteRequestSendFile() local 142 if (srcUri.empty() || dstDeviceId.empty() || sessionName.empty()) { in ExecuteRequestSendFile() 143 LOGE("params empty. %{public}s, %{public}s", sessionName.c_str(), Utils::GetAnonyString(dstDeviceId).c_str()); in ExecuteRequestSendFile() 148 requestSendFileBlock->SetValue(RequestSendFileInner(srcUri, dstPath, dstDeviceId, sessionName)); in ExecuteRequestSendFile() 153 const std::string &dstDeviceId, in RequestSendFileInner() 156 LOGI("RequestSendFile begin dstDeviceId: %{public}s", Utils::GetAnonyString(dstDeviceId).c_str()); in RequestSendFileInner() 158 int32_t ret = AllConnectManager::GetInstance().ApplyAdvancedResource(dstDeviceId, resourceReq.get()); in RequestSendFileInner() 165 ret = SoftBusHandler::GetInstance().OpenSession(sessionName, sessionName, dstDeviceId, socketId); in RequestSendFileInner() 170 AllConnectManager::GetInstance().PublishServiceState(dstDeviceId, in RequestSendFileInner() 151 RequestSendFileInner(const std::string &srcUri, const std::string &dstPath, const std::string &dstDeviceId, const std::string &sessionName) RequestSendFileInner() argument [all...] |
H A D | daemon_stub.cpp | 265 std::string dstDeviceId; in HandleRequestSendFile() local 266 if (!data.ReadString(dstDeviceId)) { in HandleRequestSendFile() 275 auto res = RequestSendFile(srcUri, dstPath, dstDeviceId, sessionName); in HandleRequestSendFile()
|
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/include/ipc/ |
H A D | daemon_event.h | 43 const std::string &dstDeviceId, in RequestSendFileData() 48 dstDeviceId_(dstDeviceId), in RequestSendFileData()
|
H A D | daemon_execute.h | 42 const std::string &dstDeviceId,
|
H A D | daemon.h | 78 const std::string &dstDeviceId,
|
/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/ability/ability_runtime/test/fuzztest/continuemission_fuzzer/ |
H A D | continuemission_fuzzer.cpp | 44 std::string dstDeviceId(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 | 31 std::string dstDeviceId;
member
|
/foundation/ability/ability_runtime/test/unittest/frameworks_kits_ability_native_test/ |
H A D | distributed_client_test.cpp | 249 std::string dstDeviceId = "deviceId"; in HWTEST_F() local 252 int32_t result = client->ContinueMission(srcDeviceId, dstDeviceId, missionId, nullptr, wantParams); in HWTEST_F() 267 std::string dstDeviceId = "deviceId"; in HWTEST_F() local 271 int32_t result = client->ContinueMission(srcDeviceId, dstDeviceId, missionId, callback, wantParams); in HWTEST_F() 290 std::string dstDeviceId = "deviceId"; in HWTEST_F() local 295 int32_t result = client->ContinueMission(srcDeviceId, dstDeviceId, missionId, callback, wantParams); in HWTEST_F() 311 std::string dstDeviceId = ""; in HWTEST_F() local 315 continueMissionInfo.dstDeviceId = dstDeviceId; in HWTEST_F() 334 std::string dstDeviceId in HWTEST_F() local 361 std::string dstDeviceId = ""; HWTEST_F() local [all...] |
/foundation/ability/dmsfwk/services/dtbschedmgr/include/ |
H A D | distributed_sched_service.h | 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, 259 const std::string& dstDeviceId, const sptr<IRemoteObject>& callback); 265 int32_t ContinueLocalMission(const std::string& dstDeviceId, int32_t missionId, 267 int32_t ContinueAbilityWithTimeout(const std::string& dstDeviceId, int32_t missionId, 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, [all...] |
H A D | distributed_sched_interface.h | 76 virtual int32_t ContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId, 78 virtual int32_t ContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId, in ContinueMission() argument
|
H A D | distributed_sched_proxy.h | 40 int32_t ContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId, 42 int32_t ContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId,
|
H A D | distributed_sched_permission.h | 86 bool CheckDeviceSecurityLevel(const std::string& srcDeviceId, const std::string& dstDeviceId) const;
|
/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() 869 const std::string& dstDeviceId, const sptr<IRemoteObject>& callback) in ContinueLocalMissionDealFreeInstall() 881 dschedContinuation_->PushCallback(missionId, callback, dstDeviceId, true); in ContinueLocalMissionDealFreeInstall() 884 want.SetDeviceId(dstDeviceId); in ContinueLocalMissionDealFreeInstall() 894 int32_t DistributedSchedService::ContinueLocalMission(const std::string& dstDeviceId, int32_t missionId, in ContinueLocalMission() argument 910 if (DmsVersionManager::IsRemoteDmsVersionLower(dstDeviceId, thresholdDmsVersion)) { in ContinueLocalMission() 912 return ContinueAbilityWithTimeout(dstDeviceId, missionId, callback); in ContinueLocalMission() 933 result = BundleManagerInternal::CheckRemoteBundleInfoForContinuation(dstDeviceId, in ContinueLocalMission() 936 return ContinueAbilityWithTimeout(dstDeviceId, missionI in ContinueLocalMission() 868 ContinueLocalMissionDealFreeInstall(OHOS::AAFwk::Want& want, int32_t missionId, const std::string& dstDeviceId, const sptr<IRemoteObject>& callback) ContinueLocalMissionDealFreeInstall() argument 946 ContinueAbilityWithTimeout(const std::string& dstDeviceId, int32_t missionId, const sptr<IRemoteObject>& callback, uint32_t remoteBundleVersion) ContinueAbilityWithTimeout() argument 970 ContinueRemoteMission(const std::string& srcDeviceId, const std::string& dstDeviceId, int32_t missionId, const sptr<IRemoteObject>& callback, const OHOS::AAFwk::WantParams& wantParams) ContinueRemoteMission() argument 1002 ContinueRemoteMission(const std::string& srcDeviceId, const std::string& dstDeviceId, const std::string& bundleName, const sptr<IRemoteObject>& callback, const OHOS::AAFwk::WantParams& wantParams) ContinueRemoteMission() argument 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 [all...] |
/foundation/ability/ability_runtime/test/unittest/ability_manager_client_branch_test/ |
H A D | ability_manager_client_branch_test.cpp | 714 std::string dstDeviceId = "ABC"; in HWTEST_F() local 718 auto result = client_->ContinueMission(srcDeviceId, dstDeviceId, missionId, callback, wantParams); in HWTEST_F() 733 std::string dstDeviceId = "ABC"; in HWTEST_F() local 737 auto result = client_->ContinueMission(srcDeviceId, dstDeviceId, missionId, callback, wantParams); in HWTEST_F() 752 std::string dstDeviceId = ""; in HWTEST_F() local 756 auto result = client_->ContinueMission(srcDeviceId, dstDeviceId, missionId, callback, wantParams); in HWTEST_F() 771 std::string dstDeviceId = "ABC"; in HWTEST_F() local 775 auto result = client_->ContinueMission(srcDeviceId, dstDeviceId, missionId, callback, wantParams); in HWTEST_F() 790 std::string dstDeviceId = ""; in HWTEST_F() local 794 auto result = client_->ContinueMission(srcDeviceId, dstDeviceId, missionI in HWTEST_F() 809 std::string dstDeviceId = ""; HWTEST_F() local 828 std::string dstDeviceId = "ABC"; HWTEST_F() local [all...] |
/foundation/ability/dmsfwk/services/dtbschedmgr/include/bundle/ |
H A D | bundle_manager_internal.h | 54 static int32_t CheckRemoteBundleInfoForContinuation(const std::string& dstDeviceId,
|
/foundation/ability/ability_runtime/interfaces/kits/native/ability/native/distributed_ability_runtime/ |
H A D | distributed_client.h | 37 int32_t ContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId,
|
/foundation/distributedhardware/distributed_audio/services/audiomanager/managersink/include/ |
H A D | daudio_sink_manager.h | 74 bool CheckDeviceSecurityLevel(const std::string &srcDeviceId, const std::string &dstDeviceId);
|
/foundation/filemanagement/dfs_service/frameworks/native/distributed_file_inner/include/ |
H A D | distributed_file_daemon_proxy.h | 51 const std::string &dstDeviceId,
|
/foundation/distributedhardware/distributed_audio/services/audiomanager/test/unittest/managersink/src/ |
H A D | daudio_sink_manager_test.cpp | 250 std::string dstDeviceId = "dstDeviceId"; in HWTEST_F() local 251 EXPECT_EQ(false, daudioSinkManager.CheckDeviceSecurityLevel(srcDeviceId, dstDeviceId)); in HWTEST_F()
|
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
H A D | distributed_sched_mission_manager.cpp | 963 void DistributedSchedMissionManager::RetryStartSyncRemoteMissions(const std::string& dstDeviceId, in RetryStartSyncRemoteMissions() argument 966 auto retryFunc = [this, dstDeviceId, localDevId, retryTimes]() { in RetryStartSyncRemoteMissions() 967 bool ret = HasSyncListener(dstDeviceId); in RetryStartSyncRemoteMissions() 971 sptr<IDistributedSched> remoteDms = GetRemoteDms(dstDeviceId); in RetryStartSyncRemoteMissions() 974 RetryStartSyncRemoteMissions(dstDeviceId, localDevId, retryTimes + 1); in RetryStartSyncRemoteMissions() 977 int32_t errNo = StartSyncRemoteMissions(dstDeviceId, remoteDms); in RetryStartSyncRemoteMissions()
|
/foundation/distributedhardware/distributed_camera/services/cameraservice/sinkservice/include/distributedcameramgr/ |
H A D | dcamera_sink_controller.h | 79 bool CheckDeviceSecurityLevel(const std::string &srcDeviceId, const std::string &dstDeviceId);
|
/foundation/ability/ability_runtime/frameworks/native/ability/native/distributed_ability_runtime/ |
H A D | distributed_client.cpp | 104 int32_t DistributedClient::ContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId, in ContinueMission() argument 121 PARCEL_WRITE_HELPER(data, String, dstDeviceId); in ContinueMission() 146 PARCEL_WRITE_HELPER(data, String, continueMissionInfo.dstDeviceId); in ContinueMission()
|
/foundation/distributedhardware/distributed_audio/services/audiomanager/managersink/src/ |
H A D | daudio_sink_manager.cpp | 426 bool DAudioSinkManager::CheckDeviceSecurityLevel(const std::string &srcDeviceId, const std::string &dstDeviceId)
in CheckDeviceSecurityLevel() argument 428 DHLOGD("CheckDeviceSecurityLevel srcDeviceId %{public}s, dstDeviceId %{public}s.",
in CheckDeviceSecurityLevel() 429 GetAnonyString(srcDeviceId).c_str(), GetAnonyString(dstDeviceId).c_str());
in CheckDeviceSecurityLevel() 435 std::string dstUdid = GetUdidByNetworkId(dstDeviceId);
in CheckDeviceSecurityLevel()
|