Home
last modified time | relevance | path

Searched refs:AddSyncOperation (Results 1 – 19 of 19) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_syncer.cpp108 void MultiVerSyncer::AddSyncOperation(ISyncEngine *engine, SyncOperation *operation) in AddSyncOperation() function in DistributedDB::MultiVerSyncer
112 GenericSyncer::AddSyncOperation(syncEngine_, operation); in AddSyncOperation()
H A Dmulti_ver_syncer.h55 void AddSyncOperation([[gnu::unused]] ISyncEngine *engine, SyncOperation *operation) override;
H A Dmulti_ver_sync_task_context.h35 int AddSyncOperation(SyncOperation *operation) override;
H A Dmulti_ver_sync_task_context.cpp70 int MultiVerSyncTaskContext::AddSyncOperation(SyncOperation *operation) in AddSyncOperation() function in DistributedDB::MultiVerSyncTaskContext
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dkv_virtual_device.cpp109 context_->AddSyncOperation(operation); in Subscribe()
132 context_->AddSyncOperation(operation); in UnSubscribe()
H A Dgeneric_virtual_device.cpp231 context_->AddSyncOperation(operation); in Sync()
259 context_->AddSyncOperation(operation); in Sync()
H A Ddistributeddb_mock_sync_module_test.cpp1280 enginePtr->AddSyncOperation(operation);
1319 enginePtr->AddSyncOperation(operation);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Disync_engine.h44 virtual int AddSyncOperation(SyncOperation *operation) = 0;
H A Disync_task_context.h42 virtual int AddSyncOperation(SyncOperation *operation) = 0;
H A Dgeneric_syncer.h131 virtual void AddSyncOperation(ISyncEngine *engine, SyncOperation *operation);
H A Dsync_engine.h47 int AddSyncOperation(SyncOperation *operation) override;
H A Dgeneric_syncer.cpp216 AddSyncOperation(engine, operation); in PrepareSync()
346 void GenericSyncer::AddSyncOperation(ISyncEngine *engine, SyncOperation *operation) in AddSyncOperation() function in DistributedDB::GenericSyncer
353 engine->AddSyncOperation(operation); in AddSyncOperation()
H A Dsync_engine.cpp158 int SyncEngine::AddSyncOperation(SyncOperation *operation) in AddSyncOperation() function in DistributedDB::SyncEngine
344 errCode = context->AddSyncOperation(operation); in AddSyncOperForContext()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvstore_sync_manager.h54 …Status AddSyncOperation(uintptr_t syncId, uint32_t delayMs, const SyncFunc &syncFunc, const SyncEn…
H A Dkvstore_sync_manager.cpp24 Status KvStoreSyncManager::AddSyncOperation(uintptr_t syncId, uint32_t delayMs, const SyncFunc &syn… in AddSyncOperation() function in OHOS::DistributedKv::KvStoreSyncManager
H A Dkvdb_service_impl.cpp266 return KvStoreSyncManager::GetInstance()->AddSyncOperation(uintptr_t(metaData.tokenId), delay, in Sync()
530 return KvStoreSyncManager::GetInstance()->AddSyncOperation(uintptr_t(metaData.tokenId), delay, in AddSubscribeInfo()
540 return KvStoreSyncManager::GetInstance()->AddSyncOperation(uintptr_t(metaData.tokenId), delay, in RmvSubscribeInfo()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dkvdb_service_test.cpp232 HWTEST_F(KvStoreSyncManagerTest, AddSyncOperation, TestSize.Level0)
238 auto kvStatus = syncManager.AddSyncOperation(syncId, 0, syncFunc, syncEnd);
241 kvStatus = syncManager.AddSyncOperation(syncId, 0, syncFunc, syncEnd);
249 kvStatus = syncManager.AddSyncOperation(0, 0, syncFunc, syncEnd);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_task_context.h47 int AddSyncOperation(SyncOperation *operation) override;
H A Dsingle_ver_sync_task_context.cpp92 int SingleVerSyncTaskContext::AddSyncOperation(SyncOperation *operation) in AddSyncOperation() function in DistributedDB::SingleVerSyncTaskContext