add rpc radar

Signed-off-by: dengxiaoyu <dengxiaoyu6@huawei.com>
This commit is contained in:
dengxiaoyu 2024-06-25 22:30:25 +08:00
parent a593b5d58d
commit 1177995669

View File

@ -815,6 +815,7 @@ int32_t DistributedSchedService::ContinueAbilityWithTimeout(const std::string& d
SetContinuationTimeout(missionId, CONTINUATION_TIMEOUT); SetContinuationTimeout(missionId, CONTINUATION_TIMEOUT);
int64_t saveDataBegin = GetTickCount(); int64_t saveDataBegin = GetTickCount();
DmsContinueTime::GetInstance().SetSaveDataDurationBegin(saveDataBegin); DmsContinueTime::GetInstance().SetSaveDataDurationBegin(saveDataBegin);
DmsRadar::GetInstance().SaveDataDmsContinue("ContinueAbility", ERR_OK);
int32_t result = AbilityManagerClient::GetInstance()->ContinueAbility(dstDeviceId, missionId, remoteBundleVersion); int32_t result = AbilityManagerClient::GetInstance()->ContinueAbility(dstDeviceId, missionId, remoteBundleVersion);
HILOGI("result: %{public}d!", result); HILOGI("result: %{public}d!", result);
if (result == ERR_INVALID_VALUE) { if (result == ERR_INVALID_VALUE) {
@ -836,6 +837,7 @@ int32_t DistributedSchedService::ContinueRemoteMission(const std::string& srcDev
return INVALID_REMOTE_PARAMETERS_ERR; return INVALID_REMOTE_PARAMETERS_ERR;
} }
int32_t result = remoteDms->ContinueMission(srcDeviceId, dstDeviceId, missionId, callback, wantParams); int32_t result = remoteDms->ContinueMission(srcDeviceId, dstDeviceId, missionId, callback, wantParams);
DmsRadar::GetInstance().ClickIconDmsContinue("ContinueMission", result);
HILOGI("ContinueRemoteMission result: %{public}d!", result); HILOGI("ContinueRemoteMission result: %{public}d!", result);
return result; return result;
} }
@ -1091,6 +1093,7 @@ int32_t DistributedSchedService::StartContinuation(const OHOS::AAFwk::Want& want
} }
} else { } else {
result = StartRemoteAbility(newWant, callerUid, DEFAULT_REQUEST_CODE, accessToken); result = StartRemoteAbility(newWant, callerUid, DEFAULT_REQUEST_CODE, accessToken);
DmsRadar::GetInstance().SaveDataDmsRemoteWant("StartRemoteAbility", result);
if (result != ERR_OK) { if (result != ERR_OK) {
HILOGE("continue ability failed, errorCode = %{public}d", result); HILOGE("continue ability failed, errorCode = %{public}d", result);
return result; return result;
@ -1133,11 +1136,12 @@ void DistributedSchedService::NotifyCompleteContinuation(const std::u16string& d
dstInfo = DmsContinueTime::GetInstance().WriteDstInfo(DmsContinueTime::GetInstance().GetDstInfo().bundleName, dstInfo = DmsContinueTime::GetInstance().WriteDstInfo(DmsContinueTime::GetInstance().GetDstInfo().bundleName,
DmsContinueTime::GetInstance().GetDstInfo().abilityName); DmsContinueTime::GetInstance().GetDstInfo().abilityName);
} }
int dSchedEventresult = dschedContinuation_->NotifyDSchedEventResult(ERR_OK); int dSchedEventResult = dschedContinuation_->NotifyDSchedEventResult(ERR_OK);
HILOGD("NotifyDSchedEventResult result:%{public}d", dSchedEventresult); HILOGD("NotifyDSchedEventResult result:%{public}d", dSchedEventresult);
remoteDms->NotifyContinuationResultFromRemote(sessionId, isSuccess, dstInfo); remoteDms->NotifyContinuationResultFromRemote(sessionId, isSuccess, dstInfo);
dschedContinuation_->continueInfo_.srcNetworkId_ = ""; dschedContinuation_->continueInfo_.srcNetworkId_ = "";
dschedContinuation_->continueInfo_.dstNetworkId_ = ""; dschedContinuation_->continueInfo_.dstNetworkId_ = "";
DmsRadar::GetInstance().ClickIconDmsRecvOver("NotifyContinuationResultFromRemote", dSchedEventResult);
} }
int32_t DistributedSchedService::NotifyContinuationResultFromRemote(int32_t sessionId, bool isSuccess, int32_t DistributedSchedService::NotifyContinuationResultFromRemote(int32_t sessionId, bool isSuccess,