#include <swcdb/core/comm/ClientConnQueues.h>
Public Types | |
typedef std::shared_ptr< Host > | Ptr |
Public Types inherited from SWC::Comm::client::ConnQueue | |
typedef ConnQueueReqBase | ReqBase |
Public Member Functions | |
Host (const ConnQueuesPtr queues, const EndPoints &endpoints, const Config::Property::Value_int32_g::Ptr keepalive_ms, const Config::Property::Value_int32_g::Ptr again_delay_ms) | |
virtual | ~Host () |
bool | connect () override |
void | close_issued () override |
Public Member Functions inherited from SWC::Comm::client::ConnQueue | |
SWC_CAN_INLINE | ConnQueue (const IoContextPtr &ioctx, const Config::Property::Value_int32_g::Ptr keepalive_ms=nullptr, const Config::Property::Value_int32_g::Ptr again_delay_ms=nullptr) |
ConnQueue (ConnQueue &&)=delete | |
ConnQueue (const ConnQueue &)=delete | |
ConnQueue & | operator= (ConnQueue &&)=delete |
ConnQueue & | operator= (const ConnQueue &)=delete |
virtual | ~ConnQueue () noexcept |
void | stop () |
EndPoint | get_endpoint_remote () noexcept |
EndPoint | get_endpoint_local () noexcept |
void | put (const ReqBase::Ptr &req) |
void | set (const ConnHandlerPtr &conn) |
void | delay (ReqBase::Ptr &&req) |
void | print (std::ostream &out) |
Public Attributes | |
const EndPoints | endpoints |
Protected Attributes | |
const ConnQueuesPtr | queues |
Protected Attributes inherited from SWC::Comm::client::ConnQueue | |
const Config::Property::Value_int32_g::Ptr | cfg_keepalive_ms |
const Config::Property::Value_int32_g::Ptr | cfg_again_delay_ms |
Definition at line 17 of file ClientConnQueues.h.
typedef std::shared_ptr<Host> SWC::Comm::client::Host::Ptr |
Definition at line 19 of file ClientConnQueues.h.
SWC_CAN_INLINE SWC::Comm::client::Host::Host | ( | const ConnQueuesPtr | queues, |
const EndPoints & | endpoints, | ||
const Config::Property::Value_int32_g::Ptr | keepalive_ms, | ||
const Config::Property::Value_int32_g::Ptr | again_delay_ms | ||
) |
Definition at line 88 of file ClientConnQueues.h.
|
virtual |
Definition at line 11 of file ClientConnQueues.cc.
References SWC::Comm::client::ConnQueue::stop().
|
overridevirtual |
Reimplemented from SWC::Comm::client::ConnQueue.
Definition at line 15 of file ClientConnQueues.cc.
|
overridevirtual |
Reimplemented from SWC::Comm::client::ConnQueue.
Definition at line 19 of file ClientConnQueues.cc.
References endpoints, SWC::Comm::client::ConnQueue::operator=(), queues, SWC::Comm::client::ConnQueue::set(), and SWC_CAN_INLINE.
const EndPoints SWC::Comm::client::Host::endpoints |
Definition at line 21 of file ClientConnQueues.h.
Referenced by close_issued(), and connect().
|
protected |
Definition at line 34 of file ClientConnQueues.h.
Referenced by close_issued(), and connect().