SWC::Ranger::Callback::RangeLocateScanCommit Class Reference

#include <swcdb/ranger/callbacks/RangeLocateScanCommit.h>

Inheritance diagram for SWC::Ranger::Callback::RangeLocateScanCommit:

Collaboration diagram for SWC::Ranger::Callback::RangeLocateScanCommit:

Public Types
typedef std::shared_ptr< RangeLocateScanCommit >	Ptr
Public Types inherited from SWC::Ranger::Callback::RangeLocateScan
typedef std::shared_ptr< RangeLocateScan >	Ptr
Public Types inherited from SWC::Ranger::ReqScan
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	RangeLocateScanCommit (const Comm::ConnHandlerPtr &conn, const Comm::Event::Ptr &ev, const DB::Cell::Key &a_range_begin, const RangePtr &a_range, uint8_t a_flags)
virtual	~RangeLocateScanCommit () noexcept
bool	selector (const DB::Types::KeySeq key_seq, const DB::Cells::Cell &cell, bool &stop) override
Public Member Functions inherited from SWC::Ranger::Callback::RangeLocateScan
SWC_CAN_INLINE	RangeLocateScan (const Comm::ConnHandlerPtr &conn, const Comm::Event::Ptr &ev, const DB::Cell::Key &a_range_begin, const DB::Cell::Key &a_range_end, const RangePtr &a_range, uint8_t a_flags)
virtual	~RangeLocateScan () noexcept
bool	reached_limits () override
bool	add_cell_and_more (const DB::Cells::Cell &cell) override
void	response (int &err) override
Public Member Functions inherited from SWC::Ranger::ReqScan
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	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_ok ()
virtual void	send_error (int err, const std::string &msg)

Additional Inherited Members
Public Attributes inherited from SWC::Ranger::Callback::RangeLocateScan
RangePtr	range
uint8_t	flags
uint32_t	any_is
const DB::Cell::Key	range_begin
Comm::Protocol::Rgr::Params::RangeLocateRsp	params
Public Attributes inherited from SWC::Ranger::ReqScan
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
Protected Attributes inherited from SWC::Comm::ResponseCallback
ConnHandlerPtr	m_conn
Event::Ptr	m_ev

Detailed Description

Definition at line 14 of file RangeLocateScanCommit.h.

Member Typedef Documentation

Ptr

typedef std::shared_ptr<RangeLocateScanCommit> SWC::Ranger::Callback::RangeLocateScanCommit::Ptr

Definition at line 17 of file RangeLocateScanCommit.h.

Constructor & Destructor Documentation

RangeLocateScanCommit()

SWC_CAN_INLINE SWC::Ranger::Callback::RangeLocateScanCommit::RangeLocateScanCommit ( const Comm::ConnHandlerPtr &  conn, const Comm::Event::Ptr &  ev, const DB::Cell::Key &  a_range_begin, const RangePtr &  a_range, uint8_t  a_flags  )

inline

Definition at line 20 of file RangeLocateScanCommit.h.

~RangeLocateScanCommit()

virtual SWC::Ranger::Callback::RangeLocateScanCommit::~RangeLocateScanCommit ( )

inlinevirtualnoexcept

Definition at line 31 of file RangeLocateScanCommit.h.

Member Function Documentation

selector()

bool SWC::Ranger::Callback::RangeLocateScanCommit::selector ( const DB::Types::KeySeq  key_seq, const DB::Cells::Cell &  cell, bool &  stop  )

inlineoverridevirtual

Reimplemented from SWC::Ranger::Callback::RangeLocateScan.

Definition at line 33 of file RangeLocateScanCommit.h.

References SWC::Ranger::Callback::RangeLocateScan::any_is, SWC::Core::Buffer< T >::base, SWC::DB::KeySeq::compare(), SWC::DB::KeySeq::compare_upto(), SWC::DB::Cell::Key::copy(), SWC::DB::Cell::Key::count, SWC::DB::Cell::Key::decode(), SWC::Serialization::decode_vi64(), SWC::Condition::EQ, SWC::DB::Cells::Cell::get_value(), SWC::Condition::GT, SWC::DB::Cells::Cell::key, SWC::Ranger::Callback::RangeLocateScan::params, SWC::Ranger::Callback::RangeLocateScan::range, SWC::Comm::Protocol::Rgr::Params::RangeLocateRsp::range_begin, SWC::Ranger::Callback::RangeLocateScan::range_begin, SWC::Comm::Protocol::Rgr::Params::RangeLocateRsp::range_end, SWC::Comm::Protocol::Rgr::Params::RangeLocateRsp::rid, SWC::Core::Buffer< T >::size, and SWC::DB::Cell::Serial::Value::skip_type_and_id().

Here is the call graph for this function:

---

The documentation for this class was generated from the following file:

• include/swcdb/ranger/callbacks/RangeLocateScanCommit.h