| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_syncer.cpp | 108 void MultiVerSyncer::AddSyncOperation(ISyncEngine *engine, SyncOperation *operation) in AddSyncOperation() function in DistributedDB::MultiVerSyncer
112 GenericSyncer::AddSyncOperation(syncEngine_, operation); in AddSyncOperation()
|
| H A D | multi_ver_syncer.h | 55 void AddSyncOperation([[gnu::unused]] ISyncEngine *engine, SyncOperation *operation) override;
|
| H A D | multi_ver_sync_task_context.h | 35 int AddSyncOperation(SyncOperation *operation) override;
|
| H A D | multi_ver_sync_task_context.cpp | 70 int MultiVerSyncTaskContext::AddSyncOperation(SyncOperation *operation) in AddSyncOperation() function in DistributedDB::MultiVerSyncTaskContext
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | kv_virtual_device.cpp | 109 context_->AddSyncOperation(operation); in Subscribe()
132 context_->AddSyncOperation(operation); in UnSubscribe()
|
| H A D | generic_virtual_device.cpp | 259 errCode = context_->AddSyncOperation(operation); in Sync()
275 context_->AddSyncOperation(operation); in Sync()
303 context_->AddSyncOperation(operation); in Sync()
|
| H A D | distributeddb_mock_sync_module_test.cpp | 1280 enginePtr->AddSyncOperation(operation); in HWTEST_F()
1319 enginePtr->AddSyncOperation(operation); in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | isync_engine.h | 44 virtual int AddSyncOperation(SyncOperation *operation) = 0;
|
| H A D | isync_task_context.h | 42 virtual int AddSyncOperation(SyncOperation *operation) = 0;
|
| H A D | generic_syncer.h | 134 virtual void AddSyncOperation(ISyncEngine *engine, SyncOperation *operation);
|
| H A D | sync_engine.h | 47 int AddSyncOperation(SyncOperation *operation) override;
|
| H A D | generic_syncer.cpp | 253 AddSyncOperation(engine, operation); in PrepareSync()
383 void GenericSyncer::AddSyncOperation(ISyncEngine *engine, SyncOperation *operation) in AddSyncOperation() function in DistributedDB::GenericSyncer
389 LOGD("[Syncer] AddSyncOperation."); in AddSyncOperation()
390 engine->AddSyncOperation(operation); in AddSyncOperation()
|
| H A D | sync_engine.cpp | 158 int SyncEngine::AddSyncOperation(SyncOperation *operation) in AddSyncOperation() function in DistributedDB::SyncEngine
344 errCode = context->AddSyncOperation(operation); in AddSyncOperForContext()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvstore_sync_manager.h | 54 Status AddSyncOperation(uintptr_t syncId, uint32_t delayMs, const SyncFunc &syncFunc, const SyncEnd &syncEnd);
|
| H A D | kvstore_sync_manager.cpp | 24 Status KvStoreSyncManager::AddSyncOperation(uintptr_t syncId, uint32_t delayMs, const SyncFunc &syncFunc, in AddSyncOperation() function in OHOS::DistributedKv::KvStoreSyncManager
|
| H A D | kvdb_service_impl.cpp | 260 return KvStoreSyncManager::GetInstance()->AddSyncOperation(uintptr_t(metaData.tokenId), delay, in Sync()
524 return KvStoreSyncManager::GetInstance()->AddSyncOperation(uintptr_t(metaData.tokenId), delay, in AddSubscribeInfo()
534 return KvStoreSyncManager::GetInstance()->AddSyncOperation(uintptr_t(metaData.tokenId), delay, in RmvSubscribeInfo()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_task_context.h | 47 int AddSyncOperation(SyncOperation *operation) override;
|
| H A D | single_ver_sync_task_context.cpp | 92 int SingleVerSyncTaskContext::AddSyncOperation(SyncOperation *operation) in AddSyncOperation() function in DistributedDB::SingleVerSyncTaskContext
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | kvdb_service_test.cpp | 228 * @tc.name: AddSyncOperation
229 * @tc.desc: AddSyncOperation test the return result of input with different values.
233 HWTEST_F(KvStoreSyncManagerTest, AddSyncOperation, TestSize.Level0)
in HWTEST_F()
239 auto kvStatus = syncManager.AddSyncOperation(syncId, 0, syncFunc, syncEnd);
in HWTEST_F()
242 kvStatus = syncManager.AddSyncOperation(syncId, 0, syncFunc, syncEnd);
in HWTEST_F()
250 kvStatus = syncManager.AddSyncOperation(0, 0, syncFunc, syncEnd);
in HWTEST_F()
|