#include <swcdb/db/Protocol/Mngr/params/RgrGet.h>
Public Member Functions | |
SWC_CAN_INLINE | RgrGetRsp (int a_err=Error::OK) noexcept |
SWC_CAN_INLINE | RgrGetRsp (cid_t a_cid, rid_t a_rid) noexcept |
RgrGetRsp (int err, const uint8_t *ptr, size_t remain) noexcept | |
SWC_CAN_INLINE | ~RgrGetRsp () noexcept |
void | print (std::ostream &out) const |
Public Member Functions inherited from SWC::Comm::Serializable | |
size_t | encoded_length () const |
void | encode (uint8_t **bufp) const |
void | decode (const uint8_t **bufp, size_t *remainp) |
Public Attributes | |
EndPoints | endpoints |
int | err |
cid_t | cid |
rid_t | rid |
DB::Cell::Key | range_end |
DB::Cell::Key | range_begin |
int64_t | revision |
Private Member Functions | |
size_t SWC_PURE_FUNC | internal_encoded_length () const override |
void | internal_encode (uint8_t **bufp) const override |
void | internal_decode (const uint8_t **bufp, size_t *remainp) override |
Additional Inherited Members | |
Protected Member Functions inherited from SWC::Comm::Serializable | |
virtual | ~Serializable () noexcept |
|
inlinenoexcept |
|
inlinenoexcept |
|
noexcept |
Definition at line 58 of file RgrGet.cc.
References SWC::Error::Exception::code(), decode(), SWC::LOG_ERROR, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
|
inlinenoexcept |
|
overrideprivatevirtual |
Implements SWC::Comm::Serializable.
Definition at line 116 of file RgrGet.cc.
References cid, SWC::Serialization::decode(), SWC::DB::Cell::Key::decode(), SWC::Serialization::decode_vi32(), SWC::Serialization::decode_vi64(), endpoints, err, SWC::DB::Types::SystemColumn::is_master(), range_begin, range_end, revision, and rid.
|
overrideprivatevirtual |
Implements SWC::Comm::Serializable.
Definition at line 102 of file RgrGet.cc.
References cid, SWC::DB::Cell::Key::encode(), SWC::Serialization::encode(), SWC::Serialization::encode_vi32(), SWC::Serialization::encode_vi64(), endpoints, err, SWC::DB::Types::SystemColumn::is_master(), range_begin, range_end, revision, and rid.
|
overrideprivatevirtual |
Implements SWC::Comm::Serializable.
Definition at line 87 of file RgrGet.cc.
References cid, SWC::DB::Cell::Key::encoded_length(), SWC::Serialization::encoded_length(), SWC::Serialization::encoded_length_vi32(), SWC::Serialization::encoded_length_vi64(), endpoints, err, SWC::DB::Types::SystemColumn::is_master(), range_begin, range_end, revision, and rid.
void SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::print | ( | std::ostream & | out | ) | const |
Definition at line 72 of file RgrGet.cc.
References cid, endpoints, err, SWC::DB::Types::SystemColumn::is_master(), SWC::DB::Cell::Key::print(), SWC::Comm::print(), SWC::Error::print(), range_begin, range_end, revision, and rid.
Referenced by SWC::Comm::Protocol::Mngr::Handler::rgr_get().
cid_t SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::cid |
Definition at line 79 of file RgrGet.h.
Referenced by internal_decode(), internal_encode(), internal_encoded_length(), SWC::client::Query::Update::Committer::located_ranger(), SWC::client::Query::Select::Scanner::mngr_located_master(), print(), SWC::client::Query::Update::Committer::proceed_on_ranger(), and SWC::Comm::Protocol::Mngr::Handler::rgr_get().
EndPoints SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::endpoints |
Definition at line 77 of file RgrGet.h.
Referenced by internal_decode(), internal_encode(), internal_encoded_length(), SWC::client::Query::Update::Committer::located_on_manager(), SWC::client::Query::Update::Committer::located_ranger(), SWC::client::Query::Select::Scanner::mngr_located_master(), SWC::client::Query::Select::Scanner::mngr_resolve_rgr_meta(), SWC::client::Query::Select::Scanner::mngr_resolve_rgr_select(), SWC::client::Query::Select::Scanner::mngr_resolved_rgr_meta(), SWC::client::Query::Select::Scanner::mngr_resolved_rgr_select(), print(), SWC::client::Query::Update::Committer::proceed_on_ranger(), SWC::client::Query::Update::Committer::resolve_on_manager(), and SWC::Comm::Protocol::Mngr::Handler::rgr_get().
int SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::err |
Definition at line 78 of file RgrGet.h.
Referenced by internal_decode(), internal_encode(), internal_encoded_length(), SWC::client::Query::Update::Committer::locate_on_manager(), SWC::client::Query::Update::Committer::located_on_manager(), SWC::client::Query::Update::Committer::located_ranger(), SWC::client::Query::Select::Scanner::mngr_locate_master(), SWC::client::Query::Select::Scanner::mngr_located_master(), SWC::client::Query::Select::Scanner::mngr_resolve_rgr_meta(), SWC::client::Query::Select::Scanner::mngr_resolve_rgr_select(), SWC::client::Query::Select::Scanner::mngr_resolved_rgr_meta(), SWC::client::Query::Select::Scanner::mngr_resolved_rgr_select(), print(), SWC::client::Query::Update::Committer::resolve_on_manager(), and SWC::Comm::Protocol::Mngr::Handler::rgr_get().
DB::Cell::Key SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::range_begin |
Definition at line 82 of file RgrGet.h.
Referenced by internal_decode(), internal_encode(), internal_encoded_length(), SWC::client::Query::Update::Committer::located_on_manager(), SWC::client::Query::Select::Scanner::mngr_located_master(), print(), and SWC::Comm::Protocol::Mngr::Handler::rgr_get().
DB::Cell::Key SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::range_end |
Definition at line 81 of file RgrGet.h.
Referenced by internal_decode(), internal_encode(), internal_encoded_length(), SWC::client::Query::Update::Committer::located_on_manager(), SWC::client::Query::Select::Scanner::mngr_located_master(), print(), SWC::client::Query::Update::Committer::proceed_on_ranger(), and SWC::Comm::Protocol::Mngr::Handler::rgr_get().
int64_t SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::revision |
Definition at line 83 of file RgrGet.h.
Referenced by internal_decode(), internal_encode(), internal_encoded_length(), SWC::client::Query::Update::Committer::located_on_manager(), SWC::client::Query::Select::Scanner::mngr_located_master(), print(), and SWC::Comm::Protocol::Mngr::Handler::rgr_get().
rid_t SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::rid |
Definition at line 80 of file RgrGet.h.
Referenced by internal_decode(), internal_encode(), internal_encoded_length(), SWC::client::Query::Update::Committer::locate_on_manager(), SWC::client::Query::Update::Committer::located_on_manager(), SWC::client::Query::Update::Committer::located_ranger(), SWC::client::Query::Select::Scanner::mngr_locate_master(), SWC::client::Query::Select::Scanner::mngr_located_master(), SWC::client::Query::Select::Scanner::mngr_resolve_rgr_meta(), SWC::client::Query::Select::Scanner::mngr_resolve_rgr_select(), print(), SWC::client::Query::Update::Committer::proceed_on_ranger(), SWC::client::Query::Update::Committer::resolve_on_manager(), and SWC::Comm::Protocol::Mngr::Handler::rgr_get().