#include <swcdb/db/client/Query/Select/Handlers/Base.h>

Inheritance diagram for SWC::client::Query::Select::Handlers::Base:

Collaboration diagram for SWC::client::Query::Select::Handlers::Base:

Public Types
typedef std::shared_ptr< Base >	Ptr

Public Member Functions
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 bool	valid () noexcept=0

virtual void	error (const cid_t cid, int err)=0

virtual bool	add_cells (const cid_t cid, StaticBuffer &buffer, bool reached_limit, DB::Specs::Interval &interval)=0

virtual size_t	get_size_bytes () noexcept=0

virtual void	response (int err=Error::OK)=0

virtual int	error () noexcept

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)

Public Attributes
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

Protected Member Functions
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

Private Member Functions
void	default_executor (DB::Types::KeySeq key_seq, cid_t cid, const DB::Specs::Interval &intval)

void	default_executor (DB::Types::KeySeq key_seq, cid_t cid, DB::Specs::Interval &&intval)

void	default_executor (int &err, const DB::Specs::Scan &specs)

void	default_executor (int &err, DB::Specs::Scan &&specs)

Detailed Description

Definition at line 26 of file Base.h.

Member Typedef Documentation

◆ Ptr

typedef std::shared_ptr<Base> SWC::client::Query::Select::Handlers::Base::Ptr

Definition at line 28 of file Base.h.

Constructor & Destructor Documentation

◆ Base() [1/3]

SWC_CAN_INLINE SWC::client::Query::Select::Handlers::Base::Base	(	const Clients::Ptr &	a_clients,
		Clients::Flag	a_executor = `Clients::DEFAULT`
	)

inlinenoexcept

Definition at line 41 of file Base.h.

◆ Base() [2/3]

SWC::client::Query::Select::Handlers::Base::Base ( Base && )

delete

◆ Base() [3/3]

SWC::client::Query::Select::Handlers::Base::Base ( const Base & )

delete

◆ ~Base()

virtual SWC::client::Query::Select::Handlers::Base::~Base ( )

inlineprotectedvirtualnoexcept

Definition at line 132 of file Base.h.

Member Function Documentation

◆ _execute() [1/4]

virtual void SWC::client::Query::Select::Handlers::Base::_execute	(	DB::Types::KeySeq	key_seq,
		cid_t	cid,
		const DB::Specs::Interval &	intval
	)

inlineprotectedvirtual

Definition at line 114 of file Base.h.

References default_executor().

Referenced by scan().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ _execute() [2/4]

virtual void SWC::client::Query::Select::Handlers::Base::_execute	(	DB::Types::KeySeq	key_seq,
		cid_t	cid,
		DB::Specs::Interval &&	intval
	)

inlineprotectedvirtual

Definition at line 119 of file Base.h.

References default_executor().

Here is the call graph for this function:

◆ _execute() [3/4]

virtual void SWC::client::Query::Select::Handlers::Base::_execute	(	int &	err,
		const DB::Specs::Scan &	specs
	)

inlineprotectedvirtual

Definition at line 124 of file Base.h.

References default_executor().

Here is the call graph for this function:

◆ _execute() [4/4]

virtual void SWC::client::Query::Select::Handlers::Base::_execute	(	int &	err,
		DB::Specs::Scan &&	specs
	)

inlineprotectedvirtual

Definition at line 128 of file Base.h.

References default_executor().

Here is the call graph for this function:

◆ add_cells()

virtual bool SWC::client::Query::Select::Handlers::Base::add_cells	(	const cid_t	cid,
		StaticBuffer &	buffer,
		bool	reached_limit,
		DB::Specs::Interval &	interval
	)

pure virtual

Implemented in SWC::Comm::Protocol::Bkr::Handler::Selector, SWC::client::Query::Select::Handlers::Common, SWC::client::Query::Select::Handlers::BaseUnorderedMap, and SWC::client::Query::Select::Handlers::BaseSingleColumn.

