SWC::Comm::client::ConnQueueReqBase Class Reference

#include <swcdb/core/comm/ClientConnQueue.h>

Inheritance diagram for SWC::Comm::client::ConnQueueReqBase:

Collaboration diagram for SWC::Comm::client::ConnQueueReqBase:

Public Types
typedef std::shared_ptr< ConnQueueReqBase >	Ptr
Public Types inherited from SWC::Comm::DispatchHandler
typedef std::shared_ptr< DispatchHandler >	Ptr

Public Member Functions
SWC_CAN_INLINE	ConnQueueReqBase (Buffers::Ptr &&a_cbp) noexcept
SWC_CAN_INLINE	ConnQueueReqBase (Buffers::Ptr &&a_cbp, const ConnQueuePtr &a_queue) noexcept
SWC_CAN_INLINE Ptr	req () noexcept
virtual bool	insistent () noexcept
void	request_again ()
void	print (std::ostream &out)
Public Member Functions inherited from SWC::Comm::DispatchHandler
virtual void	handle_no_conn ()=0
virtual void	handle (ConnHandlerPtr conn, const Event::Ptr &ev)=0
virtual bool	run ()
virtual bool	valid ()

Public Attributes
Buffers::Ptr	cbp
ConnQueuePtr	queue

Protected Member Functions
virtual	~ConnQueueReqBase () noexcept
Protected Member Functions inherited from SWC::Comm::DispatchHandler
virtual	~DispatchHandler () noexcept

Detailed Description

Definition at line 22 of file ClientConnQueue.h.

Member Typedef Documentation

Ptr

typedef std::shared_ptr<ConnQueueReqBase> SWC::Comm::client::ConnQueueReqBase::Ptr

Definition at line 25 of file ClientConnQueue.h.

Constructor & Destructor Documentation

ConnQueueReqBase() [1/2]

SWC_CAN_INLINE SWC::Comm::client::ConnQueueReqBase::ConnQueueReqBase ( Buffers::Ptr &&  a_cbp )

inlinenoexcept

Definition at line 30 of file ClientConnQueue.h.

ConnQueueReqBase() [2/2]

SWC_CAN_INLINE SWC::Comm::client::ConnQueueReqBase::ConnQueueReqBase ( Buffers::Ptr &&  a_cbp, const ConnQueuePtr &  a_queue  )

inlinenoexcept

Definition at line 34 of file ClientConnQueue.h.

~ConnQueueReqBase()

virtual SWC::Comm::client::ConnQueueReqBase::~ConnQueueReqBase ( )

inlineprotectedvirtualnoexcept

Definition at line 51 of file ClientConnQueue.h.

Member Function Documentation

insistent()

virtual bool SWC::Comm::client::ConnQueueReqBase::insistent ( )

inlinevirtualnoexcept

Reimplemented in SWC::Comm::Protocol::Mngr::Req::RgrUpdate, SWC::Comm::Protocol::Mngr::Req::MngrState, and SWC::Comm::Protocol::Mngr::Req::ColumnUpdate.

Definition at line 43 of file ClientConnQueue.h.

Referenced by print().

Here is the caller graph for this function:

print()

void SWC::Comm::client::ConnQueueReqBase::print

(

std::ostream &

out

)

Definition at line 19 of file ClientConnQueue.cc.

References cbp, insistent(), and SWC::Core::type_name().

Referenced by SWC::Comm::Protocol::Mngr::Req::RgrMngId::handle().

Here is the call graph for this function:

Here is the caller graph for this function:

req()

SWC_CAN_INLINE Ptr SWC::Comm::client::ConnQueueReqBase::req ( )

inlinenoexcept

Definition at line 39 of file ClientConnQueue.h.

