#include <swcdb/db/Protocol/Rgr/params/RangeQueryUpdate.h>
Public Member Functions | |
SWC_CAN_INLINE | RangeQueryUpdateRsp (int a_err=Error::OK) noexcept |
RangeQueryUpdateRsp (int err, const uint8_t *ptr, size_t remain) noexcept | |
SWC_CAN_INLINE | ~RangeQueryUpdateRsp () 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 | |
int32_t | err |
uint32_t | cells_added |
DB::Cell::Key | range_prev_end |
DB::Cell::Key | range_end |
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 |
Definition at line 48 of file RangeQueryUpdate.h.
|
inlinenoexcept |
Definition at line 52 of file RangeQueryUpdate.h.
|
noexcept |
Definition at line 40 of file RangeQueryUpdate.cc.
References SWC::Error::Exception::code(), decode(), SWC::LOG_ERROR, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
|
inlinenoexcept |
Definition at line 60 of file RangeQueryUpdate.h.
|
overrideprivatevirtual |
Implements SWC::Comm::Serializable.
Definition at line 83 of file RangeQueryUpdate.cc.
References cells_added, SWC::DB::Cell::Key::decode(), SWC::Serialization::decode_vi32(), err, SWC::Error::RANGE_BAD_INTERVAL, range_end, and range_prev_end.
|
overrideprivatevirtual |
Implements SWC::Comm::Serializable.
Definition at line 74 of file RangeQueryUpdate.cc.
References cells_added, SWC::DB::Cell::Key::encode(), SWC::Serialization::encode_vi32(), err, SWC::Error::RANGE_BAD_INTERVAL, range_end, and range_prev_end.
|
overrideprivatevirtual |
Implements SWC::Comm::Serializable.
Definition at line 66 of file RangeQueryUpdate.cc.
References cells_added, SWC::DB::Cell::Key::encoded_length(), SWC::Serialization::encoded_length_vi32(), err, SWC::Error::RANGE_BAD_INTERVAL, range_end, and range_prev_end.
void SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateRsp::print | ( | std::ostream & | out | ) | const |
Definition at line 54 of file RangeQueryUpdate.cc.
References cells_added, SWC::DB::Cell::Key::empty(), err, SWC::DB::Cell::Key::print(), SWC::Error::print(), SWC::Error::RANGE_BAD_INTERVAL, range_end, and range_prev_end.
uint32_t SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateRsp::cells_added |
Definition at line 65 of file RangeQueryUpdate.h.
Referenced by SWC::Ranger::Range::_run_add_queue(), SWC::Ranger::Range::MetaRegOnAddReq::callback(), SWC::client::Query::Update::Committer::committed_data(), internal_decode(), internal_encode(), internal_encoded_length(), and print().
int32_t SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateRsp::err |
Definition at line 64 of file RangeQueryUpdate.h.
Referenced by SWC::Ranger::Range::_run_add_queue(), SWC::Ranger::Range::MetaRegOnAddReq::callback(), SWC::client::Query::Update::Committer::commit_data(), SWC::client::Query::Update::Committer::committed_data(), internal_decode(), internal_encode(), internal_encoded_length(), and print().
DB::Cell::Key SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateRsp::range_end |
Definition at line 67 of file RangeQueryUpdate.h.
Referenced by SWC::Ranger::Range::_run_add_queue(), SWC::client::Query::Update::Committer::committed_data(), internal_decode(), internal_encode(), internal_encoded_length(), and print().
DB::Cell::Key SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateRsp::range_prev_end |
Definition at line 66 of file RangeQueryUpdate.h.
Referenced by SWC::Ranger::Range::_run_add_queue(), SWC::client::Query::Update::Committer::committed_data(), internal_decode(), internal_encode(), internal_encoded_length(), and print().