SWC::Comm::Protocol::Bkr::Handler::Selector Class Reference

#include <swcdb/broker/Protocol/handlers/CellsSelect.h>

Inheritance diagram for SWC::Comm::Protocol::Bkr::Handler::Selector:

Collaboration diagram for SWC::Comm::Protocol::Bkr::Handler::Selector:

Public Types
typedef std::shared_ptr< Selector >	Ptr
Public Types inherited from SWC::client::Query::Select::Handlers::Base
typedef std::shared_ptr< Base >	Ptr

Public Member Functions
SWC_CAN_INLINE	Selector (const ConnHandlerPtr &a_conn, const Event::Ptr &a_ev) noexcept
virtual	~Selector () noexcept
bool	valid () noexcept override
void	error (const cid_t, int err) override
size_t	get_size_bytes () noexcept override
bool	add_cells (const cid_t, StaticBuffer &buffer, bool, DB::Specs::Interval &interval) override
void	response (int err) override
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 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
ConnHandlerPtr	conn
Event::Ptr	ev
bool	sent
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

Detailed Description

Definition at line 21 of file CellsSelect.h.

Member Typedef Documentation

Ptr

typedef std::shared_ptr<Selector> SWC::Comm::Protocol::Bkr::Handler::Selector::Ptr

Definition at line 24 of file CellsSelect.h.

Constructor & Destructor Documentation

Selector()

SWC_CAN_INLINE SWC::Comm::Protocol::Bkr::Handler::Selector::Selector ( const ConnHandlerPtr &  a_conn, const Event::Ptr &  a_ev  )

inlinenoexcept

Definition at line 31 of file CellsSelect.h.

~Selector()

virtual SWC::Comm::Protocol::Bkr::Handler::Selector::~Selector ( )

inlinevirtualnoexcept

Definition at line 36 of file CellsSelect.h.

Member Function Documentation

add_cells()

bool SWC::Comm::Protocol::Bkr::Handler::Selector::add_cells ( const  cid_t, StaticBuffer &  buffer, bool  , DB::Specs::Interval &  interval  )

inlineoverridevirtual

Implements SWC::client::Query::Select::Handlers::Base.

Definition at line 51 of file CellsSelect.h.

References SWC::Error::CLIENT_STOPPING, conn, ev, SWC::DB::Specs::Interval::flags, SWC::Comm::Buffers::make(), SWC::DB::Specs::Flags::offset, sent, SWC::Error::SERVER_SHUTTING_DOWN, and SWC::client::Query::Select::Handlers::Base::state_error.

Here is the call graph for this function:

error()

void SWC::Comm::Protocol::Bkr::Handler::Selector::error ( const  cid_t, int  err  )

inlineoverridevirtual

Implements SWC::client::Query::Select::Handlers::Base.

Definition at line 43 of file CellsSelect.h.

References SWC::client::Query::Select::Handlers::Base::error().

Here is the call graph for this function:

get_size_bytes()

size_t SWC::Comm::Protocol::Bkr::Handler::Selector::get_size_bytes ( )

inlineoverridevirtualnoexcept

Implements SWC::client::Query::Select::Handlers::Base.

Definition at line 47 of file CellsSelect.h.

response()

void SWC::Comm::Protocol::Bkr::Handler::Selector::response ( int  err )

inlineoverridevirtual

Implements SWC::client::Query::Select::Handlers::Base.

Definition at line 70 of file CellsSelect.h.

References SWC::Error::CLIENT_STOPPING, conn, SWC::client::Query::Select::Handlers::Base::error(), ev, SWC::client::Query::Profiling::finished(), SWC::Env::Bkr::is_accepting(), SWC::LOG_DEBUG, SWC::Comm::Buffers::make(), SWC::client::Query::Profiling::print(), SWC::Error::print(), SWC::Env::Bkr::processed(), SWC::client::Query::Select::Handlers::Base::profile, sent, SWC::Error::SERVER_SHUTTING_DOWN, SWC::client::Query::Select::Handlers::Base::state_error, SWC::Core::AtomicBase< T, OrderT >::store(), SWC_LOG_OSTREAM, and SWC_LOG_OUT.

Here is the call graph for this function:

valid()

bool SWC::Comm::Protocol::Bkr::Handler::Selector::valid ( )

inlineoverridevirtualnoexcept

Implements SWC::client::Query::Select::Handlers::Base.

Definition at line 38 of file CellsSelect.h.

References conn, ev, SWC::Env::Bkr::is_accepting(), and SWC::client::Query::Select::Handlers::Base::state_error.

Here is the call graph for this function:

Member Data Documentation

conn

ConnHandlerPtr SWC::Comm::Protocol::Bkr::Handler::Selector::conn

Definition at line 26 of file CellsSelect.h.

Referenced by add_cells(), response(), and valid().

ev

Event::Ptr SWC::Comm::Protocol::Bkr::Handler::Selector::ev

Definition at line 27 of file CellsSelect.h.

Referenced by add_cells(), response(), and valid().

sent

bool SWC::Comm::Protocol::Bkr::Handler::Selector::sent

Definition at line 28 of file CellsSelect.h.

Referenced by add_cells(), and response().

---

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

• include/swcdb/broker/Protocol/handlers/CellsSelect.h