#include <swcdb/db/Columns/RgrData.h>
Classes | |
class | BaseSelector |
class | BaseUpdater |
class | SyncSelector |
class | SyncUpdater |
Public Types | |
typedef std::shared_ptr< RgrData > | Ptr |
Public Member Functions | |
SWC_CAN_INLINE | RgrData () noexcept |
~RgrData () noexcept | |
uint32_t | encoded_length () const noexcept |
void | encode (uint8_t **bufp) const noexcept |
void | decode (const uint8_t *ptr, size_t remain) |
void | print (std::ostream &out) |
void | set_insert_cell (cid_t cid, rid_t rid, client::Query::Update::Handlers::Base::Column *colp) const noexcept |
void | set_rgr (int &err, cid_t cid, rid_t rid) noexcept |
Static Public Member Functions | |
static void | set_delete_cell (cid_t cid, rid_t rid, client::Query::Update::Handlers::Base::Column *colp) noexcept |
static void | remove (int &err, cid_t cid, rid_t rid) noexcept |
static void | remove (int &err, cid_t cid) noexcept |
static void | get_rgr (const SyncSelector::Ptr &hdlr, RgrData &data, cid_t cid, rid_t rid) noexcept |
Public Attributes | |
Core::Atomic< rgrid_t > | rgrid |
Comm::EndPoints | endpoints |
typedef std::shared_ptr<RgrData> SWC::DB::RgrData::Ptr |
|
inlinenoexcept |
|
inline |
Definition at line 46 of file RgrData.h.
References SWC::Serialization::decode(), SWC::Serialization::decode_vi64(), endpoints, rgrid, and SWC::Core::AtomicBase< T, OrderT >::store().
|
inlinenoexcept |
Definition at line 41 of file RgrData.h.
References SWC::Serialization::encode(), SWC::Serialization::encode_vi64(), endpoints, SWC::Core::AtomicBase< T, OrderT >::load(), and rgrid.
Referenced by set_insert_cell().
|
inlinenoexcept |
Definition at line 36 of file RgrData.h.
References SWC::Serialization::encoded_length(), SWC::Serialization::encoded_length_vi64(), endpoints, SWC::Core::AtomicBase< T, OrderT >::load(), and rgrid.
Referenced by set_insert_cell().
|
inlinestaticnoexcept |
Definition at line 318 of file RgrData.h.
References data, and SWC::Error::OK.
Referenced by SWC::Manager::Range::get_last_rgr(), and SWC::Ranger::Range::last_rgr_chk().
|
inline |
Definition at line 51 of file RgrData.h.
References endpoints, SWC::Core::AtomicBase< T, OrderT >::load(), SWC::Comm::print(), and rgrid.
Referenced by SWC::Ranger::Range::last_rgr_chk().
|
inlinestaticnoexcept |
Definition at line 110 of file RgrData.h.
References SWC::DB::Specs::KeyIntervals::add(), SWC::DB::Cells::DELETE_LE, SWC::Condition::EQ, SWC::Condition::FIP, SWC::DB::Specs::Interval::flags, SWC::Env::Clients::get(), SWC::DB::Specs::Interval::key_intervals, SWC::LOG_DEBUG, SWC::LOG_WARN, SWC::client::Query::Update::Handlers::Common::make(), SWC::Core::Vector< T, SizeT, GROW_SZ >::reserve(), SWC::DB::Specs::Flags::set_only_keys(), SWC::DB::Specs::KeyInterval::start, SWC_CURRENT_EXCEPTION, SWC_FMT_LU, SWC_LOGF, SWC::DB::Types::SystemColumn::SYS_RGR_DATA, and SWC::Core::to_string().
Definition at line 99 of file RgrData.h.
References SWC_CURRENT_EXCEPTION.
Referenced by SWC::Ranger::Range::remove_rgr().
|
inlinestaticnoexcept |
Definition at line 75 of file RgrData.h.
References SWC::DB::Cell::Key::add(), SWC::DB::Cells::DELETE_LE, SWC::DB::Cells::Cell::flag, SWC::DB::Cells::Cell::key, SWC::DB::Cells::Cell::set_time_order_desc(), and SWC::Core::to_string().
Referenced by SWC::DB::RgrData::BaseUpdater::remove_rgr().
|
inlinenoexcept |
Definition at line 58 of file RgrData.h.
References SWC::DB::Cell::Key::add(), SWC::Core::Buffer< T >::base, encode(), encoded_length(), SWC::DB::Cells::Cell::flag, SWC::DB::Cells::INSERT, SWC::DB::Cells::Cell::key, SWC::DB::Cells::Cell::set_time_order_desc(), SWC::DB::Cells::Cell::set_value(), SWC::Core::Buffer< T >::size, and SWC::Core::to_string().
Definition at line 87 of file RgrData.h.
References SWC_CURRENT_EXCEPTION.
Referenced by SWC::Ranger::Range::set_rgr().
Comm::EndPoints SWC::DB::RgrData::endpoints |
Definition at line 29 of file RgrData.h.
Referenced by decode(), encode(), encoded_length(), SWC::Ranger::AppContext::init(), SWC::Ranger::Range::last_rgr_chk(), SWC::Manager::Rangers::next_rgr(), and print().
Core::Atomic<rgrid_t> SWC::DB::RgrData::rgrid |
Definition at line 28 of file RgrData.h.
Referenced by decode(), encode(), encoded_length(), SWC::Ranger::RangeSplit::mngr_create_range(), SWC::Ranger::CompactRange::mngr_create_range(), and print().