| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_sync_extend.cpp | 58 errCode = subManager->ActiveLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlCmdAckRecv()
60 subManager->RemoveLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlCmdAckRecv()
77 context->GetQuery().HasInKeys() && in ControlCmdStartCheck()
180 QuerySyncObject syncQuery = packet->GetQuery(); in SubscribeRequestRecvPre()
222 errCode = storage_->AddSubscribe(packet->GetQuery().GetIdentify(), packet->GetQuery(), packet->IsAutoSubscribe()); in SubscribeRequestRecv()
229 errCode = subscribeManager->ReserveRemoteSubscribeQuery(context->GetDeviceId(), packet->GetQuery()); in SubscribeRequestRecv()
233 RemoveSubscribeIfNeed(packet->GetQuery().GetIdentify(), subscribeManager); in SubscribeRequestRecv()
239 subscribeManager->DeleteRemoteSubscribeQuery(context->GetDeviceId(), packet->GetQuery()); in SubscribeRequestRecv()
240 RemoveSubscribeIfNeed(packet->GetQuery() in SubscribeRequestRecv()
[all...] |
| H A D | single_ver_sync_target.cpp | 38 operation->GetQuery(query_); in SetSyncOperation()
68 QuerySyncObject SingleVerSyncTarget::GetQuery() const in GetQuery() function in DistributedDB::SingleVerSyncTarget
|
| H A D | single_ver_sync_target.h | 45 QuerySyncObject GetQuery() const;
|
| H A D | single_ver_data_sync_utils.cpp | 68 if (version < SOFTWARE_VERSION_RELEASE_5_0 && !(context->GetQuery().IsQueryOnlyByKey())) { in QuerySyncCheck()
73 if (context->GetQuery().HasInKeys() && context->IsNotSupportAbility(SyncConfig::INKEYS_QUERY)) { in QuerySyncCheck()
101 QuerySyncObject syncQuery = packet->GetQuery(); in RequestQueryCheck()
320 packet->SetQuery(context->GetQuery()); in FillControlRequestPacket()
361 query = subPacket->GetQuery(); in IsNeedTriggerQueryAutoSync()
373 subManager->DeleteLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlAckErrorHandle()
602 QuerySyncObject queryObj = context->GetQuery(); in GetUnsyncTotal()
|
| H A D | single_ver_data_sync.cpp | 380 QuerySyncObject queryObj = context->GetQuery(); in GetUnsyncData()
605 GetLocalWaterMark(curType, context->GetQuery().GetIdentify(), context, localMark); in DealRemoveDeviceDataByAck()
694 packet->SetQuery(context->GetQuery()); in FillDataRequestPacket()
703 if (curType == SyncType::QUERY_SYNC_TYPE && (context->GetQuery().HasLimit() || in FillDataRequestPacket()
704 context->GetQuery().HasOrderBy())) { in FillDataRequestPacket()
709 STR_MASK(GetDeviceId()), STR_MASK(context->GetQuery().GetIdentify()), packet->IsCompressData()); in FillDataRequestPacket()
755 if (curType == SyncType::QUERY_SYNC_TYPE && (context->GetQuery().HasLimit() || in RequestStart()
756 context->GetQuery().HasOrderBy())) { in RequestStart()
820 packet->SetQuery(context->GetQuery()); in PullRequestStart()
865 if (curType == SyncType::QUERY_SYNC_TYPE && (context->GetQuery() in PullResponseStart()
[all...] |
| H A D | single_ver_data_packet.h | 99 QuerySyncObject GetQuery() const;
221 QuerySyncObject GetQuery() const;
|
| H A D | single_ver_sync_task_context.h | 117 QuerySyncObject GetQuery() const;
|
| H A D | single_ver_data_packet.cpp | 279 QuerySyncObject DataRequestPacket::GetQuery() const in GetQuery() function in DistributedDB::DataRequestPacket
496 QuerySyncObject SubscribeRequest::GetQuery() const in GetQuery() function in DistributedDB::SubscribeRequest
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/ |
| H A D | cloud_share_event.cpp | 24 std::shared_ptr<GenQuery> CloudShareEvent::GetQuery() const in GetQuery() function in OHOS::DistributedData::CloudShareEvent
|
| H A D | sync_event.cpp | 78 std::shared_ptr<GenQuery> SyncEvent::GetQuery() const in GetQuery() function in OHOS::DistributedData::SyncEvent
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_continue_token.cpp | 109 QueryObject SQLiteSingleVerContinueToken::GetQuery() const in GetQuery() function in DistributedDB::SQLiteSingleVerContinueToken
153 SqliteQueryHelper helper = GetQuery().GetQueryHelper(errCode); in GetCloudQueryStmt()
|
| H A D | sqlite_single_ver_continue_token.h | 62 QueryObject GetQuery() const;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
| H A D | cloud_share_event.h | 28 std::shared_ptr<GenQuery> GetQuery() const;
|
| H A D | sync_event.h | 50 std::shared_ptr<GenQuery> GetQuery() const;
|
| /foundation/graphic/graphic_2d/interfaces/kits/napi/graphic/webgl/include/webgl/ |
| H A D | webgl_query.h | 46 unsigned int GetQuery() const in GetQuery() function in OHOS::Rosen::final
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_continue_token.h | 39 const QueryObject &GetQuery() const;
|
| H A D | sqlite_single_ver_relational_continue_token.cpp | 139 const QueryObject &SQLiteSingleVerRelationalContinueToken::GetQuery() const in GetQuery() function in DistributedDB::SQLiteSingleVerRelationalContinueToken
|
| /foundation/filemanagement/app_file_service/interfaces/kits/js/file_uri/ |
| H A D | file_uri_n_exporter.cpp | 179 if (!uri.GetQuery().empty()) { in Split()
180 normalizeUri += "?" + uri.GetQuery(); in Split()
430 napi_value FileUriNExporter::GetQuery(napi_env env, napi_callback_info info) in GetQuery() function in OHOS::AppFileService::ModuleFileUri::FileUriNExporter
445 return NVal::CreateUTF8String(env, fileuriEntity->fileUri_.uri_.GetQuery()).val_; in GetQuery()
484 NVal::DeclareNapiGetter("query", GetQuery), in Export()
|
| H A D | file_uri_n_exporter.h | 46 static napi_value GetQuery(napi_env env, napi_callback_info info);
|
| /foundation/ability/ability_base/interfaces/kits/native/uri/include/ |
| H A D | uri.h | 76 std::string GetQuery();
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/ |
| H A D | sync_operation.h | 124 void GetQuery(QuerySyncObject &targetObject) const;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_query.h | 39 DistributedDB::Query GetQuery() const;
|
| /foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/ |
| H A D | datashare_helper.cpp | 89 if (uri.GetQuery().find("Proxy=true") != std::string::npos) { in Creator()
374 return (uri.GetQuery().find("Proxy=true") != std::string::npos || uri.GetScheme() == "datashareproxy"); in IsProxy()
|
| /foundation/ability/ability_runtime/services/dataobsmgr/src/ |
| H A D | dataobs_mgr_inner_pref.cpp | 114 obs->OnChangePreferences(const_cast<Uri &>(uri).GetQuery()); in HandleNotifyChange()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | cloud_test.cpp | 73 EXPECT_EQ(evt.GetQuery(), query); in HWTEST_F()
|