SWC::client::Query::Update::Handlers::Base Class Reference

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

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

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

Classes
class	Column

Public Types
typedef std::shared_ptr< Base >	Ptr
typedef Core::Vector< Column * >	Colms

Public Member Functions
SWC_CAN_INLINE	Base (const Clients::Ptr &a_clients, Clients::Flag a_executor=Clients::Flag::DEFAULT) noexcept
virtual bool	valid () noexcept=0
virtual void	response (int err=Error::OK)=0
virtual bool	requires_commit () noexcept=0
virtual bool	empty () noexcept=0
virtual size_t	size_bytes () noexcept=0
virtual void	next (Colms &cols) noexcept=0
virtual Column *	next (cid_t cid) noexcept=0
virtual void	error (cid_t cid, int err) noexcept=0
virtual int	error () noexcept
virtual void	error (int err) noexcept
SWC_CAN_INLINE void	add_resend_count (size_t count) noexcept
SWC_CAN_INLINE size_t	get_resend_count (bool reset=true) noexcept
void	commit ()
SWC_CAN_INLINE void	commit (const cid_t cid)
void	commit (Column *colp)

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 >	timeout_ratio
Core::Atomic< uint32_t >	buff_sz
Core::Atomic< uint8_t >	buff_ahead
const Clients::Flag	executor

Protected Member Functions
virtual void	_execute (Column *colp)
virtual	~Base () noexcept

Private Member Functions
void	default_executor (Column *colp)

Private Attributes
Core::Atomic< size_t >	m_resend_cells

Detailed Description

Definition at line 25 of file Base.h.

Member Typedef Documentation

Colms

typedef Core::Vector<Column*> SWC::client::Query::Update::Handlers::Base::Colms

Definition at line 102 of file Base.h.

Ptr

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

Definition at line 27 of file Base.h.

Constructor & Destructor Documentation

Base()

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

inlinenoexcept

Definition at line 117 of file Base.h.

References SWC::Core::AtomicBase< T, OrderT >::store(), and timeout_ratio.

Here is the call graph for this function:

~Base()

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

inlineprotectedvirtualnoexcept

Definition at line 194 of file Base.h.

Member Function Documentation

_execute()

virtual void SWC::client::Query::Update::Handlers::Base::_execute ( Column *  colp )

inlineprotectedvirtual

Definition at line 190 of file Base.h.

References default_executor().

Referenced by commit().

Here is the call graph for this function:

Here is the caller graph for this function:

add_resend_count()

SWC_CAN_INLINE void SWC::client::Query::Update::Handlers::Base::add_resend_count ( size_t  count )

inlinenoexcept

Definition at line 158 of file Base.h.

References SWC::Core::Atomic< T, OrderT >::fetch_add(), and m_resend_cells.

Here is the call graph for this function:

commit() [1/3]

void SWC::client::Query::Update::Handlers::Base::commit ( )

inline

Definition at line 167 of file Base.h.

References completion, SWC::Core::CompletionCounter< CountT >::increment(), next(), and response().

Referenced by commit(), SWC::client::Query::Update::Handlers::Common::commit_if_need(), SWC::client::Query::Update::Handlers::Common::commit_or_wait(), SWC::Ranger::Query::Update::BaseMeta::is_last_rsp(), SWC::DB::RgrData::BaseUpdater::remove_rgr(), SWC::client::Query::Update::Handlers::Metric::Reporting::report(), SWC::client::Query::Update::Handlers::Common::response(), SWC::client::Query::Update::Handlers::Metric::Reporting::response(), SWC::DB::RgrData::BaseUpdater::response(), and SWC::DB::RgrData::BaseUpdater::set_rgr().

Here is the call graph for this function:

Here is the caller graph for this function:

commit() [2/3]

void SWC::client::Query::Update::Handlers::Base::commit ( Column *  colp )

inline

Definition at line 181 of file Base.h.

References _execute(), completion, SWC::client::Query::Update::Handlers::Base::Column::empty(), SWC::Core::CompletionCounter< CountT >::increment(), and response().

Here is the call graph for this function:

commit() [3/3]

SWC_CAN_INLINE void SWC::client::Query::Update::Handlers::Base::commit ( const cid_t  cid )

inline

Definition at line 177 of file Base.h.

References commit(), and next().

Here is the call graph for this function:

default_executor()

void SWC::client::Query::Update::Handlers::Base::default_executor ( Column *  colp )

private

Definition at line 17 of file Base.cc.

References SWC::client::Clients::BROKER, SWC::client::Clients::DEFAULT, SWC::client::Query::Update::BrokerCommitter::execute(), SWC::client::Query::Update::Committer::execute(), executor, 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:

empty()

virtual bool SWC::client::Query::Update::Handlers::Base::empty ( )

pure virtualnoexcept

Implemented in SWC::client::Query::Update::Handlers::BaseUnorderedMap, and SWC::client::Query::Update::Handlers::BaseSingleColumn.

error() [1/3]

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

inlinevirtualnoexcept

Reimplemented in SWC::client::Query::Update::Handlers::Common, SWC::client::Query::Update::Handlers::Common, and SWC::client::Query::Update::Handlers::Common.

Definition at line 147 of file Base.h.

Referenced by SWC::Ranger::Range::MetaRegOnLoadReq::callback(), SWC::Ranger::Range::MetaRegOnAddReq::callback(), SWC::client::Query::Update::Handlers::BaseSingleColumn::error(), SWC::Ranger::Query::Update::BaseMeta::is_last_rsp(), SWC::client::Query::Update::Handlers::BaseSingleColumn::requires_commit(), SWC::Comm::Protocol::Bkr::Handler::Updater::response(), SWC::client::Query::Update::Handlers::Metric::Reporting::response(), SWC::DB::RgrData::BaseUpdater::response(), SWC::Comm::Protocol::Bkr::Handler::Updater::valid(), and SWC::Ranger::Query::Update::BaseMeta::valid().

