| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| 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
|
| D | mock_single_ver_kv_syncer.h | 29 void CallTriggerAddSubscribeAsync(ISyncInterface *syncInterface) in CallTriggerAddSubscribeAsync()
|
| D | generic_virtual_device.cpp | 77 …tualDevice::Initialize(VirtualCommunicatorAggregator *comAggregator, ISyncInterface *syncInterface) in Initialize()
|
| D | distributeddb_multi_ver_p2p_sync_test.cpp | 433 … VirtualMultiVerSyncDBInterface *syncInterface = new (std::nothrow) VirtualMultiVerSyncDBInterface; variable
|
| D | distributeddb_mock_sync_module_test.cpp | 55 void Initialize(ISyncInterface *syncInterface) in Initialize()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| D | single_ver_sync_engine.cpp | 24 ISyncTaskContext *SingleVerSyncEngine::CreateSyncTaskContext(const ISyncInterface &syncInterface) in CreateSyncTaskContext()
63 int SingleVerSyncEngine::StartAutoSubscribeTimer(const ISyncInterface &syncInterface) in StartAutoSubscribeTimer()
|
| D | single_ver_kv_syncer.cpp | 251 ISyncInterface *syncInterface = nullptr; in TriggerSubQuerySync() local
300 int SingleVerKVSyncer::InitSyncEngine(DistributedDB::ISyncInterface *syncInterface) in InitSyncEngine()
310 void SingleVerKVSyncer::TriggerAddSubscribeAsync(ISyncInterface *syncInterface) in TriggerAddSubscribeAsync()
|
| D | single_ver_relational_syncer.cpp | 22 int SingleVerRelationalSyncer::Initialize(ISyncInterface *syncInterface, bool isNeedActive) in Initialize()
48 const auto &syncInterface = static_cast<RelationalDBSyncInterface *>(syncInterface_); in PrepareSync() local
|
| D | single_ver_sync_task_context.cpp | 43 …SingleVerSyncTaskContext::Initialize(const DeviceSyncTarget &target, ISyncInterface *syncInterface, in Initialize()
|
| D | single_ver_sync_state_machine.cpp | 125 int SingleVerSyncStateMachine::Initialize(ISyncTaskContext *context, ISyncInterface *syncInterface, in Initialize()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| 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
|
| D | multi_ver_sync_task_context.cpp | 31 int MultiVerSyncTaskContext::Initialize(const std::string &deviceId, ISyncInterface *syncInterface, in Initialize()
|
| D | multi_ver_sync_state_machine.cpp | 61 int MultiVerSyncStateMachine::Initialize(ISyncTaskContext *context, ISyncInterface *syncInterface, in Initialize()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| D | sync_able_kvdb.cpp | 143 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in SetSyncModuleActive() local
189 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in StartSyncerWithNoLock() local
276 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in UserChangeHandle() local
313 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in ChangeUserListener() local
453 IKvDBSyncInterface *syncInterface = GetSyncInterface(); in SetSyncRetry() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| D | generic_syncer.cpp | 80 int GenericSyncer::Initialize(ISyncInterface *syncInterface, bool isNeedActive) in Initialize()
357 ISyncInterface *syncInterface = nullptr; in QueryAutoSync() local
426 int GenericSyncer::InitMetaData(ISyncInterface *syncInterface) in InitMetaData()
446 int GenericSyncer::InitTimeHelper(ISyncInterface *syncInterface) in InitTimeHelper()
464 int GenericSyncer::InitSyncEngine(ISyncInterface *syncInterface) in InitSyncEngine()
496 int GenericSyncer::CheckSyncActive(ISyncInterface *syncInterface, bool isNeedActive) in CheckSyncActive()
1149 bool GenericSyncer::IsNeedActive(ISyncInterface *syncInterface) in IsNeedActive()
1166 int GenericSyncer::InitStorageResource(ISyncInterface *syncInterface) in InitStorageResource()
|
| D | sync_engine.cpp | 69 int SyncEngine::Initialize(ISyncInterface *syncInterface, const std::shared_ptr<Metadata> &metadata, in Initialize()
234 const std::function<void(std::string)> &offlineChanged, ISyncInterface *syncInterface) in InitInnerSource()
276 int SyncEngine::InitComunicator(const ISyncInterface *syncInterface) in InitComunicator()
1056 int SyncEngine::StartAutoSubscribeTimer([[gnu::unused]] const ISyncInterface &syncInterface) in StartAutoSubscribeTimer()
1356 ISyncInterface *syncInterface = nullptr; in ClearSyncInterface() local
1378 void SyncEngine::SetSyncInterface(ISyncInterface *syncInterface) in SetSyncInterface()
1384 std::string SyncEngine::GetUserId(const ISyncInterface *syncInterface) in GetUserId()
1447 const ISyncInterface *syncInterface) in RegCallbackOnInitComunicator()
|
| D | remote_executor.cpp | 58 int RemoteExecutor::Initialize(ISyncInterface *syncInterface, ICommunicator *communicator) in Initialize()
253 auto *syncInterface = GetAndIncSyncInterface(); in SendRemoteExecutorData() local
513 auto syncInterface = GetAndIncSyncInterface(); in SendRequestMessage() local
849 ISyncInterface *syncInterface = syncInterface_; in GetAndIncSyncInterface() local
|
| D | syncer_proxy.cpp | 28 int SyncerProxy::Initialize(ISyncInterface *syncInterface, bool isNeedActive) in Initialize()
|
| D | sync_state_machine.cpp | 53 int SyncStateMachine::Initialize(ISyncTaskContext *context, ISyncInterface *syncInterface, in Initialize()
|
| D | ability_sync.cpp | 554 auto *syncInterface = static_cast<SyncGenericInterface *>(storageInterface_); in SecLabelCheck() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| D | distributeddb_relational_get_data_test.cpp | 1653 auto syncInterface = store->GetStorageEngine(); variable
1716 auto syncInterface = store->GetStorageEngine(); variable
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| D | distributeddb_interfaces_nb_delegate_extend_test.cpp | 105 VirtualSingleVerSyncDBInterface *&syncInterface) in InitVirtualDevice()
|
| D | distributeddb_interfaces_nb_delegate_test.cpp | 2772 VirtualSingleVerSyncDBInterface *&syncInterface) in InitVirtualDevice()
|