Referenced by SWC::Comm::Protocol::Bkr::Req::ColumnCompact< DataT >::callback(), SWC::Comm::Protocol::Mngr::Req::ColumnCompact< DataT >::callback(), SWC::Comm::Protocol::Bkr::Req::ColumnMng< DataT >::callback(), SWC::Comm::Protocol::Mngr::Req::ColumnMng< DataT >::callback(), SWC::Comm::Protocol::Bkr::Req::ColumnGet< DataT >::callback(), SWC::Comm::Protocol::Bkr::Req::ColumnList< DataT >::callback(), SWC::Comm::Protocol::Mngr::Req::ColumnGet< DataT >::callback(), SWC::Comm::Protocol::Mngr::Req::ColumnList< DataT >::callback(), SWC::Comm::Protocol::Mngr::Req::RgrGet< DataT >::callback(), SWC::Comm::Protocol::Mngr::Req::ClusterStatus::handle(), SWC::Comm::Protocol::Mngr::Req::ColumnStatus::handle(), SWC::Comm::Protocol::Mngr::Req::RangersStatus::handle(), SWC::Comm::Protocol::Mngr::Req::ManagersStatus::handle(), SWC::Comm::Protocol::Rgr::Req::ReportRes::handle(), SWC::Comm::Protocol::Rgr::Req::ReportCids::handle(), SWC::Comm::Protocol::Rgr::Req::ReportColumnRids::handle(), SWC::Comm::Protocol::Rgr::Req::ReportColumnsRanges::handle(), SWC::Comm::Protocol::Bkr::Req::CellsSelect< DataT >::handle(), SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::handle(), SWC::Comm::Protocol::Bkr::Req::ColumnCompact< DataT >::handle(), SWC::Comm::Protocol::Bkr::Req::ColumnMng< DataT >::handle(), SWC::Comm::Protocol::Mngr::Req::ColumnCompact< DataT >::handle(), SWC::Comm::Protocol::Mngr::Req::ColumnMng< DataT >::handle(), SWC::Comm::Protocol::Mngr::Req::RangeCreate< DataT >::handle(), SWC::Comm::Protocol::Mngr::Req::RangeRemove< DataT >::handle(), SWC::Comm::Protocol::Mngr::Req::RangeUnloaded< DataT >::handle(), SWC::Comm::Protocol::Mngr::Req::RgrGet< DataT >::handle(), SWC::Comm::Protocol::Rgr::Req::RangeLocate< DataT >::handle(), SWC::Comm::Protocol::Rgr::Req::RangeQuerySelect< DataT >::handle(), SWC::Comm::Protocol::Rgr::Req::RangeQueryUpdate< DataT >::handle(), SWC::Comm::Protocol::Bkr::Req::CellsSelect< DataT >::handle_no_conn(), SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::handle_no_conn(), SWC::Comm::Protocol::Mngr::Req::RangeCreate< DataT >::handle_no_conn(), SWC::Comm::Protocol::Mngr::Req::RangeRemove< DataT >::handle_no_conn(), SWC::Comm::Protocol::Mngr::Req::RangeUnloaded< DataT >::handle_no_conn(), SWC::Comm::Protocol::Mngr::Req::ClusterStatus::handle_no_conn(), SWC::Comm::Protocol::Mngr::Req::ManagersStatus::handle_no_conn(), SWC::Comm::Protocol::Rgr::Req::RangeLocate< DataT >::handle_no_conn(), SWC::Comm::Protocol::Rgr::Req::RangeQuerySelect< DataT >::handle_no_conn(), SWC::Comm::Protocol::Rgr::Req::RangeQueryUpdate< DataT >::handle_no_conn(), SWC::Comm::Protocol::Rgr::Req::ReportRes::handle_no_conn(), SWC::Comm::Protocol::Rgr::Req::ReportCids::handle_no_conn(), SWC::Comm::Protocol::Rgr::Req::ReportColumnRids::handle_no_conn(), SWC::Comm::Protocol::Rgr::Req::ReportColumnsRanges::handle_no_conn(), SWC::Comm::Protocol::Rgr::Req::RangeLocate< DataT >::request(), SWC::Comm::Protocol::Rgr::Req::RangeQuerySelect< DataT >::request(), SWC::Comm::Protocol::Rgr::Req::RangeQueryUpdate< DataT >::request(), request_again(), SWC::Comm::Protocol::Bkr::Req::CellsSelect< DataT >::run(), SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::run(), SWC::Comm::Protocol::Bkr::Req::ColumnCompact_Base::run(), SWC::Comm::Protocol::Bkr::Req::ColumnGet_Base::run(), SWC::Comm::Protocol::Bkr::Req::ColumnList_Base::run(), SWC::Comm::Protocol::Bkr::Req::ColumnMng_Base::run(), SWC::Comm::Protocol::Mngr::Req::ColumnCompact_Base::run(), SWC::Comm::Protocol::Mngr::Req::ColumnGet_Base::run(), SWC::Comm::Protocol::Mngr::Req::ColumnList_Base::run(), SWC::Comm::Protocol::Mngr::Req::ColumnMng_Base::run(), SWC::Comm::Protocol::Mngr::Req::MngrActive::run(), SWC::Comm::Protocol::Mngr::Req::RangeCreate< DataT >::run(), SWC::Comm::Protocol::Mngr::Req::RangeRemove< DataT >::run(), SWC::Comm::Protocol::Mngr::Req::RangeUnloaded< DataT >::run(), SWC::Comm::Protocol::Mngr::Req::ClusterStatus::run(), SWC::Comm::Protocol::Mngr::Req::ColumnStatus::run(), SWC::Comm::Protocol::Mngr::Req::RangersStatus::run(), SWC::Comm::Protocol::Mngr::Req::ManagersStatus::run(), SWC::Comm::Protocol::Mngr::Req::RgrGet_Base::run(), SWC::Comm::Protocol::Rgr::Req::Report::run(), and SWC::Comm::Protocol::Mngr::Req::RgrMngId::run().

