Lines Matching refs:srcDeviceId
426 void DistributedSchedService::DurationStart(const std::string srcDeviceId, const std::string dstDeviceId)
431 DmsContinueTime::GetInstance().SetNetWorkId(srcDeviceId, dstDeviceId);
970 int32_t DistributedSchedService::ContinueRemoteMission(const std::string& srcDeviceId, const std::string& dstDeviceId,
977 sptr<IDistributedSched> remoteDms = GetRemoteDms(srcDeviceId);
992 DmsUE::GetInstance().TriggerDmsContinue(bundleName, abilityName, srcDeviceId, ERR_OK);
994 std::string peerUdid = DtbschedmgrDeviceInfoStorage::GetInstance().GetUdidByNetworkId(srcDeviceId);
997 int32_t result = remoteDms->ContinueMission(srcDeviceId, dstDeviceId, missionId, callback, wantParams);
1002 int32_t DistributedSchedService::ContinueRemoteMission(const std::string& srcDeviceId, const std::string& dstDeviceId,
1005 HILOGI("ContinueRemoteMission srcDeviceId: %{public}s. dstDeviceId: %{public}s. bundleName: %{public}s.",
1006 GetAnonymStr(srcDeviceId).c_str(), GetAnonymStr(dstDeviceId).c_str(), bundleName.c_str());
1013 sptr<IDistributedSched> remoteDms = GetRemoteDms(srcDeviceId);
1024 int32_t result = remoteDms->ContinueMission(srcDeviceId, dstDeviceId, bundleName, callback, wantParams);
1041 int32_t DistributedSchedService::ContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId,
1045 if (srcDeviceId.empty() || dstDeviceId.empty() || callback == nullptr) {
1046 HILOGE("srcDeviceId or dstDeviceId or callback is null!");
1054 DurationStart(srcDeviceId, dstDeviceId);
1056 if (srcDeviceId == localDevId) {
1064 if (DtbschedmgrDeviceInfoStorage::GetInstance().GetDeviceInfoById(srcDeviceId) == nullptr) {
1065 HILOGE("GetDeviceInfoById failed, srcDeviceId: %{public}s.", GetAnonymStr(srcDeviceId).c_str());
1068 return ContinueRemoteMission(srcDeviceId, dstDeviceId, missionId, callback, wantParams);
1075 int32_t DistributedSchedService::ProcessContinueLocalMission(const std::string& srcDeviceId,
1098 dschedContinuation_->continueEvent_.srcNetworkId_ = srcDeviceId;
1103 int32_t DistributedSchedService::ProcessContinueRemoteMission(const std::string& srcDeviceId,
1108 if (DtbschedmgrDeviceInfoStorage::GetInstance().GetDeviceInfoById(srcDeviceId) == nullptr) {
1109 HILOGE("GetDeviceInfoById failed, srcDeviceId: %{public}s.", GetAnonymStr(srcDeviceId).c_str());
1117 dschedContinuation_->continueEvent_.dstNetworkId_ = srcDeviceId;
1119 return ContinueRemoteMission(srcDeviceId, dstDeviceId, bundleName, callback, wantParams);
1122 int32_t DistributedSchedService::ContinueMission(const std::string& srcDeviceId, const std::string& dstDeviceId,
1125 HILOGI("ContinueMission srcDeviceId: %{public}s. dstDeviceId: %{public}s. bundleName: %{public}s.",
1126 GetAnonymStr(srcDeviceId).c_str(), GetAnonymStr(dstDeviceId).c_str(), bundleName.c_str());
1127 if (srcDeviceId.empty() || dstDeviceId.empty() || callback == nullptr) {
1128 HILOGE("srcDeviceId or dstDeviceId or callback is null!");
1136 DurationStart(srcDeviceId, dstDeviceId);
1138 if (srcDeviceId == localDevId) {
1139 return ProcessContinueLocalMission(srcDeviceId, dstDeviceId, bundleName, callback, wantParams);
1142 return ProcessContinueRemoteMission(srcDeviceId, dstDeviceId, bundleName, callback, wantParams);
3475 std::string srcDeviceId = "";
3482 srcDeviceId = iter->second.srcDeviceId;
3484 HILOGD("get srcDeviceId and missionId success");
3491 if (!GetLocalDeviceId(localDeviceId) || !CheckDeviceId(localDeviceId, srcDeviceId)) {
3495 sptr<IDistributedSched> remoteDms = GetRemoteDms(srcDeviceId);