Here is the caller graph for this function:

error() [2/3]

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

pure virtualnoexcept

Implemented in SWC::client::Query::Update::Handlers::BaseUnorderedMap, and SWC::client::Query::Update::Handlers::BaseSingleColumn.

error() [3/3]

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

inlinevirtualnoexcept

Definition at line 151 of file Base.h.

get_resend_count()

SWC_CAN_INLINE size_t SWC::client::Query::Update::Handlers::Base::get_resend_count ( bool  reset = true )

inlinenoexcept

Definition at line 163 of file Base.h.

References SWC::Core::AtomicBase< T, OrderT >::exchange(), SWC::Core::AtomicBase< T, OrderT >::load(), m_resend_cells, and reset().

Here is the call graph for this function:

next() [1/2]

virtual Column* SWC::client::Query::Update::Handlers::Base::next ( cid_t  cid )

pure virtualnoexcept

Implemented in SWC::client::Query::Update::Handlers::BaseUnorderedMap, and SWC::client::Query::Update::Handlers::BaseSingleColumn.

next() [2/2]

virtual void SWC::client::Query::Update::Handlers::Base::next ( Colms &  cols )

pure virtualnoexcept

Implemented in SWC::client::Query::Update::Handlers::BaseUnorderedMap, and SWC::client::Query::Update::Handlers::BaseSingleColumn.

Referenced by commit().

Here is the caller graph for this function:

requires_commit()

virtual bool SWC::client::Query::Update::Handlers::Base::requires_commit ( )

pure virtualnoexcept

Implemented in SWC::client::Query::Update::Handlers::Common, SWC::client::Query::Update::Handlers::BaseUnorderedMap, and SWC::client::Query::Update::Handlers::BaseSingleColumn.

response()

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

pure virtual

Implemented in SWC::Ranger::Range::MetaRegOnAddReq, SWC::Ranger::Range::MetaRegOnLoadReq, SWC::Ranger::Query::Update::CommonMeta, SWC::DB::RgrData::BaseUpdater, SWC::client::Query::Update::Handlers::Metric::Reporting, SWC::client::Query::Update::Handlers::Common, and SWC::Comm::Protocol::Bkr::Handler::Updater.

Referenced by commit().

Here is the caller graph for this function:

size_bytes()

virtual size_t SWC::client::Query::Update::Handlers::Base::size_bytes ( )

pure virtualnoexcept

Implemented in SWC::client::Query::Update::Handlers::BaseUnorderedMap, and SWC::client::Query::Update::Handlers::BaseSingleColumn.

valid()

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

pure virtualnoexcept

Implemented in SWC::Ranger::Query::Update::BaseMeta, SWC::DB::RgrData::BaseUpdater, SWC::client::Query::Update::Handlers::Metric::Reporting, SWC::client::Query::Update::Handlers::Common, and SWC::Comm::Protocol::Bkr::Handler::Updater.

Member Data Documentation

buff_ahead

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

Definition at line 113 of file Base.h.

Referenced by SWC::client::Query::Update::Handlers::Common::wait_ahead_buffers().

buff_sz

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

Definition at line 112 of file Base.h.

Referenced by SWC::client::Query::Update::Handlers::Base::Column::get_buff(), and SWC::client::Query::Update::Handlers::Common::wait_ahead_buffers().

clients

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

Definition at line 105 of file Base.h.

Referenced by SWC::client::Query::Update::Handlers::Common::make(), and SWC::client::Query::Update::Handlers::Common::response().

completion

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

Definition at line 108 of file Base.h.

Referenced by commit(), SWC::client::Query::Update::Handlers::Common::commit_if_need(), SWC::Ranger::Query::Update::BaseMeta::is_last_rsp(), SWC::Comm::Protocol::Bkr::Handler::Updater::response(), SWC::client::Query::Update::Handlers::Common::response(), SWC::client::Query::Update::Handlers::Metric::Reporting::response(), SWC::DB::RgrData::BaseUpdater::response(), SWC::client::Query::Update::Handlers::Common::wait(), SWC::client::Query::Update::Handlers::Metric::Reporting::wait(), and SWC::client::Query::Update::Handlers::Common::wait_ahead_buffers().

executor

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

Definition at line 114 of file Base.h.

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

m_resend_cells

Core::Atomic<size_t> SWC::client::Query::Update::Handlers::Base::m_resend_cells

private

Definition at line 200 of file Base.h.

Referenced by add_resend_count(), and get_resend_count().

profile

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

Definition at line 106 of file Base.h.

Referenced by SWC::Ranger::Query::Update::BaseMeta::is_last_rsp(), SWC::client::Query::Update::Handlers::Metric::Reporting::report(), SWC::Comm::Protocol::Bkr::Handler::Updater::response(), SWC::client::Query::Update::Handlers::Common::response(), SWC::client::Query::Update::Handlers::Metric::Reporting::response(), and SWC::DB::RgrData::BaseUpdater::response().

state_error

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

Definition at line 107 of file Base.h.

Referenced by SWC::client::Query::Update::Handlers::Common::error(), and SWC::client::Query::Update::Handlers::Metric::Reporting::response().

timeout

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

Definition at line 110 of file Base.h.

timeout_ratio

Core::Atomic<uint32_t> SWC::client::Query::Update::Handlers::Base::timeout_ratio

Definition at line 111 of file Base.h.

Referenced by Base().

---

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

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