◆ default_executor() [1/4]

void SWC::client::Query::Select::Handlers::Base::default_executor	(	DB::Types::KeySeq	key_seq,
		cid_t	cid,
		const DB::Specs::Interval &	intval
	)

private

Definition at line 18 of file Base.cc.

References SWC::client::Clients::BROKER, completion, SWC::client::Clients::DEFAULT, SWC::client::Query::Select::BrokerScanner::execute(), SWC::client::Query::Select::Scanner::execute(), executor, SWC::Core::CompletionCounter< CountT >::increment(), SWC::Error::INVALID_ARGUMENT, and SWC_THROWF.

Referenced by _execute().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ default_executor() [2/4]

void SWC::client::Query::Select::Handlers::Base::default_executor	(	DB::Types::KeySeq	key_seq,
		cid_t	cid,
		DB::Specs::Interval &&	intval
	)

private

Definition at line 34 of file Base.cc.

References SWC::client::Clients::BROKER, completion, SWC::client::Clients::DEFAULT, SWC::client::Query::Select::BrokerScanner::execute(), SWC::client::Query::Select::Scanner::execute(), executor, SWC::Core::CompletionCounter< CountT >::increment(), SWC::Error::INVALID_ARGUMENT, and SWC_THROWF.

Here is the call graph for this function:

◆ default_executor() [3/4]

void SWC::client::Query::Select::Handlers::Base::default_executor	(	int &	err,
		const DB::Specs::Scan &	specs
	)

private

Definition at line 50 of file Base.cc.

References SWC::Core::Vector< T, SizeT, GROW_SZ >::begin(), SWC::client::Clients::BROKER, buff_sz, clients, SWC::DB::Specs::Scan::columns, completion, SWC::client::Clients::DEFAULT, SWC::client::Query::Select::BrokerScanner::execute(), SWC::client::Query::Select::Scanner::execute(), executor, SWC::Core::CompletionCounter< CountT >::increment(), SWC::Error::INVALID_ARGUMENT, SWC::Core::Vector< T, SizeT, GROW_SZ >::size(), and SWC_THROWF.

Here is the call graph for this function:

◆ default_executor() [4/4]

void SWC::client::Query::Select::Handlers::Base::default_executor	(	int &	err,
		DB::Specs::Scan &&	specs
	)

private

Definition at line 105 of file Base.cc.

References SWC::Core::Vector< T, SizeT, GROW_SZ >::begin(), SWC::client::Clients::BROKER, buff_sz, clients, completion, SWC::client::Clients::DEFAULT, SWC::client::Query::Select::BrokerScanner::execute(), SWC::client::Query::Select::Scanner::execute(), executor, SWC::Core::CompletionCounter< CountT >::increment(), SWC::Error::INVALID_ARGUMENT, and SWC_THROWF.

Here is the call graph for this function:

◆ error() [1/3]

virtual int SWC::client::Query::Select::Handlers::Base::error ( )

inlinevirtualnoexcept

Reimplemented in SWC::client::Query::Select::Handlers::BaseUnorderedMap, SWC::client::Query::Select::Handlers::BaseSingleColumn, SWC::client::Query::Select::Handlers::BaseUnorderedMap, SWC::client::Query::Select::Handlers::BaseSingleColumn, SWC::client::Query::Select::Handlers::BaseUnorderedMap, and SWC::client::Query::Select::Handlers::BaseSingleColumn.

Definition at line 69 of file Base.h.

Referenced by SWC::Comm::Protocol::Bkr::Handler::Selector::error(), and SWC::Comm::Protocol::Bkr::Handler::Selector::response().

Here is the caller graph for this function:

◆ error() [2/3]

virtual void SWC::client::Query::Select::Handlers::Base::error	(	const cid_t	cid,
		int	err
	)

pure virtual

