| /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() argument
63 int SingleVerSyncEngine::StartAutoSubscribeTimer(const ISyncInterface &syncInterface) in StartAutoSubscribeTimer() argument
|
| H A D | single_ver_kv_syncer.cpp | 250 ISyncInterface *syncInterface = nullptr; in TriggerSubQuerySync() local
298 int SingleVerKVSyncer::InitSyncEngine(DistributedDB::ISyncInterface *syncInterface) in InitSyncEngine() argument
308 void SingleVerKVSyncer::TriggerAddSubscribeAsync(ISyncInterface *syncInterface) in TriggerAddSubscribeAsync() argument
[all...] |
| H A D | single_ver_relational_syncer.cpp | 22 int SingleVerRelationalSyncer::Initialize(ISyncInterface *syncInterface, bool isNeedActive) in Initialize() argument
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() argument
|
| H A D | single_ver_sync_state_machine.cpp | 119 int SingleVerSyncStateMachine::Initialize(ISyncTaskContext *context, ISyncInterface *syncInterface, in Initialize() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | mock_single_ver_kv_syncer.h | 29 void CallTriggerAddSubscribeAsync(ISyncInterface *syncInterface)
in CallTriggerAddSubscribeAsync() argument
|
| H A D | kv_virtual_device.cpp | 44 VirtualSingleVerSyncDBInterface *syncInterface = static_cast<VirtualSingleVerSyncDBInterface *>(storage_); in SetSaveDataDelayTime() local
50 VirtualSingleVerSyncDBInterface *syncInterface = static_cast<VirtualSingleVerSyncDBInterface *>(storage_); in DelayGetSyncData() local
56 VirtualSingleVerSyncDBInterface *syncInterface = static_cast<VirtualSingleVerSyncDBInterface *>(storage_); in SetGetDataErrCode() local
62 VirtualSingleVerSyncDBInterface *syncInterface = static_cast<VirtualSingleVerSyncDBInterface *>(storage_); in ResetDataControl() local
69 VirtualMultiVerSyncDBInterface *syncInterface = static_cast<VirtualMultiVerSyncDBInterface *>(storage_); in GetData() local
75 VirtualMultiVerSyncDBInterface *syncInterface = static_cast<VirtualMultiVerSyncDBInterface *>(storage_); PutData() local
81 VirtualMultiVerSyncDBInterface *syncInterface = static_cast<VirtualMultiVerSyncDBInterface *>(storage_); DeleteData() local
87 VirtualMultiVerSyncDBInterface *syncInterface = static_cast<VirtualMultiVerSyncDBInterface *>(storage_); StartTransaction() local
93 VirtualMultiVerSyncDBInterface *syncInterface = static_cast<VirtualMultiVerSyncDBInterface *>(storage_); Commit() local
[all...] |
| H A D | generic_virtual_device.cpp | 76 int GenericVirtualDevice::Initialize(VirtualCommunicatorAggregator *comAggregator, ISyncInterface *syncInterface) in Initialize() argument
|
| H A D | distributeddb_mock_sync_module_test.cpp | 57 void Initialize(ISyncInterface *syncInterface) in Initialize() argument
|
| H A D | distributeddb_multi_ver_p2p_sync_test.cpp | 433 VirtualMultiVerSyncDBInterface *syncInterface = new (std::nothrow) VirtualMultiVerSyncDBInterface; in HWTEST_F() local
|
| /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_state_machine.cpp | 61 int MultiVerSyncStateMachine::Initialize(ISyncTaskContext *context, ISyncInterface *syncInterface, in Initialize() argument
|
| H A D | multi_ver_sync_task_context.cpp | 31 int MultiVerSyncTaskContext::Initialize(const std::string &deviceId, ISyncInterface *syncInterface, in Initialize() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | syncer_proxy.cpp | 28 int SyncerProxy::Initialize(ISyncInterface *syncInterface, bool isNeedActive) in Initialize() argument
|
| H A D | sync_state_machine.cpp | 53 int SyncStateMachine::Initialize(ISyncTaskContext *context, ISyncInterface *syncInterface, in Initialize() argument
|
| H A D | remote_executor.cpp | 54 int RemoteExecutor::Initialize(ISyncInterface *syncInterface, ICommunicator *communicator) in Initialize() argument
250 auto *syncInterface = GetAndIncSyncInterface(); in SendRemoteExecutorData() local
510 auto syncInterface = GetAndIncSyncInterface(); in SendRequestMessage() local
845 ISyncInterface *syncInterface = syncInterface_; GetAndIncSyncInterface() local
[all...] |
| H A D | generic_syncer.cpp | 80 int GenericSyncer::Initialize(ISyncInterface *syncInterface, bool isNeedActive) in Initialize() argument
355 ISyncInterface *syncInterface = nullptr; in QueryAutoSync() local
415 InitMetaData(ISyncInterface *syncInterface) InitMetaData() argument
435 InitTimeHelper(ISyncInterface *syncInterface) InitTimeHelper() argument
453 InitSyncEngine(ISyncInterface *syncInterface) InitSyncEngine() argument
485 CheckSyncActive(ISyncInterface *syncInterface, bool isNeedActive) CheckSyncActive() argument
1129 IsNeedActive(ISyncInterface *syncInterface) IsNeedActive() argument
1146 InitStorageResource(ISyncInterface *syncInterface) InitStorageResource() argument
[all...] |
| H A D | sync_engine.cpp | 69 int SyncEngine::Initialize(ISyncInterface *syncInterface, const std::shared_ptr<Metadata> &metadata, in Initialize() argument
275 int SyncEngine::InitComunicator(const ISyncInterface *syncInterface) in InitComunicator() argument
232 InitInnerSource(const std::function<void(std::string)> &onRemoteDataChanged, const std::function<void(std::string)> &offlineChanged, ISyncInterface *syncInterface) InitInnerSource() argument
1002 StartAutoSubscribeTimer([[gnu::unused]] const ISyncInterface &syncInterface) StartAutoSubscribeTimer() argument
1293 ISyncInterface *syncInterface = nullptr; ClearSyncInterface() local
1315 SetSyncInterface(ISyncInterface *syncInterface) SetSyncInterface() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | sync_able_kvdb.cpp | 134 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in SetSyncModuleActive() local
180 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in StartSyncerWithNoLock() local
263 IKvDBSyncInterface *syncInterface in UserChangeHandle() local
300 IKvDBSyncInterface *syncInterface = GetSyncInterface(); ChangeUserListener() local
440 IKvDBSyncInterface *syncInterface = GetSyncInterface(); SetSyncRetry() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_get_data_test.cpp | 1649 auto syncInterface = store->GetStorageEngine(); in HWTEST_F() local
1712 auto syncInterface = store->GetStorageEngine(); in HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_nb_delegate_test.cpp | 2366 InitVirtualDevice(const std::string &devId, KvVirtualDevice *&devices, VirtualSingleVerSyncDBInterface *&syncInterface) InitVirtualDevice() argument
|