Home
last modified time | relevance | path

Searched refs:CommunicatorAggregator (Results 1 – 12 of 12) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dcommunicator_aggregator.cpp41 CommunicatorAggregator::CommunicatorAggregator() in CommunicatorAggregator() function in DistributedDB::CommunicatorAggregator
48 CommunicatorAggregator::~CommunicatorAggregator() in ~CommunicatorAggregator()
103 void CommunicatorAggregator::Finalize() in Finalize()
355 void CommunicatorAggregator::SendDataRoutine() in SendDataRoutine()
719 int CommunicatorAggregator::RegCallbackToAdapter() in RegCallbackToAdapter()
768 void CommunicatorAggregator::GenerateLocalSourceId() in GenerateLocalSourceId()
913 void CommunicatorAggregator::RegDBChangeCallback() in RegDBChangeCallback()
933 void CommunicatorAggregator::InitSendThread() in InitSendThread()
942 void CommunicatorAggregator::SendOnceData() in SendOnceData()
980 void CommunicatorAggregator::TriggerSendData() in TriggerSendData()
[all …]
H A Dcommunicator_linker.h33 class CommunicatorAggregator; // Forward Declaration variable
37 explicit CommunicatorLinker(CommunicatorAggregator *inAggregator,
100 CommunicatorAggregator *aggregator_ = nullptr;
H A Dcommunicator.h33 Communicator(CommunicatorAggregator *inCommAggregator, const LabelType &inLabel);
76 CommunicatorAggregator *commAggrHandle_ = nullptr;
H A Dcommunicator.cpp22 Communicator::Communicator(CommunicatorAggregator *inCommAggregator, const LabelType &inLabel) in Communicator()
H A Dcommunicator_linker.cpp35 CommunicatorLinker::CommunicatorLinker(CommunicatorAggregator *inAggregator, in CommunicatorLinker()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dcommunicator_aggregator.h49 class CommunicatorAggregator : public ICommunicatorAggregator {
51 CommunicatorAggregator();
52 ~CommunicatorAggregator() override;
54 DISABLE_COPY_ASSIGN_MOVE(CommunicatorAggregator);
164 DECLARE_OBJECT_TAG(CommunicatorAggregator);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_send_receive_test.cpp60 CommunicatorAggregator::EnableCommunicatorNotFoundFeedback(false); in SetUpTestCase()
72 CommunicatorAggregator::EnableCommunicatorNotFoundFeedback(true); in TearDownTestCase()
639 CommunicatorAggregator::EnableCommunicatorNotFoundFeedback(true);
699 CommunicatorAggregator::EnableCommunicatorNotFoundFeedback(false);
H A Ddistributeddb_communicator_common.h32 DistributedDB::CommunicatorAggregator *commAggrHandle = nullptr;
H A Ddistributeddb_communicator_common.cpp39 inEnv.commAggrHandle = new (nothrow) CommunicatorAggregator(); in SetUpEnv()
H A Ddistributeddb_communicator_deep_test.cpp66 CommunicatorAggregator::EnableCommunicatorNotFoundFeedback(false); in SetUpTestCase()
79 CommunicatorAggregator::EnableCommunicatorNotFoundFeedback(true); in TearDownTestCase()
H A Ddistributeddb_communicator_test.cpp71 CommunicatorAggregator::EnableCommunicatorNotFoundFeedback(false); in SetUpTestCase()
83 CommunicatorAggregator::EnableCommunicatorNotFoundFeedback(true); in TearDownTestCase()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Druntime_context_impl.cpp124 communicatorAggregator_ = new (std::nothrow) CommunicatorAggregator; in GetCommunicatorAggregator()