Home
last modified time | relevance | path

Searched refs:syncInterface (Results 1 – 25 of 39) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dkv_virtual_device.cpp45 syncInterface->SetSaveDataDelayTime(milliDelayTime); in SetSaveDataDelayTime()
51 syncInterface->DelayGetSyncData(milliDelayTime); in DelayGetSyncData()
57 syncInterface->SetGetDataErrCode(whichTime, errCode, isGetDataControl); in SetGetDataErrCode()
63 syncInterface->ResetDataControl(); in ResetDataControl()
69 …VirtualMultiVerSyncDBInterface *syncInterface = static_cast<VirtualMultiVerSyncDBInterface *>(stor… in GetData() local
70 return syncInterface->GetData(key, value); in GetData()
75 …VirtualMultiVerSyncDBInterface *syncInterface = static_cast<VirtualMultiVerSyncDBInterface *>(stor… in PutData() local
76 return syncInterface->PutData(key, value); in PutData()
82 return syncInterface->DeleteData(key); in DeleteData()
88 return syncInterface->StartTransaction(); in StartTransaction()
[all …]
H A Dmock_single_ver_kv_syncer.h29 void CallTriggerAddSubscribeAsync(ISyncInterface *syncInterface) in CallTriggerAddSubscribeAsync() argument
31 SingleVerKVSyncer::TriggerAddSubscribeAsync(syncInterface); in CallTriggerAddSubscribeAsync()
H A Dgeneric_virtual_device.cpp76 …tualDevice::Initialize(VirtualCommunicatorAggregator *comAggregator, ISyncInterface *syncInterface) in Initialize() argument
78 if ((comAggregator == nullptr) || (syncInterface == nullptr)) { in Initialize()
89 storage_ = syncInterface; in Initialize()
121 executor_->Initialize(syncInterface, communicateHandle_); in Initialize()
H A Dmock_sync_engine.h25 MOCK_METHOD1(CreateSyncTaskContext, ISyncTaskContext *(const ISyncInterface &syncInterface));
H A Dgeneric_virtual_device.h34 int Initialize(VirtualCommunicatorAggregator *comAggregator, ISyncInterface *syncInterface);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_kv_syncer.cpp250 ISyncInterface *syncInterface = nullptr; in TriggerSubQuerySync() local
257 syncInterface = syncInterface_; in TriggerSubQuerySync()
258 syncInterface->IncRefCount(); in TriggerSubQuerySync()
288 syncInterface->DecRefCount(); in TriggerSubQuerySync()
300 int errCode = GenericSyncer::InitSyncEngine(syncInterface); in InitSyncEngine()
304 TriggerAddSubscribeAsync(syncInterface); in InitSyncEngine()
308 void SingleVerKVSyncer::TriggerAddSubscribeAsync(ISyncInterface *syncInterface) in TriggerAddSubscribeAsync() argument
310 if (syncInterface == nullptr || syncEngine_ == nullptr) { in TriggerAddSubscribeAsync()
313 if (syncInterface->GetInterfaceType() != ISyncInterface::SYNC_SVD) { in TriggerAddSubscribeAsync()
317 auto storage = static_cast<SyncGenericInterface *>(syncInterface); in TriggerAddSubscribeAsync()
[all …]
H A Dsingle_ver_sync_engine.cpp24 ISyncTaskContext *SingleVerSyncEngine::CreateSyncTaskContext(const ISyncInterface &syncInterface) in CreateSyncTaskContext() argument
27 switch (syncInterface.GetInterfaceType()) { in CreateSyncTaskContext()
63 int SingleVerSyncEngine::StartAutoSubscribeTimer(const ISyncInterface &syncInterface) in StartAutoSubscribeTimer() argument
65 if (syncInterface.IsSupportSubscribe() == -E_NOT_SUPPORT) { in StartAutoSubscribeTimer()
H A Dsingle_ver_relational_syncer.cpp22 int SingleVerRelationalSyncer::Initialize(ISyncInterface *syncInterface, bool isNeedActive) in Initialize() argument
24 int errCode = SingleVerSyncer::Initialize(syncInterface, isNeedActive); in Initialize()
29 return static_cast<RelationalDBSyncInterface *>(syncInterface)-> in Initialize()
43 const auto &syncInterface = static_cast<RelationalDBSyncInterface *>(syncInterface_); in PrepareSync() local
48 tablesQuery = syncInterface->GetTablesQuery(); in PrepareSync()
H A Dsingle_ver_sync_engine.h30 int StartAutoSubscribeTimer(const ISyncInterface &syncInterface) override;
42 ISyncTaskContext *CreateSyncTaskContext(const ISyncInterface &syncInterface) override;
H A Dsingle_ver_kv_syncer.h44 int InitSyncEngine(ISyncInterface *syncInterface) override;
46 void TriggerAddSubscribeAsync(ISyncInterface *syncInterface);
H A Dsingle_ver_sync_task_context.cpp42 int SingleVerSyncTaskContext::Initialize(const std::string &deviceId, ISyncInterface *syncInterface, in Initialize() argument
45 if (deviceId.empty() || syncInterface == nullptr || metadata == nullptr || in Initialize()
54 std::vector<uint8_t> dbIdentifier = syncInterface->GetIdentifier(); in Initialize()
59 int errCode = stateMachine_->Initialize(this, syncInterface, metadata, communicator); in Initialize()
66 errCode = timeHelper_->Initialize(syncInterface, metadata); in Initialize()
76 syncInterface_ = syncInterface; in Initialize()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dsync_able_kvdb.cpp125 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in SetSyncModuleActive() local
126 if (syncInterface == nullptr) { in SetSyncModuleActive()
171 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in StartSyncerWithNoLock() local
172 if (syncInterface == nullptr) { in StartSyncerWithNoLock()
180 int errCode = syncer_.Initialize(syncInterface, isNeedActive); in StartSyncerWithNoLock()
254 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in UserChangeHandle() local
255 if (syncInterface == nullptr) { in UserChangeHandle()
259 bool isSyncDualTupleMode = syncInterface->GetDbProperties(). in UserChangeHandle()
291 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in ChangeUserListener() local
431 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in SetSyncRetry() local
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dgeneric_syncer.cpp82 if (syncInterface == nullptr) { in Initialize()
124 errCode = InitSyncEngine(syncInterface); in Initialize()
318 ISyncInterface *syncInterface = nullptr; in QueryAutoSync() local
326 syncInterface = syncInterface_; in QueryAutoSync()
328 syncInterface->IncRefCount(); in QueryAutoSync()
337 syncInterface->DecRefCount(); in QueryAutoSync()
342 syncInterface->DecRefCount(); in QueryAutoSync()
394 syncInterface_ = syncInterface; in InitMetaData()
437 syncInterface->IncRefCount(); in InitSyncEngine()
1119 errCode = InitTimeHelper(syncInterface); in InitStorageResource()
[all …]
H A Dgeneric_syncer.h38 int Initialize(ISyncInterface *syncInterface, bool isNeedActive) override;
140 int InitMetaData(ISyncInterface *syncInterface);
143 int InitTimeHelper(ISyncInterface *syncInterface);
146 virtual int InitSyncEngine(ISyncInterface *syncInterface);
148 int CheckSyncActive(ISyncInterface *syncInterface, bool isNeedActive);
201 int InitStorageResource(ISyncInterface *syncInterface);
209 static bool IsNeedActive(ISyncInterface *syncInterface);
H A Dsync_engine.h39 int Initialize(ISyncInterface *syncInterface, const std::shared_ptr<Metadata> &metadata,
101 int StartAutoSubscribeTimer(const ISyncInterface &syncInterface) override;
131 virtual ISyncTaskContext *CreateSyncTaskContext(const ISyncInterface &syncInterface) = 0;
141 void SetSyncInterface(ISyncInterface *syncInterface);
157 const std::function<void(std::string)> &offlineChanged, ISyncInterface *syncInterface);
160 int InitComunicator(const ISyncInterface *syncInterface);
H A Dremote_executor.cpp61 syncInterface_ = syncInterface; in Initialize()
250 auto *syncInterface = GetAndIncSyncInterface(); in SendRemoteExecutorData() local
251 if (syncInterface == nullptr) { in SendRemoteExecutorData()
257 syncInterface->DecRefCount(); in SendRemoteExecutorData()
510 auto syncInterface = GetAndIncSyncInterface(); in SendRequestMessage() local
513 if (syncInterface != nullptr) { in SendRequestMessage()
514 syncInterface->DecRefCount(); in SendRequestMessage()
534 syncInterface->DecRefCount(); in SendRequestMessage()
847 if (syncInterface != nullptr) { in GetAndIncSyncInterface()
848 syncInterface->IncRefCount(); in GetAndIncSyncInterface()
[all …]
H A Dsync_engine.cpp72 if ((syncInterface == nullptr) || (metadata == nullptr)) { in Initialize()
75 int errCode = StartAutoSubscribeTimer(*syncInterface); in Initialize()
80 errCode = InitComunicator(syncInterface); in Initialize()
97 SetSyncInterface(syncInterface); in Initialize()
275 int SyncEngine::InitComunicator(const ISyncInterface *syncInterface) in InitComunicator() argument
283 std::vector<uint8_t> label = syncInterface->GetIdentifier(); in InitComunicator()
1283 ISyncInterface *syncInterface = nullptr; in ClearSyncInterface() local
1289 syncInterface = syncInterface_; in ClearSyncInterface()
1292 syncInterface->DecRefCount(); in ClearSyncInterface()
1305 void SyncEngine::SetSyncInterface(ISyncInterface *syncInterface) in SetSyncInterface() argument
[all …]
H A Dsyncer_proxy.cpp28 int SyncerProxy::Initialize(ISyncInterface *syncInterface, bool isNeedActive) in Initialize() argument
30 if (syncInterface == nullptr) { in Initialize()
34 int interfaceType = syncInterface->GetInterfaceType(); in Initialize()
46 return syncer_->Initialize(syncInterface, isNeedActive); in Initialize()
H A Disync_engine.h36 virtual int Initialize(ISyncInterface *syncInterface, const std::shared_ptr<Metadata> &metadata,
75 virtual int StartAutoSubscribeTimer(const ISyncInterface &syncInterface) = 0;
H A Disync_state_machine.h33 virtual int Initialize(ISyncTaskContext *context, ISyncInterface *syncInterface,
H A Dsync_state_machine.cpp53 int SyncStateMachine::Initialize(ISyncTaskContext *context, ISyncInterface *syncInterface, in Initialize() argument
56 …if ((context == nullptr) || (syncInterface == nullptr) || (metadata == nullptr) || (communicator =… in Initialize()
60 storageInterface_ = syncInterface; in Initialize()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_syncer.cpp110 …MultiVerKvDBSyncInterface *syncInterface = static_cast<MultiVerKvDBSyncInterface *>(syncInterface_… in AddSyncOperation() local
111 syncInterface->NotifyStartSyncOperation(); in AddSyncOperation()
119 …MultiVerKvDBSyncInterface *syncInterface = static_cast<MultiVerKvDBSyncInterface *>(syncInterface_… in SyncOperationKillCallbackInner() local
120 syncInterface->NotifyFinishSyncOperation(); in SyncOperationKillCallbackInner()
H A Dmulti_ver_sync_task_context.cpp31 int MultiVerSyncTaskContext::Initialize(const std::string &deviceId, ISyncInterface *syncInterface, in Initialize() argument
34 if (deviceId.empty() || (syncInterface == nullptr) || (communicator == nullptr)) { in Initialize()
37 syncInterface_ = syncInterface; in Initialize()
43 int errCode = timeHelper_->Initialize(syncInterface, metadata); in Initialize()
54 errCode = stateMachine_->Initialize(this, syncInterface, metadata, communicator); in Initialize()
H A Dmulti_ver_sync_state_machine.cpp61 int MultiVerSyncStateMachine::Initialize(ISyncTaskContext *context, ISyncInterface *syncInterface, in Initialize() argument
64 …if (context == nullptr || syncInterface == nullptr || metadata == nullptr || communicator == nullp… in Initialize()
67 int errCode = SyncStateMachine::Initialize(context, syncInterface, metadata, communicator); in Initialize()
77 errCode = timeSync_->Initialize(communicator, metadata, syncInterface, context->GetDeviceId()); in Initialize()
85 multiVerStorage_ = static_cast<MultiVerKvDBSyncInterface *>(syncInterface); in Initialize()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_get_data_test.cpp1650 auto syncInterface = store->GetStorageEngine(); variable
1651 ASSERT_NE(syncInterface, nullptr);
1652 RefObject::IncObjRef(syncInterface);
1667 syncInterface->GetMaxTimestamp(maxTimestamp);
1668 RefObject::DecObjRef(syncInterface);
1713 auto syncInterface = store->GetStorageEngine(); variable
1714 ASSERT_NE(syncInterface, nullptr);
1722 …EXPECT_EQ(syncInterface->GetSyncData(query, SyncTimeRange {}, sizeInfo, token, entries), -E_UNFINI…
1724 syncInterface->ReleaseContinueToken(token);
1725 RefObject::IncObjRef(syncInterface);
[all …]

12