Home
last modified time | relevance | path

Searched refs:syncParam (Results 1 - 25 of 38) sorted by relevance

12

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/
H A Dsync_event.cpp24 SyncEvent::EventInfo::EventInfo(const SyncParam &syncParam, bool retry, std::shared_ptr<GenQuery> query, GenAsync async) in EventInfo() argument
25 : retry_(retry), mode_(syncParam.mode), wait_(syncParam.wait), query_(std::move(query)), in EventInfo()
26 asyncDetail_(std::move(async)), isCompensation_(syncParam.isCompensation), triggerMode_(syncParam.triggerMode), in EventInfo()
27 prepareTraceId_(syncParam.prepareTraceId), user_(syncParam.user) in EventInfo()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dkvdb_general_store_test.cpp325 SyncParam syncParam{}; in HWTEST_F()
326 syncParam.mode = mixMode; in HWTEST_F()
327 auto ret = store->Sync({}, query, [](const GenDetails &result) {}, syncParam); in HWTEST_F()
447 SyncParam syncParam{}; in HWTEST_F()
448 syncParam.mode = mixMode; in HWTEST_F()
451 auto ret = store->Sync({}, query, [](const GenDetails &result) {}, syncParam); in HWTEST_F()
456 ret = store->Sync({}, query, [](const GenDetails &result) {}, syncParam); in HWTEST_F()
461 syncParam.mode = mixMode; in HWTEST_F()
462 ret = store->Sync({}, query, [](const GenDetails &result) {}, syncParam); in HWTEST_F()
468 syncParam in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dsync_able_kvdb_connection.cpp148 ISyncer::SyncParma syncParam; in PragmaSyncAction() local
149 syncParam.devices = syncParameter->devices_; in PragmaSyncAction()
150 syncParam.mode = syncParameter->mode_; in PragmaSyncAction()
151 syncParam.wait = syncParameter->wait_; in PragmaSyncAction()
152 syncParam.isQuerySync = syncParameter->isQuerySync_; in PragmaSyncAction()
153 syncParam.syncQuery = syncParameter->query_; in PragmaSyncAction()
154 syncParam.onFinalize = [this]() { DecObjRef(this); }; in PragmaSyncAction()
156 syncParam.onComplete = [this, onComplete = syncParameter->onComplete_, wait = syncParameter->wait_]( in PragmaSyncAction()
163 syncParam.onSyncProcess = [this, onSyncProcess = syncParameter->onSyncProcess_]( in PragmaSyncAction()
170 int errCode = kvDB->Sync(syncParam, GetConnectionI in PragmaSyncAction()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_relational_store_connection.cpp247 ISyncer::SyncParma syncParam; in SyncToDevice() local
248 syncParam.devices = info.devices; in SyncToDevice()
249 syncParam.mode = info.mode; in SyncToDevice()
250 syncParam.wait = info.wait; in SyncToDevice()
251 syncParam.isQuerySync = true; in SyncToDevice()
252 syncParam.relationOnComplete = info.onComplete; in SyncToDevice()
253 syncParam.syncQuery = QuerySyncObject(info.query); in SyncToDevice()
254 syncParam.onFinalize = [this]() { in SyncToDevice()
257 if (syncParam.syncQuery.GetSortType() != SortType::NONE) { in SyncToDevice()
262 int errCode = store->Sync(syncParam, GetConnectionI in SyncToDevice()
[all...]
H A Dsqlite_relational_store.h49 int Sync(const ISyncer::SyncParma &syncParam, uint64_t connectionId);
/foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/include/
H A Dkvdb_service.h45 virtual Status SetSyncParam(const AppId &appId, const StoreId &storeId, const KvSyncParam &syncParam) = 0;
46 virtual Status GetSyncParam(const AppId &appId, const StoreId &storeId, KvSyncParam &syncParam) = 0;
H A Dsingle_store_impl.h76 Status SetSyncParam(const KvSyncParam &syncParam) override;
77 Status GetSyncParam(KvSyncParam &syncParam) override;
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dsingle_kvstore.h234 * @param syncParam Sync policy parameter.
237 virtual Status SetSyncParam(const KvSyncParam &syncParam) = 0;
241 * @param syncParam Sync policy parameter.
244 virtual Status GetSyncParam(KvSyncParam &syncParam) = 0;
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dkvdb_service_client.h42 Status SetSyncParam(const AppId &appId, const StoreId &storeId, const KvSyncParam &syncParam) override;
43 Status GetSyncParam(const AppId &appId, const StoreId &storeId, KvSyncParam &syncParam) override;
H A Dkvdb_service.h58 virtual Status SetSyncParam(const AppId &appId, const StoreId &storeId, const KvSyncParam &syncParam) = 0;
59 virtual Status GetSyncParam(const AppId &appId, const StoreId &storeId, KvSyncParam &syncParam) = 0;
H A Dsingle_store_impl.h92 Status SetSyncParam(const KvSyncParam &syncParam) override;
93 Status GetSyncParam(KvSyncParam &syncParam) override;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_syncer_test.h313 void SetResumeSyncParam(TaskId taskId, const SyncParam &syncParam) in SetResumeSyncParam() argument
315 resumeTaskInfos_[taskId].syncParam = syncParam; in SetResumeSyncParam()
316 resumeTaskInfos_[taskId].context.tableName = syncParam.tableName; in SetResumeSyncParam()
/foundation/ability/form_fwk/test/mock/include/
H A Dmock_single_kv_store.h108 DistributedKv::Status SetSyncParam(const DistributedKv::KvSyncParam &syncParam) override
113 DistributedKv::Status GetSyncParam(DistributedKv::KvSyncParam &syncParam) override
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/
H A Dsync_event.h27 API_EXPORT EventInfo(const SyncParam &syncParam, bool retry, std::shared_ptr<GenQuery> query, GenAsync async);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_service_impl.cpp442 Status KVDBServiceImpl::SetSyncParam(const AppId &appId, const StoreId &storeId, const KvSyncParam &syncParam) in SetSyncParam() argument
444 if (syncParam.allowedDelayMs > 0 && syncParam.allowedDelayMs < KvStoreSyncManager::SYNC_MIN_DELAY_MS) { in SetSyncParam()
447 if (syncParam.allowedDelayMs > KvStoreSyncManager::SYNC_MAX_DELAY_MS) { in SetSyncParam()
451 syncAgents_.Compute(tokenId, [&appId, &storeId, &syncParam](auto &key, SyncAgent &value) { in SetSyncParam()
455 value.delayTimes_[storeId] = syncParam.allowedDelayMs; in SetSyncParam()
461 Status KVDBServiceImpl::GetSyncParam(const AppId &appId, const StoreId &storeId, KvSyncParam &syncParam) in GetSyncParam() argument
463 syncParam.allowedDelayMs = 0; in GetSyncParam()
465 syncAgents_.ComputeIfPresent(tokenId, [&appId, &storeId, &syncParam](auto &key, SyncAgent &value) { in GetSyncParam()
474 syncParam in GetSyncParam()
[all...]
H A Dkvdb_service_stub.cpp276 KvSyncParam syncParam; in OnSetSyncParam() local
277 if (!ITypesUtil::Unmarshal(data, syncParam.allowedDelayMs)) { in OnSetSyncParam()
282 int32_t status = SetSyncParam(appId, storeId, syncParam); in OnSetSyncParam()
294 KvSyncParam syncParam; in OnGetSyncParam() local
295 int32_t status = GetSyncParam(appId, storeId, syncParam); in OnGetSyncParam()
296 if (!ITypesUtil::Marshal(reply, status, syncParam.allowedDelayMs)) { in OnGetSyncParam()
H A Dkvdb_service_impl.h54 Status SetSyncParam(const AppId &appId, const StoreId &storeId, const KvSyncParam &syncParam) override;
55 Status GetSyncParam(const AppId &appId, const StoreId &storeId, KvSyncParam &syncParam) override;
H A Dkvdb_general_store.cpp378 int32_t KVDBGeneralStore::Sync(const Devices &devices, GenQuery &query, DetailAsync async, SyncParam &syncParam) in Sync() argument
380 auto syncMode = GeneralStore::GetSyncMode(syncParam.mode); in Sync()
384 devices.empty() ? "null" : Anonymous::Change(*devices.begin()).c_str(), syncParam.mode); in Sync()
393 dbStatus = CloudSync(devices, dbMode, async, syncParam.wait, syncParam.prepareTraceId); in Sync()
396 ZLOGE("Devices is empty! mode:%{public}d", syncParam.mode); in Sync()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dgeneric_syncer.cpp164 SyncParma syncParam; in Sync() local
165 syncParam.devices = param.devices; in Sync()
166 syncParam.mode = param.mode; in Sync()
167 syncParam.isQuerySync = param.isQuerySync; in Sync()
168 syncParam.syncQuery = param.syncQuery; in Sync()
169 return Sync(syncParam); in Sync()
470 [this](const InternalSyncParma &syncParam) { QueryAutoSync(syncParam); }; in InitSyncEngine()
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dkvdb_service_client.cpp226 Status KVDBServiceClient::SetSyncParam(const AppId &appId, const StoreId &storeId, const KvSyncParam &syncParam) in SetSyncParam() argument
230 appId, storeId, syncParam.allowedDelayMs); in SetSyncParam()
238 Status KVDBServiceClient::GetSyncParam(const AppId &appId, const StoreId &storeId, KvSyncParam &syncParam) in GetSyncParam() argument
248 ITypesUtil::Unmarshal(reply, syncParam.allowedDelayMs); in GetSyncParam()
/foundation/ability/ability_runtime/test/mock/common/include/
H A Dmock_single_kv_store.h105 DistributedKv::Status SetSyncParam(const DistributedKv::KvSyncParam &syncParam) override
110 DistributedKv::Status GetSyncParam(DistributedKv::KvSyncParam &syncParam) override
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_general_store.cpp504 int32_t RdbGeneralStore::Sync(const Devices &devices, GenQuery &query, DetailAsync async, SyncParam &syncParam) in Sync() argument
516 auto syncMode = GeneralStore::GetSyncMode(syncParam.mode); in Sync()
522 devices.empty() ? "null" : Anonymous::Change(*devices.begin()).c_str(), syncParam.mode, syncParam.wait); in Sync()
525 auto highMode = GetHighMode(static_cast<uint32_t>(syncParam.mode)); in Sync()
529 dbStatus = delegate_->Sync(devices, dbMode, dbQuery, GetDBBriefCB(std::move(async)), syncParam.wait != 0); in Sync()
536 dbStatus = delegate_->Sync({ devices, dbMode, dbQuery, syncParam.wait, in Sync()
537 (isPriority || highMode == MANUAL_SYNC_MODE), syncParam.isCompensation, {}, in Sync()
538 highMode == AUTO_SYNC_MODE, LOCK_ACTION, syncParam.prepareTraceId }, in Sync()
H A Drdb_service_impl.cpp441 SyncParam syncParam = { option.mode, 0, option.isCompensation };
445 auto complete = [this, rdbQuery, store, pid, syncParam, tokenId, async, seq = option.seqNum](
453 syncParam);
464 syncParam);
558 SyncParam syncParam = { mixMode, (option.isAsync ? 0 : WAIT_TIME), option.isCompensation };
559 auto info = ChangeEvent::EventInfo(syncParam, option.isAutoSync, query,
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/
H A Dsync_manager.cpp320 SyncParam syncParam = { info.mode_, info.wait_, info.isCompensation_, info.triggerMode_, in GetPostEventTask() local
323 SyncEvent::EventInfo{ syncParam, retry, std::move(query), info.async_ }); in GetPostEventTask()
409 SyncParam syncParam = { evt.GetMode(), evt.GetWait(), evt.IsCompensation(), MODE_DEFAULT, prepareTraceId };
413 syncParam);
/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/
H A Djs_single_kv_store.cpp421 KvSyncParam syncParam { ctxt->allowedDelayMs }; in SetSyncParam()
422 Status status = kvStore->SetSyncParam(syncParam); in SetSyncParam()

Completed in 20 milliseconds

12