Here is the caller graph for this function:

request_again()

void SWC::Comm::client::ConnQueueReqBase::request_again

(

)

Definition at line 12 of file ClientConnQueue.cc.

References queue, req(), and SWC::Comm::DispatchHandler::run().

Referenced by SWC::Comm::Protocol::Bkr::Req::ColumnGet_Base::handle(), SWC::Comm::Protocol::Bkr::Req::ColumnList_Base::handle(), SWC::Comm::Protocol::Mngr::Req::ColumnGet_Base::handle(), SWC::Comm::Protocol::Mngr::Req::ColumnList_Base::handle(), SWC::Comm::Protocol::Mngr::Req::ColumnUpdate::handle(), SWC::Comm::Protocol::Rgr::Req::ColumnCompact::handle(), SWC::Comm::Protocol::Bkr::Req::ColumnCompact_Base::handle_no_conn(), SWC::Comm::Protocol::Bkr::Req::ColumnGet_Base::handle_no_conn(), SWC::Comm::Protocol::Bkr::Req::ColumnList_Base::handle_no_conn(), SWC::Comm::Protocol::Bkr::Req::ColumnMng_Base::handle_no_conn(), SWC::Comm::Protocol::Mngr::Handler::MngrColumnGet::handle_no_conn(), SWC::Comm::Protocol::Rgr::Req::ColumnDelete::handle_no_conn(), and SWC::Comm::Protocol::Rgr::Req::ColumnUpdate::handle_no_conn().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

cbp

Buffers::Ptr SWC::Comm::client::ConnQueueReqBase::cbp

Definition at line 26 of file ClientConnQueue.h.

Referenced by SWC::Comm::Protocol::Mngr::Req::RgrMngId::create(), print(), SWC::Comm::Protocol::Rgr::Req::Report::Report(), SWC::Comm::Protocol::Mngr::Req::Report::Report(), and SWC::Comm::Protocol::Rgr::Req::ReportRes::ReportRes().

queue

ConnQueuePtr SWC::Comm::client::ConnQueueReqBase::queue

Definition at line 27 of file ClientConnQueue.h.

Referenced by request_again().

---

The documentation for this class was generated from the following files:

• include/swcdb/core/comm/ClientConnQueue.h
• lib/swcdb/core/comm/ClientConnQueue.cc