| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_task_context.cpp | 102 std::string queryId = operation->GetQueryId(); in AddSyncOperation()
111 … return (tmpOperation != nullptr && tmpOperation->GetQueryId() == queryId) && target->IsAutoSync(); in AddSyncOperation()
508 lastQuerySyncTaskStatusMap_[syncOperation_->GetQueryId()] = finalStatus; in SaveLastPushTaskExecStatus()
518 operation->GetQueryId(), deviceId_, in GetCorrectedSendWaterMarkForCurrentTask()
556 auto it = lastQuerySyncTaskStatusMap_.find(operation->GetQueryId()); in IsCurrentSyncTaskCanBeSkippedInner()
|
| H A D | single_ver_data_packet.h | 100 std::string GetQueryId() const;
|
| H A D | single_ver_data_packet.cpp | 285 std::string DataRequestPacket::GetQueryId() const in GetQueryId() function in DistributedDB::DataRequestPacket
|
| H A D | single_ver_data_sync.cpp | 998 STR_MASK(packet->GetQueryId()), label_.c_str(), STR_MASK(GetDeviceId())); in DataRequestRecv()
1029 … UpdateQueryPeerWaterMark(curType, packet->GetQueryId(), dataTime, context, isUpdateWaterMark); in DataRequestRecv()
1528 GetPeerWaterMark(syncType, packet->GetQueryId(), context->GetDeviceId(), peerMark); in WaterMarkErrHandle()
1591 GetLocalWaterMark(curType, packet->GetQueryId(), context, localMark); in SetAckPacket()
1598 GetPeerWaterMark(curType, packet->GetQueryId(), context->GetDeviceId(), mark); in SetAckPacket()
|
| H A D | single_ver_serialize_manager.cpp | 280 errCode = parcel.WriteString(packet->GetQueryId()); in DataPacketQuerySyncSerialization()
|
| /ohos5.0/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_p2p/ |
| H A D | wifi_p2p_service_manager.h | 61 virtual const std::string &GetQueryId() const;
|
| H A D | wifi_p2p_service_manager.cpp | 42 const std::string &WifiP2pServiceManager::GetQueryId() const in GetQueryId() function in OHOS::Wifi::WifiP2pServiceManager
|
| H A D | p2p_state_machine.cpp | 697 if (serviceManager.GetQueryId().empty()) { in CancelSupplicantSrvDiscReq()
701 …etCode = WifiP2PHalInterface::GetInstance().CancelReqServiceDiscovery(serviceManager.GetQueryId()); in CancelSupplicantSrvDiscReq()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/ |
| H A D | sync_operation.h | 126 std::string GetQueryId() const;
|
| H A D | sync_operation.cpp | 328 std::string SyncOperation::GetQueryId() const in GetQueryId() function in DistributedDB::SyncOperation
|
| /ohos5.0/foundation/communication/wifi/wifi/test/wifi_standard/wifi_framework/wifi_manage/wifi_p2p/test/ |
| H A D | wifi_p2p_service_manager_test.cpp | 53 EXPECT_EQ(pWifiP2pServiceManager->GetQueryId(), "queryId");
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_single_ver_p2p_query_sync_test.cpp | 674 EXPECT_EQ(outPacket->GetQueryId(), syncQuery.GetIdentify());
|