#include <swcdb/db/Protocol/Mngr/req/Report.h>
Public Types | |
typedef std::function< void(const client::ConnQueue::ReqBase::Ptr &, const int &, const Params::Report::RspColumnStatus &)> | Cb_t |
typedef std::shared_ptr< ColumnStatus > | Ptr |
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 Member Functions | |
ColumnStatus (const SWC::client::Clients::Ptr &clients, const Params::Report::ReqColumnStatus ¶ms, Cb_t &&cb, const uint32_t timeout) | |
virtual | ~ColumnStatus () noexcept |
bool | run () override |
void | handle (ConnHandlerPtr conn, const Event::Ptr &ev) override |
Public Member Functions inherited from SWC::Comm::Protocol::Mngr::Req::Report | |
Report (const SWC::client::Clients::Ptr &clients, Params::Report::Function func, const uint32_t timeout) | |
Report (const SWC::client::Clients::Ptr &clients, const EndPoints &endpoints, Params::Report::Function func, const uint32_t timeout) | |
Report (const SWC::client::Clients::Ptr &clients, const Serializable ¶ms, Params::Report::Function func, const uint32_t timeout) | |
Report (Report &&)=delete | |
Report (const Report &)=delete | |
Report & | operator= (Report &&)=delete |
Report & | operator= (const Report &)=delete |
virtual | ~Report () noexcept |
void | handle_no_conn () 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 bool | valid () |
Static Public Member Functions | |
static SWC_CAN_INLINE void | request (const SWC::client::Clients::Ptr &clients, cid_t cid, Cb_t &&cb, const uint32_t timeout=10000) |
static SWC_CAN_INLINE void | request (const SWC::client::Clients::Ptr &clients, const Params::Report::ReqColumnStatus ¶ms, Cb_t &&cb, const uint32_t timeout=10000) |
static SWC_CAN_INLINE Ptr | make (const SWC::client::Clients::Ptr &clients, const Params::Report::ReqColumnStatus ¶ms, Cb_t &&cb, const uint32_t timeout=10000) |
Private Attributes | |
const Cb_t | cb |
cid_t | cid |
Additional Inherited Members | |
Public Attributes inherited from SWC::Comm::client::ConnQueueReqBase | |
Buffers::Ptr | cbp |
ConnQueuePtr | queue |
Protected Member Functions inherited from SWC::Comm::Protocol::Mngr::Req::Report | |
void | clear_endpoints () |
Protected Member Functions inherited from SWC::Comm::client::ConnQueueReqBase | |
virtual | ~ConnQueueReqBase () noexcept |
Protected Member Functions inherited from SWC::Comm::DispatchHandler | |
virtual | ~DispatchHandler () noexcept |
Protected Attributes inherited from SWC::Comm::Protocol::Mngr::Req::Report | |
SWC::client::Clients::Ptr | clients |
EndPoints | endpoints |
typedef std::function<void(const client::ConnQueue::ReqBase::Ptr&, const int&, const Params::Report::RspColumnStatus&)> SWC::Comm::Protocol::Mngr::Req::ColumnStatus::Cb_t |
typedef std::shared_ptr<ColumnStatus> SWC::Comm::Protocol::Mngr::Req::ColumnStatus::Ptr |
SWC::Comm::Protocol::Mngr::Req::ColumnStatus::ColumnStatus | ( | const SWC::client::Clients::Ptr & | clients, |
const Params::Report::ReqColumnStatus & | params, | ||
ColumnStatus::Cb_t && | a_cb, | ||
const uint32_t | timeout | ||
) |
|
inlinevirtualnoexcept |
|
overridevirtual |
Implements SWC::Comm::DispatchHandler.
Definition at line 133 of file Report.cc.
References cb, SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Serialization::decode_i32(), SWC::LOG_ERROR, SWC::Comm::client::ConnQueueReqBase::req(), SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
|
inlinestatic |
Definition at line 118 of file Report.h.
References cb, SWC::Comm::Protocol::Mngr::Req::Report::clients, and ColumnStatus().
Referenced by request().
|
inlinestatic |
Definition at line 103 of file Report.h.
References cb, cid, and SWC::Comm::Protocol::Mngr::Req::Report::clients.
Referenced by SWC::Utils::shell::Mngr::column_status().
|
inlinestatic |
Definition at line 111 of file Report.h.
References cb, SWC::Comm::Protocol::Mngr::Req::Report::clients, and make().
|
overridevirtual |
Reimplemented from SWC::Comm::DispatchHandler.
Definition at line 117 of file Report.cc.
References cb, cid, SWC::Error::CLIENT_STOPPING, SWC::Comm::Protocol::Mngr::Req::Report::clients, SWC::Core::Vector< T, SizeT, GROW_SZ >::empty(), SWC::Comm::Protocol::Mngr::Req::Report::endpoints, SWC::Comm::Protocol::Mngr::Req::MngrActive::make(), and SWC::Comm::client::ConnQueueReqBase::req().
|
private |
|
private |