#include <swcdb/db/client/Query/Select/BrokerScanner.h>
Public Types | |
typedef std::shared_ptr< BrokerScanner > | Ptr |
Public Member Functions | |
SWC_CAN_INLINE | BrokerScanner (const Handlers::Base::Ptr &hdlr, DB::Specs::Interval &&a_interval, const cid_t a_cid) noexcept |
SWC_CAN_INLINE | BrokerScanner (const Handlers::Base::Ptr &hdlr, const DB::Specs::Interval &a_interval, const cid_t a_cid) |
~BrokerScanner () noexcept | |
void | print (std::ostream &out) |
Static Public Member Functions | |
static SWC_CAN_INLINE void | execute (const Handlers::Base::Ptr &hdlr, cid_t cid, const DB::Specs::Interval &intval) |
static SWC_CAN_INLINE void | execute (const Handlers::Base::Ptr &hdlr, cid_t cid, DB::Specs::Interval &&intval) |
Public Attributes | |
Handlers::Base::Ptr | selector |
DB::Specs::Interval | interval |
const cid_t | cid |
Private Member Functions | |
void | select () |
void | selected (const ReqBase::Ptr &req, Comm::Protocol::Bkr::Params::CellsSelectRsp &rsp) |
Definition at line 18 of file BrokerScanner.h.
typedef std::shared_ptr<BrokerScanner> SWC::client::Query::Select::BrokerScanner::Ptr |
Definition at line 34 of file BrokerScanner.h.
|
inlinenoexcept |
Definition at line 40 of file BrokerScanner.h.
Referenced by execute().
|
inline |
Definition at line 48 of file BrokerScanner.h.
|
noexcept |
Definition at line 25 of file BrokerScanner.cc.
|
inlinestatic |
Definition at line 22 of file BrokerScanner.h.
References BrokerScanner(), and cid.
Referenced by SWC::client::Query::Select::Handlers::Base::default_executor().
|
inlinestatic |
Definition at line 28 of file BrokerScanner.h.
References BrokerScanner(), and cid.
void SWC::client::Query::Select::BrokerScanner::print | ( | std::ostream & | out | ) |
Definition at line 27 of file BrokerScanner.cc.
References cid, interval, SWC::DB::Specs::Interval::print(), and selector.
|
private |
Definition at line 34 of file BrokerScanner.cc.
References SWC::client::Query::Profiling::Component::Start::add(), cid, SWC::Comm::Protocol::Bkr::Params::CellsSelectRsp::err, interval, SWC::Comm::Protocol::Bkr::Req::CellsSelect< DataT >::request(), selector, SWC_CAN_INLINE, and SWC_SCANNER_REQ_DEBUG.
Referenced by selected().
|
private |
Definition at line 66 of file BrokerScanner.cc.
References cid, SWC::Error::CLIENT_STOPPING, SWC::Error::COLUMN_MARKED_REMOVED, SWC::Error::COLUMN_NOT_EXISTS, SWC::Error::COLUMN_SCHEMA_NAME_NOT_EXISTS, SWC::Comm::Protocol::Bkr::Params::CellsSelectRsp::data, SWC::Comm::Protocol::Bkr::Params::CellsSelectRsp::err, SWC::DB::Specs::Interval::flags, interval, SWC::Comm::Protocol::Bkr::Params::CellsSelectRsp::more, SWC::DB::Specs::Flags::offset, SWC::Comm::Protocol::Bkr::Params::CellsSelectRsp::offset, SWC::Error::OK, select(), selector, SWC::Core::Buffer< T >::size, and SWC_SCANNER_RSP_DEBUG.
const cid_t SWC::client::Query::Select::BrokerScanner::cid |
Definition at line 37 of file BrokerScanner.h.
Referenced by execute(), print(), select(), and selected().
DB::Specs::Interval SWC::client::Query::Select::BrokerScanner::interval |
Definition at line 36 of file BrokerScanner.h.
Referenced by print(), select(), and selected().
Handlers::Base::Ptr SWC::client::Query::Select::BrokerScanner::selector |
Definition at line 35 of file BrokerScanner.h.
Referenced by print(), select(), and selected().