| /foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/lane_manager/src/ |
| H A D | lnn_lane_query.c | 303 static int32_t QueryByRequireLink(const LaneQueryInfo *queryInfo, const QosInfo *qosInfo) in QueryByRequireLink() argument
306 return IsValidLaneLink(queryInfo->networkId, LANE_P2P); in QueryByRequireLink()
316 int32_t ret = GetLaneResource(queryInfo->transType, optLink, &linkNum, isHighBand); in QueryByRequireLink()
322 ret = IsValidLaneLink(queryInfo->networkId, optLink[i]); in QueryByRequireLink()
331 static int32_t QueryByDefaultLink(const LaneQueryInfo *queryInfo) in QueryByDefaultLink() argument
336 int32_t ret = GetLaneResource(queryInfo->transType, optLink, &linkNum, false); in QueryByDefaultLink()
342 ret = IsValidLaneLink(queryInfo->networkId, optLink[i]); in QueryByDefaultLink()
351 int32_t QueryLaneResource(const LaneQueryInfo *queryInfo, const QosInfo *qosInfo) in QueryLaneResource() argument
353 if (queryInfo == NULL || qosInfo == NULL) { in QueryLaneResource()
359 queryInfo in QueryLaneResource()
[all...] |
| H A D | lnn_lane.c | 567 int32_t LnnQueryLaneResource(const LaneQueryInfo *queryInfo, const QosInfo *qosInfo) in LnnQueryLaneResource() argument
569 if (queryInfo == NULL || qosInfo == NULL) { in LnnQueryLaneResource()
574 if (!LnnGetOnlineStateById(queryInfo->networkId, CATEGORY_NETWORK_ID)) { in LnnQueryLaneResource()
576 Anonymize(queryInfo->networkId, &anonyNetworkId); in LnnQueryLaneResource()
582 return QueryLaneResource(queryInfo, qosInfo); in LnnQueryLaneResource()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | subscribe_manager.cpp | 195 for (const auto &queryInfo : iter->second) { in GetRemoteSubscribeQueryIds()
196 if (remoteSubscribedTotalMap_.find(queryInfo.first) == remoteSubscribedTotalMap_.end()) { in GetRemoteSubscribeQueryIds()
197 LOGE("[SubscribeManager] queryId=%s not in RemoteTotalMap", STR_MASK(queryInfo.first)); in GetRemoteSubscribeQueryIds()
200 subscribeQueryIds.push_back(queryInfo.first); in GetRemoteSubscribeQueryIds()
240 for (const auto &queryInfo : subscribeMap[device]) { in ClearSubscribeQuery()
241 if (subscribedTotalMap.find(queryInfo.first) != subscribedTotalMap.end()) { in ClearSubscribeQuery()
242 if (subscribedTotalMap[queryInfo.first].second > 0) { in ClearSubscribeQuery()
243 subscribedTotalMap[queryInfo.first].second--; in ClearSubscribeQuery()
245 if (subscribedTotalMap[queryInfo.first].second == 0) { in ClearSubscribeQuery()
246 LOGI("[SubscribeManager] queryId=%s delete from TotalMap", STR_MASK(queryInfo in ClearSubscribeQuery()
[all...] |
| /foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/lane_manager/include/ |
| H A D | lnn_lane_query.h | 25 int32_t QueryLaneResource(const LaneQueryInfo *queryInfo, const QosInfo *qosInfo);
|
| H A D | lnn_lane_interface.h | 256 int32_t (*lnnQueryLaneResource)(const LaneQueryInfo *queryInfo, const QosInfo *qosInfo);
273 int32_t LnnQueryLaneResource(const LaneQueryInfo *queryInfo, const QosInfo *qosInfo);
|
| /foundation/communication/dsoftbus/tests/core/bus_center/lnn/lane/src/ |
| H A D | lnn_lane_deps_mock.cpp | 383 int32_t QueryLaneResource(const LaneQueryInfo *queryInfo, const QosInfo *qosInfo) in QueryLaneResource() argument
385 return GetLaneDepsInterface()->QueryLaneResource(queryInfo, qosInfo); in QueryLaneResource()
|
| /foundation/ability/ability_runtime/services/abilitymgr/src/data_ability/ |
| H A D | data_ability_manager.cpp | 606 auto queryInfo = [&info, isPerm](DataAbilityRecordPtrMap::reference data) { in GetAbilityRunningInfos() local
628 std::for_each(dataAbilityRecordsLoading_.begin(), dataAbilityRecordsLoading_.end(), queryInfo); in GetAbilityRunningInfos()
629 std::for_each(dataAbilityRecordsLoaded_.begin(), dataAbilityRecordsLoaded_.end(), queryInfo); in GetAbilityRunningInfos()
|
| /foundation/communication/dsoftbus/tests/core/bus_center/lnn/lane/include/ |
| H A D | lnn_lane_deps_mock.h | 99 virtual int32_t QueryLaneResource(const LaneQueryInfo *queryInfo, const QosInfo *qosInfo) = 0;
|
| /foundation/ability/ability_runtime/services/abilitymgr/src/ |
| H A D | ability_connect_manager.cpp | 2503 auto queryInfo = [&](ServiceMapType::reference service) { in GetExtensionRunningInfos() local
2520 std::for_each(serviceMapBack.begin(), serviceMapBack.end(), queryInfo); in GetExtensionRunningInfos()
2545 auto queryInfo = [&info, isPerm](ServiceMapType::reference service) { in GetAbilityRunningInfos() local
2560 std::for_each(serviceMapBack.begin(), serviceMapBack.end(), queryInfo); in GetAbilityRunningInfos()
|
| /foundation/distributedhardware/device_manager/interfaces/kits/js/src/ |
| H A D | native_devicemanager_js.cpp | 2638 if (!CheckArgsType(env, queryInfoValueType == napi_string, "queryInfo", "string")) {
in DeleteCredential()
2664 std::string queryInfo = type;
in DeleteCredential() local
2665 int32_t ret = DeviceManager::GetInstance().DeleteCredential(deviceManagerWrapper->bundleName_, queryInfo);
in DeleteCredential()
|