#include <swcdb/manager/Protocol/Rgr/req/RangeUnoadForMerge.h>
Public Types | |
typedef std::shared_ptr< RangeUnoadForMerge > | 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 | |
RangeUnoadForMerge (const Manager::Ranger::Ptr &rgr, const Manager::ColumnHealthCheck::ColumnMerger::RangesMerger::Ptr &merger, const Manager::Range::Ptr &range, uint32_t timeout=60000) | |
virtual | ~RangeUnoadForMerge () noexcept |
bool | valid () override |
void | handle (ConnHandlerPtr conn, const Event::Ptr &ev) override |
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 | run () |
Private Attributes | |
const Manager::Ranger::Ptr | rgr |
const Manager::ColumnHealthCheck::ColumnMerger::RangesMerger::Ptr | merger |
const Manager::Range::Ptr | range |
Additional Inherited Members | |
Public Attributes inherited from SWC::Comm::client::ConnQueueReqBase | |
Buffers::Ptr | cbp |
ConnQueuePtr | queue |
Protected Member Functions inherited from SWC::Comm::client::ConnQueueReqBase | |
virtual | ~ConnQueueReqBase () noexcept |
Protected Member Functions inherited from SWC::Comm::DispatchHandler | |
virtual | ~DispatchHandler () noexcept |
Definition at line 15 of file RangeUnoadForMerge.h.
typedef std::shared_ptr<RangeUnoadForMerge> SWC::Comm::Protocol::Rgr::Req::RangeUnoadForMerge::Ptr |
Definition at line 17 of file RangeUnoadForMerge.h.
SWC_CAN_INLINE SWC::Comm::Protocol::Rgr::Req::RangeUnoadForMerge::RangeUnoadForMerge | ( | const Manager::Ranger::Ptr & | rgr, |
const Manager::ColumnHealthCheck::ColumnMerger::RangesMerger::Ptr & | merger, | ||
const Manager::Range::Ptr & | range, | ||
uint32_t | timeout = 60000 |
||
) |
Definition at line 13 of file RangeUnoadForMerge.cc.
|
inlinevirtualnoexcept |
Definition at line 25 of file RangeUnoadForMerge.h.
|
overridevirtual |
Implements SWC::Comm::DispatchHandler.
Definition at line 41 of file RangeUnoadForMerge.cc.
References SWC::Error::Exception::code(), SWC::Error::COLUMN_MARKED_REMOVED, SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::Rgr::Params::RangeUnloadRsp::EMPTY, SWC::Comm::Protocol::Rgr::Params::RangeUnloadRsp::err, SWC::Comm::Protocol::Rgr::Params::RangeUnloadRsp::flags, SWC::LOG_ERROR, merger, range, SWC::Env::Mngr::rangers(), SWC::Manager::Rangers::running(), SWC::Error::SERVER_SHUTTING_DOWN, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, SWC_LOG_OUT, and valid().
|
overridevirtual |
Implements SWC::Comm::DispatchHandler.
Definition at line 37 of file RangeUnoadForMerge.cc.
References SWC::Error::COMM_NOT_CONNECTED, merger, and range.
|
overridevirtual |
Reimplemented from SWC::Comm::DispatchHandler.
Definition at line 30 of file RangeUnoadForMerge.cc.
References SWC::DB::Types::MngrColumn::DELETED, merger, range, SWC::Env::Mngr::rangers(), and SWC::Manager::Rangers::running().
Referenced by handle().
|
private |
Definition at line 36 of file RangeUnoadForMerge.h.
Referenced by handle(), handle_no_conn(), and valid().
|
private |
Definition at line 37 of file RangeUnoadForMerge.h.
Referenced by handle(), handle_no_conn(), and valid().
|
private |
Definition at line 35 of file RangeUnoadForMerge.h.