Home
last modified time | relevance | path

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

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp193 std::vector<std::string> &deviceBQueies, SubscribeManager &subManager) in CheckUnFinishedMap()
210 …std::string> &deviceAQueies, std::vector<std::string> &deviceBQueies, SubscribeManager &subManager) in InitLocalSubscribeMap()
354 SubscribeManager subManager; variable
425 SubscribeManager subManager; variable
481 SubscribeManager subManager; variable
531 SubscribeManager subManager; variable
582 SubscribeManager subManager; variable
656 SubscribeManager subManager; variable
Ddistributeddb_single_ver_p2p_complex_sync_test.cpp1050 std::shared_ptr<SubscribeManager> subManager = std::make_shared<SubscribeManager>(); variable
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
Dsingle_ver_sync_state_machine.cpp551 std::shared_ptr<SubscribeManager> subManager = context_->GetSubscribeManager(); in DoTimeout() local
567 std::shared_ptr<SubscribeManager> subManager = context_->GetSubscribeManager(); in DoInnerErr() local
Dsingle_ver_sync_task_context.cpp474 void SingleVerSyncTaskContext::SetSubscribeManager(std::shared_ptr<SubscribeManager> &subManager) in SetSubscribeManager()
Dsingle_ver_data_sync_utils.cpp336 const std::shared_ptr<SubscribeManager> &subManager) in ControlAckErrorHandle()
Dsingle_ver_data_sync.cpp1758 std::shared_ptr<SubscribeManager> subManager = context->GetSubscribeManager(); in ControlCmdStart() local
1810 std::shared_ptr<SubscribeManager> subManager = context->GetSubscribeManager(); in ControlCmdAckRecv() local