Home
last modified time | relevance | path

Searched refs:subManager (Results 1 – 8 of 8) 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.cpp223 subManager.GetAllUnFinishSubQueries(allSyncQueries); in CheckUnFinishedMap()
381 SubscribeManager subManager; variable
413 subManager.RemoveLocalSubscribeQuery(device, querySyncObj1);
452 SubscribeManager subManager; variable
508 SubscribeManager subManager; variable
558 SubscribeManager subManager; variable
586 subManager.ClearRemoteSubscribeQuery(device);
609 SubscribeManager subManager; variable
683 SubscribeManager subManager; variable
691 subManager.GetAllUnFinishSubQueries(allSyncQueries);
[all …]
H A Ddistributeddb_single_ver_p2p_complex_sync_test.cpp1061 std::shared_ptr<SubscribeManager> subManager = std::make_shared<SubscribeManager>(); variable
1062 tmpContext.SetSubscribeManager(subManager);
1072 subManager = nullptr;
/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
553 if (subManager != nullptr) { in DoTimeout()
554 subManager->DeleteLocalSubscribeQuery(context_->GetDeviceId(), context_->GetQuery()); in DoTimeout()
568 std::shared_ptr<SubscribeManager> subManager = context_->GetSubscribeManager(); in DoInnerErr() local
569 if (subManager != nullptr) { in DoInnerErr()
570 … subManager->DeleteLocalSubscribeQuery(context_->GetDeviceId(), context_->GetQuery()); in DoInnerErr()
H A Dsingle_ver_sync_task_context.h126 void SetSubscribeManager(std::shared_ptr<SubscribeManager> &subManager);
H A Dsingle_ver_data_sync.cpp1786 std::shared_ptr<SubscribeManager> subManager = context->GetSubscribeManager(); in ControlCmdStart() local
1787 if (subManager == nullptr) { in ControlCmdStart()
1800 … errCode = subManager->ReserveLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlCmdStart()
1811 subManager->DeleteLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlCmdStart()
1838 std::shared_ptr<SubscribeManager> subManager = context->GetSubscribeManager(); in ControlCmdAckRecv() local
1839 if (subManager == nullptr) { in ControlCmdAckRecv()
1844 SingleVerDataSyncUtils::ControlAckErrorHandle(context, subManager); in ControlCmdAckRecv()
1857 SingleVerDataSyncUtils::ControlAckErrorHandle(context, subManager); in ControlCmdAckRecv()
1861 … errCode = subManager->ActiveLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlCmdAckRecv()
1863 subManager->RemoveLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlCmdAckRecv()
H A Dsingle_ver_data_sync_utils.h71 const std::shared_ptr<SubscribeManager> &subManager);
H A Dsingle_ver_sync_task_context.cpp478 void SingleVerSyncTaskContext::SetSubscribeManager(std::shared_ptr<SubscribeManager> &subManager) in SetSubscribeManager() argument
480 subManager_ = subManager; in SetSubscribeManager()
H A Dsingle_ver_data_sync_utils.cpp369 const std::shared_ptr<SubscribeManager> &subManager) in ControlAckErrorHandle() argument
373 subManager->DeleteLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlAckErrorHandle()