Lines Matching refs:callerInfo
697 uint32_t accessToken, CallerInfo &callerInfo)
699 callerInfo.sourceDeviceId = localDeviceId;
700 callerInfo.uid = callerUid;
701 callerInfo.accessToken = accessToken;
702 if (!BundleManagerInternal::GetCallerAppIdFromBms(callerInfo.uid, callerInfo.callerAppId)) {
706 if (!BundleManagerInternal::GetBundleNameListFromBms(callerInfo.uid, callerInfo.bundleNames)) {
710 callerInfo.extraInfoJson[DMS_VERSION_ID] = DMS_VERSION;
735 CallerInfo callerInfo;
736 int32_t ret = GetCallerInfo(localDeviceId, callerUid, accessToken, callerInfo);
742 ret = DistributedSchedPermission::GetInstance().GetAccountInfo(deviceId, callerInfo, accountInfo);
756 int32_t result = remoteDms->StartAbilityFromRemote(*newWant, abilityInfo, requestCode, callerInfo, accountInfo);
768 const CallerInfo& callerInfo, const AccountInfo& accountInfo)
774 !CheckDeviceIdFromRemote(localDeviceId, deviceId, callerInfo.sourceDeviceId)) {
784 int32_t result = CheckTargetPermission(want, callerInfo, accountInfo, START_PERMISSION, true);
794 const CallerInfo& callerInfo, const AccountInfo& accountInfo, int32_t resultCode)
800 !CheckDeviceIdFromRemote(localDeviceId, deviceId, callerInfo.sourceDeviceId)) {
824 int32_t result = CheckTargetPermission(want, callerInfo, accountInfo, SEND_RESULT_PERMISSION, false);
1481 void DistributedSchedService::GetCurSrcCollaborateEvent(const CallerInfo &callerInfo,
1485 if (!BundleManagerInternal::GetSpecifyBundleNameFromBms(callerInfo.uid, callingBundleName)) {
1486 HILOGE("Get specify bundle name for from Bms fail, connect session caller uid %{public}d.", callerInfo.uid);
1490 event.srcNetworkId_ = callerInfo.sourceDeviceId;
1502 void DistributedSchedService::GetCurDestCollaborateEvent(const CallerInfo &callerInfo,
1506 if (callerInfo.extraInfoJson.find(DMS_UID_SPEC_BUNDLE_NAME) != callerInfo.extraInfoJson.end() &&
1507 callerInfo.extraInfoJson[DMS_UID_SPEC_BUNDLE_NAME].is_string()) {
1508 callerBundleName = callerInfo.extraInfoJson[DMS_UID_SPEC_BUNDLE_NAME];
1512 event.srcNetworkId_ = callerInfo.sourceDeviceId;
1526 const CallerInfo& callerInfo, TargetComponent targetComponent)
1534 uint32_t number = ++trackingUidMap_[callerInfo.uid];
1536 callerInfo.uid, number, targetComponent);
1539 ReportDistributedComponentChange(callerInfo, DISTRIBUTED_COMPONENT_ADD, IDistributedSched::CONNECT,
1551 auto& session = sessionsList.emplace_back(localDeviceId, remoteDeviceId, callerInfo, targetComponent);
1556 int32_t DistributedSchedService::CheckDistributedConnectLocked(const CallerInfo& callerInfo) const
1558 if (callerInfo.uid < 0) {
1559 HILOGE("uid %{public}d is invalid.", callerInfo.uid);
1562 auto it = trackingUidMap_.find(callerInfo.uid);
1564 HILOGE("uid %{public}d connected too much abilities, it maybe leak.", callerInfo.uid);
1613 CallerInfo callerInfo = { callerUid, callerPid, CALLER_TYPE_HARMONY, localDeviceId };
1614 callerInfo.accessToken = accessToken;
1617 int32_t checkResult = CheckDistributedConnectLocked(callerInfo);
1622 if (!BundleManagerInternal::GetCallerAppIdFromBms(callerInfo.uid, callerInfo.callerAppId)) {
1626 if (!BundleManagerInternal::GetBundleNameListFromBms(callerInfo.uid, callerInfo.bundleNames)) {
1630 callerInfo.extraInfoJson[DMS_VERSION_ID] = DMS_VERSION;
1632 int32_t result = TryConnectRemoteAbility(want, connect, callerInfo);
1641 const sptr<IRemoteObject>& connect, const CallerInfo& callerInfo)
1651 int32_t ret = DistributedSchedPermission::GetInstance().GetAccountInfo(remoteDeviceId, callerInfo, accountInfo);
1661 result = remoteDms->ConnectAbilityFromRemote(want, abilityInfo, connect, callerInfo, accountInfo);
1665 RemoteConnectAbilityMappingLocked(connect, callerInfo.sourceDeviceId, remoteDeviceId,
1666 want.GetElement(), callerInfo, TargetComponent::HARMONY_COMPONENT);
1693 CallerInfo callerInfo;
1702 callerInfo = itConnect->second.callerInfo;
1706 GetCurDestCollaborateEvent(callerInfo, element, DMS_DSCHED_EVENT_STOP, ERR_OK, tempEvent);
1718 GetCurDestCollaborateEvent(callerInfo, element, DMS_DSCHED_EVENT_FINISH, result, tempEvent);
1759 CallerInfo callerInfo;
1769 callerInfo = itConnect->second.callerInfo;
1777 GetCurDestCollaborateEvent(callerInfo, element, DMS_DSCHED_EVENT_STOP, ERR_OK, tempEvent);
1781 GetCurDestCollaborateEvent(callerInfo, element, DMS_DSCHED_EVENT_FINISH, ERR_OK, tempEvent);
1804 const sptr<IRemoteObject>& connect, const CallerInfo& callerInfo)
1816 int32_t ret = DistributedSchedPermission::GetInstance().GetAccountInfo(remoteDeviceId, callerInfo, accountInfo);
1825 int32_t result = remoteDms->StartAbilityByCallFromRemote(remoteWant, connect, callerInfo, accountInfo);
1828 SaveCallerComponent(want, connect, callerInfo);
1836 const sptr<IRemoteObject>& connect, const CallerInfo& callerInfo)
1846 ReportDistributedComponentChange(callerInfo, DISTRIBUTED_COMPONENT_ADD, IDistributedSched::CALL,
1859 auto& session = sessionsList.emplace_back(callerInfo.sourceDeviceId, remoteDeviceId, callerInfo);
1864 GetCurSrcCollaborateEvent(callerInfo, want.GetElement(), DMS_DSCHED_EVENT_PROCESSING, ERR_OK, tempEvent);
1912 CallerInfo callerInfo;
1914 callerInfo = itSession->GetCallerInfo();
1917 GetCurSrcCollaborateEvent(callerInfo, element, DMS_DSCHED_EVENT_FINISH, ERR_OK, tempEvent);
1927 ReportDistributedComponentChange(callerInfo, DISTRIBUTED_COMPONENT_REMOVE,
1980 CallerInfo callerInfo = { callerUid, callerPid };
1981 callerInfo.sourceDeviceId = localDeviceId;
1982 callerInfo.accessToken = accessToken;
1983 if (!BundleManagerInternal::GetCallerAppIdFromBms(callerInfo.uid, callerInfo.callerAppId)) {
1987 if (!BundleManagerInternal::GetBundleNameListFromBms(callerInfo.uid, callerInfo.bundleNames)) {
1991 callerInfo.extraInfoJson[DMS_VERSION_ID] = DMS_VERSION;
1993 if (!BundleManagerInternal::GetSpecifyBundleNameFromBms(callerInfo.uid, uidSpecBundleName)) {
1994 HILOGE("Get specify bundle name for from Bms fail, connect session caller uid %{public}d.", callerInfo.uid);
1996 callerInfo.extraInfoJson[DMS_UID_SPEC_BUNDLE_NAME] = uidSpecBundleName;
1999 GetCurSrcCollaborateEvent(callerInfo, want.GetElement(), DMS_DSCHED_EVENT_START, ERR_OK, tempEvent);
2002 int32_t ret = TryStartRemoteAbilityByCall(want, connect, callerInfo);
2030 CallerInfo callerInfo;
2031 if (!GetLocalDeviceId(callerInfo.sourceDeviceId)) {
2035 int32_t result = remoteDms->ReleaseAbilityFromRemote(connect, element, callerInfo);
2045 const sptr<IRemoteObject>& connect, const CallerInfo& callerInfo, const AccountInfo& accountInfo)
2054 GetCurDestCollaborateEvent(callerInfo, want.GetElement(), DMS_DSCHED_EVENT_START, ERR_OK, tempEvent);
2060 !CheckDeviceIdFromRemote(localDeviceId, destinationDeviceId, callerInfo.sourceDeviceId)) {
2064 int32_t result = CheckTargetPermission(want, callerInfo, accountInfo, CALL_PERMISSION, false);
2085 ConnectInfo connectInfo {callerInfo, callbackWrapper, want.GetElement()};
2091 if (!RegisterAppStateObserver(want, callerInfo, connect, callbackWrapper)) {
2096 GetCurDestCollaborateEvent(callerInfo, want.GetElement(), DMS_DSCHED_EVENT_PROCESSING, ERR_OK, tempEvent);
2102 const AppExecFwk::ElementName &element, const CallerInfo& callerInfo)
2109 GetCurDestCollaborateEvent(callerInfo, element, DMS_DSCHED_EVENT_STOP, ERR_OK, tempEvent);
2115 callerInfo.sourceDeviceId.empty() || localDeviceId == callerInfo.sourceDeviceId) {
2140 GetCurDestCollaborateEvent(callerInfo, element, DMS_DSCHED_EVENT_FINISH, result, tempEvent);
2221 CallerInfo callerInfo = iter.second.front().GetCallerInfo();
2223 componentInfoJson[PID_KEY] = callerInfo.pid;
2224 componentInfoJson[UID_KEY] = callerInfo.uid;
2226 callerInfo.bundleNames.empty() ? std::string() : callerInfo.bundleNames.front();
2256 CallerInfo callerInfo = iter.second.front().GetCallerInfo();
2258 componentInfoJson[PID_KEY] = callerInfo.pid;
2259 componentInfoJson[UID_KEY] = callerInfo.uid;
2261 callerInfo.bundleNames.empty() ? std::string() : callerInfo.bundleNames.front();
2283 void DistributedSchedService::ReportDistributedComponentChange(const CallerInfo& callerInfo, int32_t changeType,
2288 auto func = [this, callerInfo, changeType, componentType, deviceType]() {
2291 payload[PID_KEY] = std::to_string(callerInfo.pid);
2292 payload[UID_KEY] = std::to_string(callerInfo.uid);
2294 callerInfo.bundleNames.empty() ? std::string() : callerInfo.bundleNames.front();
2302 Memory::MemMgrClient::GetInstance().NotifyDistDevStatus(callerInfo.pid, callerInfo.uid,
2303 callerInfo.bundleNames.empty() ? std::string() : callerInfo.bundleNames.front(),
2409 const CallerInfo& callerInfo, const AccountInfo& accountInfo)
2417 callerInfo.uid, callerInfo.pid, GetAnonymStr(std::to_string(callerInfo.accessToken)).c_str());
2421 !CheckDeviceIdFromRemote(localDeviceId, destinationDeviceId, callerInfo.sourceDeviceId)) {
2425 int32_t result = CheckTargetPermission(want, callerInfo, accountInfo, START_PERMISSION, true);
2431 HILOGD("ConnectAbilityFromRemote callerType is %{public}d", callerInfo.callerType);
2434 if (callerInfo.callerType == CALLER_TYPE_HARMONY) {
2448 ConnectInfo connectInfo {callerInfo, callbackWrapper, want.GetElement()};
2554 int32_t DistributedSchedService::NotifyProcessDiedFromRemote(const CallerInfo& callerInfo)
2562 if (callerInfo.sourceDeviceId == connectInfo.callerInfo.sourceDeviceId
2563 && callerInfo.uid == connectInfo.callerInfo.uid
2564 && callerInfo.pid == connectInfo.callerInfo.pid
2565 && callerInfo.callerType == connectInfo.callerInfo.callerType) {
2592 CallerInfo callerInfo;
2595 callerInfo = itSession->GetCallerInfo();
2604 ReportDistributedComponentChange(callerInfo, DISTRIBUTED_COMPONENT_REMOVE,
2617 if (deviceId == connectInfo.callerInfo.sourceDeviceId) {
2713 CallerInfo callerInfo = connectSessionsList.front().GetCallerInfo();
2718 if (!sessionsList.empty() && sessionsList.front().IsSameCaller(callerInfo)) {
2727 ProcessDiedNotifyInfo notifyInfo = { remoteDeviceId, callerInfo, targetComponent };
2731 DecreaseConnectLocked(callerInfo.uid);
2735 ReportDistributedComponentChange(callerInfo, DISTRIBUTED_COMPONENT_REMOVE,
2749 NotifyProcessDied(it->remoteDeviceId, it->callerInfo, it->targetComponent);
2754 const CallerInfo& callerInfo, TargetComponent targetComponent)
2766 int32_t result = remoteDms->NotifyProcessDiedFromRemote(callerInfo);
2771 const CallerInfo& callerInfo, TargetComponent targetComponent)
2774 callerInfo_(callerInfo),
2789 bool ConnectAbilitySession::IsSameCaller(const CallerInfo& callerInfo)
2791 return (callerInfo.uid == callerInfo_.uid &&
2792 callerInfo.pid == callerInfo_.pid &&
2793 callerInfo.sourceDeviceId == callerInfo_.sourceDeviceId &&
2794 callerInfo.callerType == callerInfo_.callerType);
2856 const CallerInfo& callerInfo)
2859 .NotifyMissionsChangedFromRemote(callerInfo, missionInfos);
2903 int32_t DistributedSchedService::StartSyncMissionsFromRemote(const CallerInfo& callerInfo,
2906 return DistributedSchedMissionManager::GetInstance().StartSyncMissionsFromRemote(callerInfo, missionInfos);
2909 int32_t DistributedSchedService::StopSyncMissionsFromRemote(const CallerInfo& callerInfo)
2911 DistributedSchedMissionManager::GetInstance().StopSyncMissionsFromRemote(callerInfo.sourceDeviceId);
3074 HILOGE("Connect session callerInfo uid %{public}d is different from callingUid %{public}d, "
3102 GetCurDestCollaborateEvent(iter.second.callerInfo, iter.second.element,
3115 int32_t callerUid, std::string localDeviceId, uint32_t accessToken, CallerInfo& callerInfo)
3117 callerInfo.uid = callerUid;
3118 callerInfo.callerType = CALLER_TYPE_HARMONY;
3119 callerInfo.sourceDeviceId = localDeviceId;
3120 callerInfo.accessToken = accessToken;
3121 if (!BundleManagerInternal::GetCallerAppIdFromBms(callerInfo.uid, callerInfo.callerAppId)) {
3125 if (!BundleManagerInternal::GetBundleNameListFromBms(callerInfo.uid, callerInfo.bundleNames)) {
3129 callerInfo.extraInfoJson[DMS_VERSION_ID] = DMS_VERSION;
3165 CallerInfo callerInfo;
3166 if (SetCallerInfo(callerUid, localDeviceId, accessToken, callerInfo) != ERR_OK) {
3171 if ((DistributedSchedPermission::GetInstance().GetAccountInfo(deviceId, callerInfo, accountInfo)) != ERR_OK) {
3177 FreeInstallInfo info = {*newWant, requestCode, callerInfo, accountInfo};
3193 !CheckDeviceIdFromRemote(localDeviceId, deviceId, info.callerInfo.sourceDeviceId)) {
3241 int32_t result = CheckTargetPermission(info.want, info.callerInfo, info.accountInfo, START_PERMISSION, true);
3293 sptr<IDistributedSched> remoteDms = GetRemoteDms(info.callerInfo.sourceDeviceId);
3365 bool DistributedSchedService::RegisterAppStateObserver(const OHOS::AAFwk::Want& want, const CallerInfo& callerInfo,
3401 observerMap_[callbackWrapper] = {appStateObserver, callerInfo.sourceDeviceId, connectToken,
3539 const CallerInfo& callerInfo, const AccountInfo& accountInfo, int32_t flag,
3552 callerInfo.callerType, accountInfo.accountType, callerInfo.uid,
3553 GetAnonymStr(std::to_string(callerInfo.accessToken)).c_str());
3556 return permissionInstance.CheckStartPermission(want, callerInfo, accountInfo, targetAbility, true);
3559 return permissionInstance.CheckGetCallerPermission(want, callerInfo, accountInfo, targetAbility);
3562 return permissionInstance.CheckSendResultPermission(want, callerInfo, accountInfo, targetAbility);
3569 const CallerInfo& callerInfo, const AccountInfo& accountInfo, int32_t flag,
3582 callerInfo.callerType, accountInfo.accountType, callerInfo.uid,
3583 GetAnonymStr(std::to_string(callerInfo.accessToken)).c_str());
3586 return permissionInstance.CheckStartPermission(want, callerInfo, accountInfo, targetAbility, false);
3589 return permissionInstance.CheckGetCallerPermission(want, callerInfo, accountInfo, targetAbility);
3592 return permissionInstance.CheckSendResultPermission(want, callerInfo, accountInfo, targetAbility);
3612 CallerInfo callerInfo;
3613 callerInfo.sourceDeviceId = localDeviceId;
3614 callerInfo.uid = callerUid;
3615 callerInfo.accessToken = accessToken;
3616 if (!BundleManagerInternal::GetCallerAppIdFromBms(callerInfo.uid, callerInfo.callerAppId)) {
3620 if (!BundleManagerInternal::GetBundleNameListFromBms(callerInfo.uid, callerInfo.bundleNames)) {
3625 if ((DistributedSchedPermission::GetInstance().GetAccountInfo(deviceId, callerInfo, accountInfo)) != ERR_OK) {
3631 return remoteDms->StopExtensionAbilityFromRemote(remoteWant, callerInfo, accountInfo, extensionType);
3635 const CallerInfo& callerInfo, const AccountInfo& accountInfo, int32_t extensionType)
3640 !CheckDeviceIdFromRemote(localDeviceId, destinationDeviceId, callerInfo.sourceDeviceId)) {
3645 int32_t permissionValid = CheckTargetPermission(remoteWant, callerInfo, accountInfo, START_PERMISSION, true);