#include <swcdb/ranger/queries/select/CheckMeta.h>
Public Types | |
typedef std::shared_ptr< CheckMeta > | 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 | |
CheckMeta (const RangePtr &range, const Callback::RangeLoad::Ptr &req) | |
virtual | ~CheckMeta () noexcept |
bool | valid () noexcept override |
void | response (int err) override |
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) |
Static Public Member Functions | |
static void | run (const RangePtr &range, const Callback::RangeLoad::Ptr &req) |
Public Attributes | |
RangePtr | range |
Callback::RangeLoad::Ptr | req |
DB::Specs::Interval | spec |
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 |
Additional Inherited Members | |
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 |
Definition at line 27 of file CheckMeta.h.
typedef std::shared_ptr<CheckMeta> SWC::Ranger::Query::Select::CheckMeta::Ptr |
Definition at line 33 of file CheckMeta.h.
SWC_CAN_INLINE SWC::Ranger::Query::Select::CheckMeta::CheckMeta | ( | const RangePtr & | range, |
const Callback::RangeLoad::Ptr & | req | ||
) |
Definition at line 21 of file CheckMeta.cc.
References SWC::DB::Specs::KeyIntervals::add(), SWC::DB::Specs::Values::add(), SWC::DB::Specs::Serial::Value::Fields::add(), SWC::DB::Specs::Serial::Value::Fields::encode(), SWC::Condition::EQ, SWC::Condition::FIP, SWC::DB::Specs::Interval::key_intervals, SWC::DB::Specs::Serial::Value::Field_INT64::make(), range, SWC::Core::Vector< T, SizeT, GROW_SZ >::reserve(), spec, SWC::DB::Specs::KeyInterval::start, SWC::Core::to_string(), and SWC::DB::Specs::Interval::values.
Referenced by run().
|
inlinevirtualnoexcept |
Definition at line 41 of file CheckMeta.h.
|
overridevirtual |
Implements SWC::client::Query::Select::Handlers::Base.
Definition at line 42 of file CheckMeta.cc.
References SWC::Core::AtomicBase< T, OrderT >::compare_exchange_weak(), SWC::client::Query::Profiling::finished(), SWC::Error::OK, SWC::client::Query::Select::Handlers::Base::operator=(), SWC::Env::Rgr::post(), SWC::client::Query::Select::Handlers::Base::profile, SWC::client::Query::Select::Handlers::Base::state_error, and SWC_CAN_INLINE.
|
static |
Definition at line 14 of file CheckMeta.cc.
References CheckMeta(), range, and req.
Referenced by SWC::Ranger::Range::load().
|
overridevirtualnoexcept |
Implements SWC::client::Query::Select::Handlers::Base.
Definition at line 38 of file CheckMeta.cc.
References range, and SWC::client::Query::Select::Handlers::Base::state_error.
RangePtr SWC::Ranger::Query::Select::CheckMeta::range |
Definition at line 35 of file CheckMeta.h.
Referenced by CheckMeta(), run(), and valid().
Callback::RangeLoad::Ptr SWC::Ranger::Query::Select::CheckMeta::req |
Definition at line 36 of file CheckMeta.h.
Referenced by run().
DB::Specs::Interval SWC::Ranger::Query::Select::CheckMeta::spec |
Definition at line 37 of file CheckMeta.h.
Referenced by CheckMeta().