Implemented in SWC::Comm::Protocol::Bkr::Handler::Selector, SWC::client::Query::Select::Handlers::BaseUnorderedMap, and SWC::client::Query::Select::Handlers::BaseSingleColumn.

◆ error() [3/3]

virtual void SWC::client::Query::Select::Handlers::Base::error ( int err )

inlinevirtualnoexcept

Definition at line 73 of file Base.h.

◆ get_size_bytes()

virtual size_t SWC::client::Query::Select::Handlers::Base::get_size_bytes ( )

pure virtualnoexcept

Implemented in SWC::client::Query::Select::Handlers::BaseUnorderedMap, SWC::client::Query::Select::Handlers::BaseSingleColumn, and SWC::Comm::Protocol::Bkr::Handler::Selector.

◆ operator=() [1/2]

Base& SWC::client::Query::Select::Handlers::Base::operator= ( Base && )

delete

◆ operator=() [2/2]

Base& SWC::client::Query::Select::Handlers::Base::operator= ( const Base & )

delete

Referenced by SWC::Ranger::Query::Select::CheckMeta::response(), and SWC::client::Query::Select::Handlers::Common::send_result().

Here is the caller graph for this function:

◆ response()

virtual void SWC::client::Query::Select::Handlers::Base::response ( int err = Error::OK )

pure virtual

Implemented in SWC::Ranger::Query::Select::CheckMeta, SWC::DB::RgrData::BaseSelector, SWC::client::Query::Select::Handlers::Common, and SWC::Comm::Protocol::Bkr::Handler::Selector.

◆ scan() [1/6]

SWC_CAN_INLINE void SWC::client::Query::Select::Handlers::Base::scan	(	const DB::Schema::Ptr &	schema,
		const DB::Specs::Interval &	intval
	)

inline

Definition at line 79 of file Base.h.

References _execute().

Here is the call graph for this function:

◆ scan() [2/6]

SWC_CAN_INLINE void SWC::client::Query::Select::Handlers::Base::scan	(	const DB::Schema::Ptr &	schema,
		DB::Specs::Interval &&	intval
	)

inline

Definition at line 85 of file Base.h.

References _execute().

Here is the call graph for this function:

◆ scan() [3/6]

SWC_CAN_INLINE void SWC::client::Query::Select::Handlers::Base::scan	(	DB::Types::KeySeq	key_seq,
		cid_t	cid,
		const DB::Specs::Interval &	intval
	)

inline

Definition at line 91 of file Base.h.

References _execute().

Here is the call graph for this function:

◆ scan() [4/6]

SWC_CAN_INLINE void SWC::client::Query::Select::Handlers::Base::scan	(	DB::Types::KeySeq	key_seq,
		cid_t	cid,
		DB::Specs::Interval &&	intval
	)

inline

Definition at line 97 of file Base.h.

References _execute().

Here is the call graph for this function:

◆ scan() [5/6]

SWC_CAN_INLINE void SWC::client::Query::Select::Handlers::Base::scan	(	int &	err,
		const DB::Specs::Scan &	specs
	)

inline

Definition at line 103 of file Base.h.

References _execute().

Here is the call graph for this function:

◆ scan() [6/6]

SWC_CAN_INLINE void SWC::client::Query::Select::Handlers::Base::scan	(	int &	err,
		DB::Specs::Scan &&	specs
	)

inline

Definition at line 108 of file Base.h.

References _execute().

Here is the call graph for this function:

◆ valid()

virtual bool SWC::client::Query::Select::Handlers::Base::valid ( )

pure virtualnoexcept

Implemented in SWC::Ranger::Query::Select::CheckMeta, SWC::DB::RgrData::BaseSelector, SWC::client::Query::Select::Handlers::Common, and SWC::Comm::Protocol::Bkr::Handler::Selector.

Member Data Documentation

◆ buff_ahead

Core::Atomic<uint8_t> SWC::client::Query::Select::Handlers::Base::buff_ahead

