Searched refs:CommunicatorProxy (Results 1 – 5 of 5) sorted by relevance
22 CommunicatorProxy::CommunicatorProxy() : mainComm_(nullptr) in CommunicatorProxy() function in DistributedDB::CommunicatorProxy26 CommunicatorProxy::~CommunicatorProxy() in ~CommunicatorProxy()81 void CommunicatorProxy::Activate() in Activate()103 uint32_t CommunicatorProxy::GetCommunicatorMtuSize() const in GetCommunicatorMtuSize()111 uint32_t CommunicatorProxy::GetCommunicatorMtuSize(const std::string &target) const in GetCommunicatorMtuSize()134 uint32_t CommunicatorProxy::GetTimeout() const in GetTimeout()142 uint32_t CommunicatorProxy::GetTimeout(const std::string &target) const in GetTimeout()165 bool CommunicatorProxy::IsDeviceOnline(const std::string &device) const in IsDeviceOnline()170 int CommunicatorProxy::GetLocalIdentity(std::string &outTarget) const in GetLocalIdentity()228 void CommunicatorProxy::SetMainCommunicator(ICommunicator *communicator) in SetMainCommunicator()[all …]
29 class CommunicatorProxy : public ICommunicator {31 CommunicatorProxy();32 ~CommunicatorProxy();
233 CommunicatorProxy *communicatorProxy_;
250 CommunicatorProxy *comProxy = nullptr; in InitInnerSource()308 communicatorProxy_ = new (std::nothrow) CommunicatorProxy(); in InitComunicator()470 CommunicatorProxy *comProxy = nullptr; in ScheduleDealMsg()
63 CommunicatorProxy *commProxy_ = nullptr;110 commProxy_ = new (std::nothrow) CommunicatorProxy(); in SetUp()