Home
last modified time | relevance | path

Searched refs:subscribeMap (Results 1 – 5 of 5) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsubscribe_manager.cpp236 if (subscribeMap.find(device) == subscribeMap.end()) { in ClearSubscribeQuery()
251 subscribeMap.erase(device); in ClearSubscribeQuery()
266 if (iter == subscribeMap.end() && subscribeMap.size() >= MAX_DEVICES_NUM) { in ReserveSubscribeQuery()
281 if (iter == subscribeMap.end()) { in ReserveSubscribeQuery()
285 if (subscribeMap[device].find(queryId) == subscribeMap[device].end()) { in ReserveSubscribeQuery()
304 if (subscribeMap.find(device) == subscribeMap.end()) { in ActiveSubscribeQuery()
308 if (subscribeMap[device].find(queryId) == subscribeMap[device].end()) { in ActiveSubscribeQuery()
319 if (subscribeMap.find(device) == subscribeMap.end()) { in DeleteSubscribeQuery()
323 if (subscribeMap[device].find(queryId) == subscribeMap[device].end()) { in DeleteSubscribeQuery()
351 if (iter == subscribeMap.end()) { in RemoveSubscribeQuery()
[all …]
H A Dsubscribe_manager.h91 void ClearSubscribeQuery(const std::string &device, SubscribeMap &subscribeMap,
94 …SubscribeQuery(const std::string &device, const QuerySyncObject &query, SubscribeMap &subscribeMap,
97 …veSubscribeQuery(const std::string &device, const std::string &queryId, SubscribeMap &subscribeMap,
100 …teSubscribeQuery(const std::string &device, const std::string &queryId, SubscribeMap &subscribeMap,
103 …veSubscribeQuery(const std::string &device, const std::string &queryId, SubscribeMap &subscribeMap,
106 void GetSubscribeQueries(const std::string &device, const SubscribeMap &subscribeMap,
/ohos5.0/foundation/ability/form_fwk/services/include/
H A Dform_data_proxy_record.h74 bool keyCheckingNeeded, SubscribeMap &subscribeMap);
75 void ConvertSubscribeMapToRequests(const SubscribeMap &subscribeMap,
/ohos5.0/foundation/ability/form_fwk/services/src/
H A Dform_data_proxy_record.cpp393 bool keyCheckingNeeded, SubscribeMap &subscribeMap) in ParseFormDataProxiesIntoSubscribeMapWithExpectedKeys() argument
395 subscribeMap.clear(); in ParseFormDataProxiesIntoSubscribeMapWithExpectedKeys()
401 auto it = subscribeMap.find(formDataProxy.key); in ParseFormDataProxiesIntoSubscribeMapWithExpectedKeys()
402 if (it == subscribeMap.end()) { in ParseFormDataProxiesIntoSubscribeMapWithExpectedKeys()
405 subscribeMap.emplace(formDataProxy.key, subscribeIds); in ParseFormDataProxiesIntoSubscribeMapWithExpectedKeys()
415 const SubscribeMap &subscribeMap, std::vector<FormDataProxyRequest> &formDataProxyRequests) in ConvertSubscribeMapToRequests() argument
422 for (const auto &record : subscribeMap) { in ConvertSubscribeMapToRequests()
/ohos5.0/foundation/ability/form_fwk/test/unittest/fms_form_data_proxy_record_test/
H A Dfms_form_data_proxy_record_test.cpp251 FormDataProxyRecord::SubscribeMap subscribeMap; variable
253 formDataProxyRecord.ConvertSubscribeMapToRequests(subscribeMap, formDataProxyRequests);