Definition at line 37 of file Base.h.

Referenced by SWC::client::Query::Select::Handlers::Common::wait_on_partials().

◆ buff_sz

Core::Atomic<uint32_t> SWC::client::Query::Select::Handlers::Base::buff_sz

Definition at line 36 of file Base.h.

Referenced by default_executor(), and SWC::client::Query::Select::Handlers::Common::wait_on_partials().

◆ clients

Clients::Ptr SWC::client::Query::Select::Handlers::Base::clients

Definition at line 30 of file Base.h.

Referenced by default_executor(), SWC::client::Query::Select::Handlers::Common::make(), and SWC::client::Query::Select::Handlers::Common::send_result().

◆ completion

Core::CompletionCounter<uint64_t> SWC::client::Query::Select::Handlers::Base::completion

Definition at line 33 of file Base.h.

Referenced by default_executor(), and SWC::client::Query::Select::Handlers::Common::wait().

◆ executor

const Clients::Flag SWC::client::Query::Select::Handlers::Base::executor

Definition at line 38 of file Base.h.

Referenced by default_executor(), and SWC::client::Query::Select::Handlers::Common::make().

◆ profile

Profiling SWC::client::Query::Select::Handlers::Base::profile

Definition at line 31 of file Base.h.

Referenced by SWC::Comm::Protocol::Bkr::Handler::Selector::response(), SWC::client::Query::Select::Handlers::Common::response(), SWC::DB::RgrData::BaseSelector::response(), and SWC::Ranger::Query::Select::CheckMeta::response().

◆ state_error

Core::Atomic<int> SWC::client::Query::Select::Handlers::Base::state_error

Definition at line 32 of file Base.h.

Referenced by SWC::Comm::Protocol::Bkr::Handler::Selector::add_cells(), SWC::client::Query::Select::Handlers::BaseUnorderedMap::error(), SWC::client::Query::Select::Handlers::BaseSingleColumn::error(), SWC::Comm::Protocol::Bkr::Handler::Selector::response(), SWC::client::Query::Select::Handlers::Common::response(), SWC::DB::RgrData::BaseSelector::response(), SWC::Ranger::Query::Select::CheckMeta::response(), SWC::Comm::Protocol::Bkr::Handler::Selector::valid(), SWC::DB::RgrData::BaseSelector::valid(), and SWC::Ranger::Query::Select::CheckMeta::valid().

◆ timeout

Core::Atomic<uint32_t> SWC::client::Query::Select::Handlers::Base::timeout

Definition at line 35 of file Base.h.

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

include/swcdb/db/client/Query/Select/Handlers/Base.h
lib/swcdb/db/client/Query/Select/Handlers/Base.cc

Public Types

Public Member Functions

Public Attributes

Protected Member Functions

Private Member Functions

Detailed Description

Member Typedef Documentation

◆ Ptr

Constructor & Destructor Documentation

◆ Base() [1/3]

◆ Base() [2/3]

◆ Base() [3/3]

◆ ~Base()

Member Function Documentation

◆ _execute() [1/4]

◆ _execute() [2/4]

◆ _execute() [3/4]

◆ _execute() [4/4]

◆ add_cells()

◆ default_executor() [1/4]

◆ default_executor() [2/4]

◆ default_executor() [3/4]

◆ default_executor() [4/4]

◆ error() [1/3]

◆ error() [2/3]

◆ error() [3/3]

◆ get_size_bytes()

◆ operator=() [1/2]

◆ operator=() [2/2]

◆ response()

◆ scan() [1/6]

◆ scan() [2/6]

◆ scan() [3/6]

◆ scan() [4/6]

◆ scan() [5/6]

◆ scan() [6/6]

◆ valid()

Member Data Documentation

◆ buff_ahead

◆ buff_sz

◆ clients

◆ completion

◆ executor

◆ profile

◆ state_error

◆ timeout