distributed_sched_service.cpp - OpenGrok cross reference for /foundation/ability/dmsfwk/services/dtbschedmgr/src/distributed_sched

Lines Matching defs:connectInfo
2085             ConnectInfo connectInfo {callerInfo, callbackWrapper, want.GetElement()};
2086             ReportDistributedComponentChange(connectInfo, DISTRIBUTED_COMPONENT_ADD,
2088             calleeMap_.emplace(connect, connectInfo);
2236             ConnectInfo connectInfo = iter.second;
2238             componentInfoJson[UID_KEY] = BundleManagerInternal::GetUidFromBms(connectInfo.element.GetBundleName());
2239             componentInfoJson[BUNDLE_NAME_KEY] = connectInfo.element.GetBundleName();
2271             ConnectInfo connectInfo = iter.second;
2273             componentInfoJson[UID_KEY] = BundleManagerInternal::GetUidFromBms(connectInfo.element.GetBundleName());
2274             componentInfoJson[BUNDLE_NAME_KEY] = connectInfo.element.GetBundleName();
2315 void DistributedSchedService::ReportDistributedComponentChange(const ConnectInfo& connectInfo, int32_t changeType,
2320     auto func = [this, connectInfo, changeType, componentType, deviceType]() {
2322         payload[UID_KEY] = std::to_string(BundleManagerInternal::GetUidFromBms(connectInfo.element.GetBundleName()));
2323         payload[BUNDLE_NAME_KEY] = connectInfo.element.GetBundleName();
2448             ConnectInfo connectInfo {callerInfo, callbackWrapper, want.GetElement()};
2449             ReportDistributedComponentChange(connectInfo, DISTRIBUTED_COMPONENT_ADD,
2451             connectAbilityMap_.emplace(connect, connectInfo);
2561             ConnectInfo& connectInfo = iter->second;
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) {
2567                 int32_t ret = DistributedSchedAdapter::GetInstance().DisconnectAbility(connectInfo.callbackWrapper);
2571                 ReportDistributedComponentChange(connectInfo, DISTRIBUTED_COMPONENT_REMOVE,
2616             ConnectInfo& connectInfo = iter->second;
2617             if (deviceId == connectInfo.callerInfo.sourceDeviceId) {
2618                 DistributedSchedAdapter::GetInstance().DisconnectAbility(connectInfo.callbackWrapper);
2619                 ReportDistributedComponentChange(connectInfo, DISTRIBUTED_COMPONENT_REMOVE,