#include <swcdb/db/Columns/RgrData.h>
Public Types | |
typedef std::shared_ptr< BaseSelector > | Ptr |
Public Types inherited from SWC::client::Query::Select::Handlers::BaseSingleColumn | |
typedef std::shared_ptr< BaseSingleColumn > | Ptr |
Public Types inherited from SWC::client::Query::Select::Handlers::Base | |
typedef std::shared_ptr< Base > | Ptr |
Public Member Functions | |
SWC_CAN_INLINE | BaseSelector () |
bool | valid () noexcept override |
void | response (int err) override |
virtual void | callback ()=0 |
void | scan (cid_t a_cid, rid_t a_rid) |
void | get_rgr (int &err, DB::RgrData &data) noexcept |
Public Member Functions inherited from SWC::client::Query::Select::Handlers::BaseSingleColumn | |
SWC_CAN_INLINE | BaseSingleColumn (const Clients::Ptr &a_clients, const cid_t a_cid, Clients::Flag a_executor=Clients::DEFAULT) noexcept |
virtual | ~BaseSingleColumn () noexcept |
virtual void | error (const cid_t _cid, int err) override |
virtual bool | add_cells (const cid_t _cid, StaticBuffer &buffer, bool reached_limit, DB::Specs::Interval &interval) override |
virtual size_t | get_size_bytes () noexcept override |
virtual size_t | get_size () noexcept |
virtual bool | empty () noexcept |
virtual void | get_cells (DB::Cells::Result &cells) |
virtual void | error (const cid_t cid, int err)=0 |
virtual int | error () noexcept |
virtual void | error (int err) noexcept |
Public Member Functions inherited from SWC::client::Query::Select::Handlers::Base | |
SWC_CAN_INLINE | Base (const Clients::Ptr &a_clients, Clients::Flag a_executor=Clients::DEFAULT) noexcept |
Base (Base &&)=delete | |
Base (const Base &)=delete | |
Base & | operator= (const Base &)=delete |
Base & | operator= (Base &&)=delete |
virtual void | error (int err) noexcept |
SWC_CAN_INLINE void | scan (const DB::Schema::Ptr &schema, const DB::Specs::Interval &intval) |
SWC_CAN_INLINE void | scan (const DB::Schema::Ptr &schema, DB::Specs::Interval &&intval) |
SWC_CAN_INLINE void | scan (DB::Types::KeySeq key_seq, cid_t cid, const DB::Specs::Interval &intval) |
SWC_CAN_INLINE void | scan (DB::Types::KeySeq key_seq, cid_t cid, DB::Specs::Interval &&intval) |
SWC_CAN_INLINE void | scan (int &err, const DB::Specs::Scan &specs) |
SWC_CAN_INLINE void | scan (int &err, DB::Specs::Scan &&specs) |
Protected Member Functions | |
virtual | ~BaseSelector () noexcept |
Protected Member Functions inherited from SWC::client::Query::Select::Handlers::Base | |
virtual void | _execute (DB::Types::KeySeq key_seq, cid_t cid, const DB::Specs::Interval &intval) |
virtual void | _execute (DB::Types::KeySeq key_seq, cid_t cid, DB::Specs::Interval &&intval) |
virtual void | _execute (int &err, const DB::Specs::Scan &specs) |
virtual void | _execute (int &err, DB::Specs::Scan &&specs) |
virtual | ~Base () noexcept |
Additional Inherited Members | |
Public Attributes inherited from SWC::client::Query::Select::Handlers::BaseSingleColumn | |
const cid_t | cid |
Public Attributes inherited from SWC::client::Query::Select::Handlers::Base | |
Clients::Ptr | clients |
Profiling | profile |
Core::Atomic< int > | state_error |
Core::CompletionCounter< uint64_t > | completion |
Core::Atomic< uint32_t > | timeout |
Core::Atomic< uint32_t > | buff_sz |
Core::Atomic< uint8_t > | buff_ahead |
const Clients::Flag | executor |
typedef std::shared_ptr<BaseSelector> SWC::DB::RgrData::BaseSelector::Ptr |
|
inline |
|
inlineprotectedvirtualnoexcept |
|
pure virtual |
Implemented in SWC::DB::RgrData::SyncSelector.
Referenced by response().
|
inlinenoexcept |
Definition at line 279 of file RgrData.h.
References data, SWC::client::Query::Select::Handlers::BaseSingleColumn::get_cells(), SWC_CURRENT_EXCEPTION, SWC::DB::Cells::Cell::value, and SWC::DB::Cells::Cell::vlen.
|
inlineoverridevirtual |
Implements SWC::client::Query::Select::Handlers::Base.
Definition at line 254 of file RgrData.h.
References callback(), SWC::Core::AtomicBase< T, OrderT >::compare_exchange_weak(), SWC::client::Query::Profiling::finished(), SWC::Error::OK, SWC::client::Query::Select::Handlers::Base::profile, and SWC::client::Query::Select::Handlers::Base::state_error.
Definition at line 265 of file RgrData.h.
References SWC::DB::Specs::KeyIntervals::add(), SWC::Condition::EQ, SWC::DB::Specs::Interval::flags, SWC::DB::Specs::Interval::key_intervals, SWC::DB::Specs::Flags::limit, SWC::Core::Vector< T, SizeT, GROW_SZ >::reserve(), SWC::DB::Specs::KeyInterval::start, SWC::DB::Types::SystemColumn::SYS_RGR_DATA, and SWC::Core::to_string().
|
inlineoverridevirtualnoexcept |
Implements SWC::client::Query::Select::Handlers::Base.
Definition at line 250 of file RgrData.h.
References SWC::client::Query::Select::Handlers::Base::state_error.
Referenced by SWC::Manager::Range::get_last_rgr().