| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | kv_virtual_device.cpp | 44 …VirtualSingleVerSyncDBInterface *syncInterface = static_cast<VirtualSingleVerSyncDBInterface *>(st… in SetSaveDataDelayTime() local
50 …VirtualSingleVerSyncDBInterface *syncInterface = static_cast<VirtualSingleVerSyncDBInterface *>(st… in DelayGetSyncData() local
56 …VirtualSingleVerSyncDBInterface *syncInterface = static_cast<VirtualSingleVerSyncDBInterface *>(st… in SetGetDataErrCode() local
62 …VirtualSingleVerSyncDBInterface *syncInterface = static_cast<VirtualSingleVerSyncDBInterface *>(st… in ResetDataControl() local
69 …VirtualMultiVerSyncDBInterface *syncInterface = static_cast<VirtualMultiVerSyncDBInterface *>(stor… in GetData() local
75 …VirtualMultiVerSyncDBInterface *syncInterface = static_cast<VirtualMultiVerSyncDBInterface *>(stor… in PutData() local
81 …VirtualMultiVerSyncDBInterface *syncInterface = static_cast<VirtualMultiVerSyncDBInterface *>(stor… in DeleteData() local
87 …VirtualMultiVerSyncDBInterface *syncInterface = static_cast<VirtualMultiVerSyncDBInterface *>(stor… in StartTransaction() local
93 …VirtualMultiVerSyncDBInterface *syncInterface = static_cast<VirtualMultiVerSyncDBInterface *>(stor… in Commit() local
|
| H A D | mock_single_ver_kv_syncer.h | 29 void CallTriggerAddSubscribeAsync(ISyncInterface *syncInterface) in CallTriggerAddSubscribeAsync()
|
| H A D | generic_virtual_device.cpp | 76 …tualDevice::Initialize(VirtualCommunicatorAggregator *comAggregator, ISyncInterface *syncInterface) in Initialize()
|
| H A D | distributeddb_multi_ver_p2p_sync_test.cpp | 433 … VirtualMultiVerSyncDBInterface *syncInterface = new (std::nothrow) VirtualMultiVerSyncDBInterface; variable
|
| H A D | distributeddb_mock_sync_module_test.cpp | 57 void Initialize(ISyncInterface *syncInterface) in Initialize()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_engine.cpp | 24 ISyncTaskContext *SingleVerSyncEngine::CreateSyncTaskContext(const ISyncInterface &syncInterface) in CreateSyncTaskContext()
63 int SingleVerSyncEngine::StartAutoSubscribeTimer(const ISyncInterface &syncInterface) in StartAutoSubscribeTimer()
|
| H A D | single_ver_kv_syncer.cpp | 250 ISyncInterface *syncInterface = nullptr; in TriggerSubQuerySync() local
298 int SingleVerKVSyncer::InitSyncEngine(DistributedDB::ISyncInterface *syncInterface) in InitSyncEngine()
308 void SingleVerKVSyncer::TriggerAddSubscribeAsync(ISyncInterface *syncInterface) in TriggerAddSubscribeAsync()
|
| H A D | single_ver_relational_syncer.cpp | 22 int SingleVerRelationalSyncer::Initialize(ISyncInterface *syncInterface, bool isNeedActive) in Initialize()
43 const auto &syncInterface = static_cast<RelationalDBSyncInterface *>(syncInterface_); in PrepareSync() local
|
| H A D | single_ver_sync_task_context.cpp | 42 int SingleVerSyncTaskContext::Initialize(const std::string &deviceId, ISyncInterface *syncInterface, in Initialize()
|
| H A D | single_ver_sync_state_machine.cpp | 119 int SingleVerSyncStateMachine::Initialize(ISyncTaskContext *context, ISyncInterface *syncInterface, in Initialize()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_syncer.cpp | 110 …MultiVerKvDBSyncInterface *syncInterface = static_cast<MultiVerKvDBSyncInterface *>(syncInterface_… in AddSyncOperation() local
119 …MultiVerKvDBSyncInterface *syncInterface = static_cast<MultiVerKvDBSyncInterface *>(syncInterface_… in SyncOperationKillCallbackInner() local
|
| H A D | multi_ver_sync_task_context.cpp | 31 int MultiVerSyncTaskContext::Initialize(const std::string &deviceId, ISyncInterface *syncInterface, in Initialize()
|
| H A D | multi_ver_sync_state_machine.cpp | 61 int MultiVerSyncStateMachine::Initialize(ISyncTaskContext *context, ISyncInterface *syncInterface, in Initialize()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | sync_able_kvdb.cpp | 125 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in SetSyncModuleActive() local
171 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in StartSyncerWithNoLock() local
254 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in UserChangeHandle() local
291 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in ChangeUserListener() local
431 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in SetSyncRetry() local
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | generic_syncer.cpp | 80 int GenericSyncer::Initialize(ISyncInterface *syncInterface, bool isNeedActive) in Initialize()
318 ISyncInterface *syncInterface = nullptr; in QueryAutoSync() local
378 int GenericSyncer::InitMetaData(ISyncInterface *syncInterface) in InitMetaData()
398 int GenericSyncer::InitTimeHelper(ISyncInterface *syncInterface) in InitTimeHelper()
416 int GenericSyncer::InitSyncEngine(ISyncInterface *syncInterface) in InitSyncEngine()
448 int GenericSyncer::CheckSyncActive(ISyncInterface *syncInterface, bool isNeedActive) in CheckSyncActive()
1091 bool GenericSyncer::IsNeedActive(ISyncInterface *syncInterface) in IsNeedActive()
1108 int GenericSyncer::InitStorageResource(ISyncInterface *syncInterface) in InitStorageResource()
|
| H A D | sync_engine.cpp | 69 int SyncEngine::Initialize(ISyncInterface *syncInterface, const std::shared_ptr<Metadata> &metadata, in Initialize()
233 const std::function<void(std::string)> &offlineChanged, ISyncInterface *syncInterface) in InitInnerSource()
275 int SyncEngine::InitComunicator(const ISyncInterface *syncInterface) in InitComunicator()
1283 ISyncInterface *syncInterface = nullptr; in ClearSyncInterface() local
1305 void SyncEngine::SetSyncInterface(ISyncInterface *syncInterface) in SetSyncInterface()
|
| H A D | remote_executor.cpp | 54 int RemoteExecutor::Initialize(ISyncInterface *syncInterface, ICommunicator *communicator) in Initialize()
250 auto *syncInterface = GetAndIncSyncInterface(); in SendRemoteExecutorData() local
510 auto syncInterface = GetAndIncSyncInterface(); in SendRequestMessage() local
846 ISyncInterface *syncInterface = syncInterface_; in GetAndIncSyncInterface() local
|
| H A D | syncer_proxy.cpp | 28 int SyncerProxy::Initialize(ISyncInterface *syncInterface, bool isNeedActive) in Initialize()
|
| H A D | sync_state_machine.cpp | 53 int SyncStateMachine::Initialize(ISyncTaskContext *context, ISyncInterface *syncInterface, in Initialize()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_get_data_test.cpp | 1650 auto syncInterface = store->GetStorageEngine(); variable
1713 auto syncInterface = store->GetStorageEngine(); variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_nb_delegate_test.cpp | 2248 VirtualSingleVerSyncDBInterface *&syncInterface) in InitVirtualDevice()
|