SWC-DB  v0.5.9 C++ documentations
SWC-DB© (Super Wide Column Database) - High Performance Scalable Database (https://github.com/kashirin-alex/swc-db)
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< ConnQueueReqBasePtr
 
- Public Types inherited from SWC::Comm::DispatchHandler
typedef std::shared_ptr< DispatchHandlerPtr
 

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

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()

Member Data Documentation

◆ cbp

◆ 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: