#include <swcdb/db/Protocol/Mngr/req/ColumnMng_Base.h>
Public Member Functions | |
SWC_CAN_INLINE | ColumnMng_Base (const Params::ColumnMng ¶ms, const uint32_t timeout) |
virtual | ~ColumnMng_Base () noexcept |
void | handle_no_conn () override |
bool | run () override |
Public Member Functions inherited from SWC::Comm::client::ConnQueueReqBase | |
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 (ConnHandlerPtr conn, const Event::Ptr &ev)=0 |
virtual bool | valid () |
Protected Member Functions | |
virtual SWC::client::Clients::Ptr & | get_clients () noexcept=0 |
virtual void | callback (int error)=0 |
Protected Member Functions inherited from SWC::Comm::client::ConnQueueReqBase | |
virtual | ~ConnQueueReqBase () noexcept |
Protected Member Functions inherited from SWC::Comm::DispatchHandler | |
virtual | ~DispatchHandler () noexcept |
Private Attributes | |
EndPoints | endpoints |
Additional Inherited Members | |
Public Types inherited from SWC::Comm::client::ConnQueueReqBase | |
typedef std::shared_ptr< ConnQueueReqBase > | Ptr |
Public Types inherited from SWC::Comm::DispatchHandler | |
typedef std::shared_ptr< DispatchHandler > | Ptr |
Public Attributes inherited from SWC::Comm::client::ConnQueueReqBase | |
Buffers::Ptr | cbp |
ConnQueuePtr | queue |
Definition at line 19 of file ColumnMng_Base.h.
|
inline |
Definition at line 23 of file ColumnMng_Base.h.
|
inlinevirtualnoexcept |
Definition at line 30 of file ColumnMng_Base.h.
|
protectedpure virtual |
Implemented in SWC::Comm::Protocol::Mngr::Req::ColumnMng< DataT >.
Referenced by handle_no_conn().
|
protectedpure virtualnoexcept |
Implemented in SWC::Comm::Protocol::Mngr::Req::ColumnMng< DataT >.
Referenced by handle_no_conn(), and run().
|
overridevirtual |
Implements SWC::Comm::DispatchHandler.
Definition at line 16 of file ColumnMng_Base.cc.
References callback(), SWC::Error::CANCELLED, SWC::Core::Vector< T, SizeT, GROW_SZ >::clear(), SWC::Error::CLIENT_STOPPING, endpoints, get_clients(), run(), and SWC::Comm::DispatchHandler::valid().
|
inlineoverridevirtual |
Reimplemented from SWC::Comm::DispatchHandler.
Definition at line 34 of file ColumnMng_Base.h.
References endpoints, get_clients(), and SWC::Comm::client::ConnQueueReqBase::req().
Referenced by handle_no_conn().
|
private |
Definition at line 47 of file ColumnMng_Base.h.
Referenced by handle_no_conn(), and run().