#include <swcdb/manager/Protocol/Rgr/req/ColumnUpdate.h>
Public Types | |
typedef std::shared_ptr< ColumnUpdate > | 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 | |
ColumnUpdate (const Manager::Ranger::Ptr &rgr, const Manager::Column::Ptr &col, const DB::Schema::Ptr &schema, uint64_t req_id) | |
ColumnUpdate (ColumnUpdate &&)=delete | |
ColumnUpdate (const ColumnUpdate &)=delete | |
ColumnUpdate & | operator= (ColumnUpdate &&)=delete |
ColumnUpdate & | operator= (const ColumnUpdate &)=delete |
virtual | ~ColumnUpdate () noexcept |
void | handle (ConnHandlerPtr conn, const Event::Ptr &ev) override |
void | handle_no_conn () override |
void | updated () |
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 () |
virtual bool | valid () |
Private Attributes | |
Manager::Ranger::Ptr | rgr |
Manager::Column::Ptr | col |
DB::Schema::Ptr | schema |
uint64_t | req_id |
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 14 of file ColumnUpdate.h.
typedef std::shared_ptr<ColumnUpdate> SWC::Comm::Protocol::Rgr::Req::ColumnUpdate::Ptr |
Definition at line 16 of file ColumnUpdate.h.
SWC_CAN_INLINE SWC::Comm::Protocol::Rgr::Req::ColumnUpdate::ColumnUpdate | ( | const Manager::Ranger::Ptr & | rgr, |
const Manager::Column::Ptr & | col, | ||
const DB::Schema::Ptr & | schema, | ||
uint64_t | req_id | ||
) |
Definition at line 15 of file ColumnUpdate.cc.
|
delete |
|
delete |
|
inlinevirtualnoexcept |
Definition at line 28 of file ColumnUpdate.h.
|
overridevirtual |
Implements SWC::Comm::DispatchHandler.
Definition at line 26 of file ColumnUpdate.cc.
References col, handle_no_conn(), rgr, schema, and updated().
|
overridevirtual |
Implements SWC::Comm::DispatchHandler.
Definition at line 34 of file ColumnUpdate.cc.
References SWC::DB::Types::MngrRangerState::ACK, SWC::Comm::client::ConnQueueReqBase::request_again(), rgr, and updated().
Referenced by handle().
|
delete |
|
delete |
void SWC::Comm::Protocol::Rgr::Req::ColumnUpdate::updated | ( | ) |
Definition at line 43 of file ColumnUpdate.cc.
References col, SWC::Env::Mngr::mngd_columns(), SWC::Error::OK, SWC::Env::Mngr::rangers(), req_id, schema, and SWC::Manager::MngdColumns::update().
Referenced by handle(), and handle_no_conn().
|
private |
Definition at line 38 of file ColumnUpdate.h.
|
private |
Definition at line 40 of file ColumnUpdate.h.
Referenced by updated().
|
private |
Definition at line 37 of file ColumnUpdate.h.
Referenced by handle(), and handle_no_conn().
|
private |
Definition at line 39 of file ColumnUpdate.h.