| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | subscribe_manager.cpp | 54 std::string queryId = query.GetIdentify(); in ActiveRemoteSubscribeQuery() local
72 std::string queryId = query.GetIdentify(); in ActiveLocalSubscribeQuery() local
88 std::string queryId = query.GetIdentify(); in DeleteLocalSubscribeQuery() local
95 std::string queryId = query.GetIdentify(); in DeleteRemoteSubscribeQuery() local
139 std::string queryId = query.GetIdentify(); in RemoveRemoteSubscribeQuery() local
146 std::string queryId = query.GetIdentify(); in RemoveLocalSubscribeQuery() local
292 subscribedTotalMap[queryId].second++; in ReserveSubscribeQuery()
333 subscribeMap[device].erase(queryId); in DeleteSubscribeQuery()
342 subscribedTotalMap.erase(queryId); in DeleteSubscribeQuery()
359 iter->second.erase(queryId); in RemoveSubscribeQuery()
[all …]
|
| H A D | subscribe_manager.h | 85 bool IsLastRemoteContainSubscribe(const std::string &device, const std::string &queryId) const;
89 bool IsQueryExistSubscribe(const std::string &queryId) const;
97 …int ActiveSubscribeQuery(const std::string &device, const std::string &queryId, SubscribeMap &subs…
100 …void DeleteSubscribeQuery(const std::string &device, const std::string &queryId, SubscribeMap &sub…
103 …void RemoveSubscribeQuery(const std::string &device, const std::string &queryId, SubscribeMap &sub…
|
| H A D | subscribe_recorder.cpp | 104 const std::string &queryId) in RemoveSubscribeQuery() argument
118 …queryEntry->second.begin(), queryEntry->second.end(), [&queryId](const QuerySyncObject &checkQuery… in RemoveSubscribeQuery()
119 return checkQuery.GetIdentify() == queryId; in RemoveSubscribeQuery()
|
| H A D | query_sync_water_mark_helper.cpp | 287 …erySyncWaterMarkHelper::GetHashQuerySyncDeviceId(const DeviceID &deviceId, const DeviceID &queryId) in GetHashQuerySyncDeviceId() argument
291 if (deviceIdToHashQuerySyncIdMap_[deviceId].count(queryId) == 0) { in GetHashQuerySyncDeviceId()
293 …QuerySyncId = DBConstant::QUERY_SYNC_PREFIX_KEY + DBCommon::TransferHashString(deviceId) + queryId; in GetHashQuerySyncDeviceId()
294 deviceIdToHashQuerySyncIdMap_[deviceId][queryId] = hashQuerySyncId; in GetHashQuerySyncDeviceId()
296 hashQuerySyncId = deviceIdToHashQuerySyncIdMap_[deviceId][queryId]; in GetHashQuerySyncDeviceId()
|
| H A D | subscribe_recorder.h | 49 …d RemoveSubscribeQuery(const DBInfo &dbInfo, const DeviceID &deviceId, const std::string &queryId);
|
| H A D | meta_data.h | 135 uint64_t GetQueryLastTimestamp(const DeviceID &deviceId, const std::string &queryId) const;
137 void RemoveQueryFromRecordSet(const DeviceID &deviceId, const std::string &queryId);
|
| H A D | query_sync_water_mark_helper.h | 110 DeviceID GetHashQuerySyncDeviceId(const DeviceID &deviceId, const DeviceID &queryId);
|
| H A D | meta_data.cpp | 546 uint64_t Metadata::GetQueryLastTimestamp(const DeviceID &deviceId, const std::string &queryId) const in GetQueryLastTimestamp()
550 …d::string hashqueryId = DBConstant::SUBSCRIBE_QUERY_PREFIX + DBCommon::TransferHashString(queryId); in GetQueryLastTimestamp()
576 void Metadata::RemoveQueryFromRecordSet(const DeviceID &deviceId, const std::string &queryId) in RemoveQueryFromRecordSet() argument
579 …d::string hashqueryId = DBConstant::SUBSCRIBE_QUERY_PREFIX + DBCommon::TransferHashString(queryId); in RemoveQueryFromRecordSet()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/cj/src/ |
| H A D | distributed_kv_store_ffi.cpp | 234 …OSDistributedKVStoreDeviceKVStoreGetEntriesQuery(int64_t id, const char* deviceId, int64_t queryId, in FfiOHOSDistributedKVStoreDeviceKVStoreGetEntriesQuery() argument
238 auto query = FFIData::GetData<CQuery>(queryId); in FfiOHOSDistributedKVStoreDeviceKVStoreGetEntriesQuery()
257 …DistributedKVStoreDeviceKVStoreGetResultSetQuery(int64_t id, const char* deviceId, int64_t queryId, in FfiOHOSDistributedKVStoreDeviceKVStoreGetResultSetQuery() argument
261 auto query = FFIData::GetData<CQuery>(queryId); in FfiOHOSDistributedKVStoreDeviceKVStoreGetResultSetQuery()
269 …OHOSDistributedKVStoreDeviceKVStoreGetResultSize(int64_t id, const char* deviceId, int64_t queryId, in FfiOHOSDistributedKVStoreDeviceKVStoreGetResultSize() argument
273 auto query = FFIData::GetData<CQuery>(queryId); in FfiOHOSDistributedKVStoreDeviceKVStoreGetResultSize()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_relational_sync_task_context.cpp | 58 std::string queryId; in CopyTargetData() local
62 queryId = query_.GetIdentify(); in CopyTargetData()
67 querySyncId_ = hexTableName + queryId; // save as deviceId + hexTableName + queryId in CopyTargetData()
|
| H A D | single_ver_kv_syncer.cpp | 265 std::string queryId = query.GetIdentify(); in TriggerSubQuerySync() local
267 uint64_t lastTimestamp = metadata->GetQueryLastTimestamp(device, queryId); in TriggerSubQuerySync()
268 errCode = metadata->GetSendQueryWaterMark(queryId, device, queryWaterMark, false); in TriggerSubQuerySync()
270 … LOGE("[Syncer] get queryId=%s,dev=%s watermark failed", STR_MASK(queryId), STR_MASK(device)); in TriggerSubQuerySync()
277 queryWaterMark, STR_MASK(queryId), STR_MASK(device)); in TriggerSubQuerySync()
|
| H A D | single_ver_data_sync.h | 188 …void UpdateQueryPeerWaterMark(SyncType syncType, const std::string &queryId, const SyncTimeRange &…
191 …void UpdatePeerWaterMark(SyncType syncType, const std::string &queryId, const SingleVerSyncTaskCon…
252 …void RemoveSubscribeIfNeed(const std::string &queryId, const std::shared_ptr<SubscribeManager> &su…
|
| H A D | single_ver_sync_task_context.cpp | 102 std::string queryId = operation->GetQueryId(); in AddSyncOperation() local
104 [isQuerySync, queryId](const ISyncTarget *target) { in AddSyncOperation()
111 … return (tmpOperation != nullptr && tmpOperation->GetQueryId() == queryId) && target->IsAutoSync(); in AddSyncOperation()
|
| H A D | single_ver_data_sync.cpp | 470 std::string queryId = context->GetQuerySyncId(); in SaveLocalWaterMark() local
473 GetLocalWaterMark(syncType, queryId, context, localMark); in SaveLocalWaterMark()
484 GetLocalWaterMark(syncType, queryId, context, localMark); in SaveLocalWaterMark()
495 errCode = metadata_->SetSendQueryWaterMark(queryId, deviceId, dataTimeRange.endTime); in SaveLocalWaterMark()
875 void SingleVerDataSync::UpdateQueryPeerWaterMark(SyncType syncType, const std::string &queryId, in UpdateQueryPeerWaterMark() argument
886 UpdatePeerWaterMark(syncType, queryId, context, tmpPeerWatermark, tmpPeerDeletedWatermark); in UpdateQueryPeerWaterMark()
889 void SingleVerDataSync::UpdatePeerWaterMark(SyncType syncType, const std::string &queryId, in UpdatePeerWaterMark() argument
901 … errCode = metadata_->SetRecvQueryWaterMark(queryId, context->GetDeviceId(), peerWatermark); in UpdatePeerWaterMark()
2136 void SingleVerDataSync::RemoveSubscribeIfNeed(const std::string &queryId, in RemoveSubscribeIfNeed() argument
2139 if (!subscribeManager->IsQueryExistSubscribe(queryId)) { in RemoveSubscribeIfNeed()
[all …]
|
| H A D | single_ver_data_packet.cpp | 280 void DataRequestPacket::SetQueryId(const std::string &queryId) in SetQueryId() argument
282 queryId_ = queryId; in SetQueryId()
|
| H A D | single_ver_sync_state_machine.h | 97 int GetSendQueryWaterMark(const std::string &queryId, const DeviceID &deviceId, bool isAutoLift,
|
| H A D | single_ver_data_packet.h | 99 void SetQueryId(const std::string &queryId);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/cj/include/ |
| H A D | distributed_kv_store_ffi.h | 81 int64_t queryId, int32_t* errCode);
87 int64_t queryId, int32_t* errCode);
90 int64_t queryId, int32_t* errCode);
|
| /ohos5.0/foundation/graphic/graphic_2d/interfaces/kits/napi/graphic/webgl/src/ |
| H A D | webgl2_rendering_context_impl.cpp | 66 uint32_t queryId = 0; in CreateQuery() local
67 glGenQueries(1, &queryId); in CreateQuery()
68 webGlQuery->SetQuery(queryId); in CreateQuery()
76 uint32_t queryId = 0; in DeleteQuery() local
81 queryId = webGlQuery->GetQuery(); in DeleteQuery()
82 glDeleteQueries(1, &queryId); in DeleteQuery()
98 GLuint queryId = 0; in IsQuery() local
133 GLuint queryId = 0; in BeginQuery() local
157 currentQuery_[index] = queryId; in BeginQuery()
160 glBeginQuery(target, queryId); in BeginQuery()
[all …]
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
| H A D | medialibrary_formmap_operations.cpp | 246 …yFormMapOperations::CheckQueryIsInDb(const OperationObject &operationObject, const string &queryId) in CheckQueryIsInDb() argument
252 queryFormMapCmd.GetAbsRdbPredicates()->EqualTo(FormMap::FORMMAP_FORM_ID, queryId); in CheckQueryIsInDb()
255 queryFormMapCmd.GetAbsRdbPredicates()->EqualTo(MEDIA_DATA_DB_ID, queryId); in CheckQueryIsInDb()
|
| /ohos5.0/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_p2p/ |
| H A D | wifi_p2p_service_manager.cpp | 22 WifiP2pServiceManager::WifiP2pServiceManager() : transId(0), queryId(""), requestRecord(), in WifiP2pServiceManager()
39 queryId = setQueryId; in SetQueryId()
44 return queryId; in GetQueryId()
|
| H A D | wifi_p2p_service_manager.h | 232 std::string queryId; variable
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/include/ |
| H A D | medialibrary_formmap_operations.h | 47 …T static bool CheckQueryIsInDb(const OperationObject &operationObject, const std::string &queryId);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_single_ver_p2p_subscribe_sync_test.cpp | 227 std::string queryId = item.GetIdentify(); in CheckUnFinishedMap() local
228 …ASSERT_TRUE(std::find(deviceAQueies.begin(), deviceAQueies.end(), queryId) != deviceAQueies.end()); in CheckUnFinishedMap()
231 std::string queryId = item.GetIdentify(); in CheckUnFinishedMap() local
232 …ASSERT_TRUE(std::find(deviceBQueies.begin(), deviceBQueies.end(), queryId) != deviceBQueies.end()); in CheckUnFinishedMap()
697 std::string queryId = "queryId"; variable
698 EXPECT_EQ(subManager.IsLastRemoteContainSubscribe(DEVICE_A, queryId), false);
720 EXPECT_EQ(subManager.IsLastRemoteContainSubscribe(DEVICE_A, queryId), false);
|
| H A D | distributeddb_single_ver_p2p_query_sync_test.cpp | 1382 const std::string queryId = "Q1"; variable
1397 EXPECT_EQ(meta.SetRecvQueryWaterMark(queryId, deviceId, queryWaterMark), E_OK);
1398 EXPECT_EQ(meta.SetSendQueryWaterMark(queryId, deviceId, queryWaterMark), E_OK);
1421 EXPECT_EQ(anotherMeta.GetRecvQueryWaterMark(queryId, deviceId, waterMark), E_OK);
1423 EXPECT_EQ(anotherMeta.GetSendQueryWaterMark(queryId, deviceId, waterMark), E_OK);
1546 std::string queryId = std::to_string(i); in InitVerifyStorageEnvironment() local
1548 EXPECT_EQ(meta.SetRecvQueryWaterMark(queryId, deviceId, recvWaterMark), E_OK); in InitVerifyStorageEnvironment()
|