Home
last modified time | relevance | path

Searched defs:subManager (Results 1 – 6 of 6) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp220 std::vector<std::string> &deviceBQueies, SubscribeManager &subManager) in CheckUnFinishedMap()
237 …std::string> &deviceAQueies, std::vector<std::string> &deviceBQueies, SubscribeManager &subManager) in InitLocalSubscribeMap()
381 SubscribeManager subManager; variable
452 SubscribeManager subManager; variable
508 SubscribeManager subManager; variable
558 SubscribeManager subManager; variable
609 SubscribeManager subManager; variable
683 SubscribeManager subManager; variable
H A Ddistributeddb_single_ver_p2p_complex_sync_test.cpp1061 std::shared_ptr<SubscribeManager> subManager = std::make_shared<SubscribeManager>(); variable
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_state_machine.cpp552 std::shared_ptr<SubscribeManager> subManager = context_->GetSubscribeManager(); in DoTimeout() local
568 std::shared_ptr<SubscribeManager> subManager = context_->GetSubscribeManager(); in DoInnerErr() local
H A Dsingle_ver_sync_task_context.cpp478 void SingleVerSyncTaskContext::SetSubscribeManager(std::shared_ptr<SubscribeManager> &subManager) in SetSubscribeManager()
H A Dsingle_ver_data_sync_utils.cpp369 const std::shared_ptr<SubscribeManager> &subManager) in ControlAckErrorHandle()
H A Dsingle_ver_data_sync.cpp1786 std::shared_ptr<SubscribeManager> subManager = context->GetSubscribeManager(); in ControlCmdStart() local
1838 std::shared_ptr<SubscribeManager> subManager = context->GetSubscribeManager(); in ControlCmdAckRecv() local