#include <swcdb/ranger/db/ReqScan.h>
Public Types | |
enum | Type : uint8_t { QUERY, BLK_PRELOAD, COMPACTION } |
typedef std::shared_ptr< ReqScan > | Ptr |
Public Types inherited from SWC::DB::Cells::ReqScan | |
typedef std::shared_ptr< ReqScan > | Ptr |
Public Types inherited from SWC::Comm::ResponseCallback | |
typedef std::shared_ptr< ResponseCallback > | Ptr |
Public Member Functions | |
SWC_CAN_INLINE | ReqScan (Type a_type=Type::QUERY, bool a_release_block=false, uint8_t a_readahead=1, uint32_t a_blk_size=0) noexcept |
SWC_CAN_INLINE | ReqScan (const Comm::ConnHandlerPtr &conn, const Comm::Event::Ptr &ev, const DB::Cell::Key &range_begin, const DB::Cell::Key &range_end, uint32_t a_blk_size) |
SWC_CAN_INLINE | ReqScan (const Comm::ConnHandlerPtr &conn, const Comm::Event::Ptr &ev, DB::Specs::Interval &&a_spec, uint32_t a_blk_size) |
SWC_CAN_INLINE | ReqScan (ReqScan &&)=delete |
ReqScan (const ReqScan &)=delete | |
ReqScan & | operator= (const ReqScan &)=delete |
ReqScan & | operator= (ReqScan &&)=delete |
virtual | ~ReqScan () noexcept |
SWC_CAN_INLINE Ptr | get_req_scan () noexcept |
virtual bool | with_block () const noexcept |
Public Member Functions inherited from SWC::DB::Cells::ReqScan | |
SWC_CAN_INLINE | ReqScan () noexcept |
SWC_CAN_INLINE | ReqScan (const DB::Specs::Interval &a_spec) |
SWC_CAN_INLINE | ReqScan (const Comm::ConnHandlerPtr &conn, const Comm::Event::Ptr &ev, DB::Specs::Interval &&a_spec) |
SWC_CAN_INLINE | ReqScan (const Comm::ConnHandlerPtr &conn, const Comm::Event::Ptr &ev, const DB::Specs::Interval &a_spec) |
SWC_CAN_INLINE | ReqScan (const Comm::ConnHandlerPtr &conn, const Comm::Event::Ptr &ev, const DB::Cell::Key &range_begin, const DB::Cell::Key &range_end) |
ReqScan (const ReqScan &)=delete | |
ReqScan (const ReqScan &&)=delete | |
ReqScan & | operator= (const ReqScan &)=delete |
SWC_CAN_INLINE Ptr | get_req_scan () noexcept |
SWC_CAN_INLINE bool | offset_adjusted () noexcept |
virtual bool | selector (const Types::KeySeq key_seq, const Cell &cell, bool &stop) |
virtual bool | reached_limits ()=0 |
virtual bool | add_cell_and_more (const Cell &cell)=0 |
virtual bool | has_update () const noexcept |
virtual void | update (DB::Cells::Mutable &) |
virtual void | print (std::ostream &out) const |
Public Member Functions inherited from SWC::Comm::ResponseCallback | |
ResponseCallback (const ConnHandlerPtr &conn, const Event::Ptr &ev) | |
virtual | ~ResponseCallback () noexcept |
virtual void | run () |
virtual bool | expired (int64_t within=0) const noexcept |
virtual void | response (int &err) |
virtual void | response_ok () |
virtual void | send_error (int err, const std::string &msg) |
Public Attributes | |
Type | type |
bool | release_block |
uint8_t | readahead |
const uint32_t | blk_size |
void * | block |
Public Attributes inherited from SWC::DB::Cells::ReqScan | |
DB::Specs::Interval | spec |
bool | only_keys |
uint64_t | offset |
Profile | profile |
Additional Inherited Members | |
Protected Attributes inherited from SWC::Comm::ResponseCallback | |
ConnHandlerPtr | m_conn |
Event::Ptr | m_ev |
typedef std::shared_ptr<ReqScan> SWC::Ranger::ReqScan::Ptr |
enum SWC::Ranger::ReqScan::Type : uint8_t |
|
inlinenoexcept |
Definition at line 33 of file ReqScan.h.
References blk_size, SWC::Env::Rgr::scan_reserved_bytes_add(), and SWC_SCAN_RSVD_BUFFS.
|
inline |
Definition at line 45 of file ReqScan.h.
References blk_size, SWC::Env::Rgr::scan_reserved_bytes_add(), and SWC_SCAN_RSVD_BUFFS.
|
inline |
Definition at line 57 of file ReqScan.h.
References blk_size, SWC::Env::Rgr::scan_reserved_bytes_add(), and SWC_SCAN_RSVD_BUFFS.
|
delete |
|
delete |
|
inlinevirtualnoexcept |
Reimplemented from SWC::DB::Cells::ReqScan.
Definition at line 75 of file ReqScan.h.
References blk_size, SWC::Env::Rgr::scan_reserved_bytes_sub(), and SWC_SCAN_RSVD_BUFFS.
|
inlinenoexcept |
|
inlinevirtualnoexcept |
Reimplemented in SWC::Ranger::CompactRange.
const uint32_t SWC::Ranger::ReqScan::blk_size |
Definition at line 91 of file ReqScan.h.
Referenced by SWC::Ranger::Callback::RangeQuerySelect::RangeQuerySelect(), SWC::Ranger::CompactRange::reached_limits(), ReqScan(), SWC::Ranger::CompactRange::request_more(), SWC::Ranger::CompactRange::response(), and ~ReqScan().