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

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

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

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

Public Types
typedef std::shared_ptr< Updater >	Ptr
Public Types inherited from SWC::client::Query::Update::Handlers::BaseSingleColumn
typedef std::shared_ptr< BaseSingleColumn >	Ptr
Public Types inherited from SWC::client::Query::Update::Handlers::Base
typedef std::shared_ptr< Base >	Ptr
typedef Core::Vector< Column * >	Colms

Public Member Functions
SWC_CAN_INLINE	Updater (const DB::Schema::Ptr &schema, const ConnHandlerPtr &a_conn, const Event::Ptr &a_ev)
virtual	~Updater () noexcept
bool	valid () noexcept override
void	response (int err=Error::OK) override
Public Member Functions inherited from SWC::client::Query::Update::Handlers::BaseSingleColumn
SWC_CAN_INLINE	BaseSingleColumn (const Clients::Ptr &a_clients, const cid_t cid, DB::Types::KeySeq seq, uint32_t versions, uint32_t ttl_secs, DB::Types::Column type, Clients::Flag a_executor=Clients::DEFAULT)
SWC_CAN_INLINE	BaseSingleColumn (const Clients::Ptr &a_clients, const cid_t cid, DB::Types::KeySeq seq, uint32_t versions, uint32_t ttl_secs, DB::Types::Column type, const StaticBuffer &buffer)
virtual	~BaseSingleColumn () noexcept
virtual bool	requires_commit () noexcept override
virtual bool	empty () noexcept override
virtual size_t	size_bytes () noexcept override
virtual void	next (Base::Colms &cols) noexcept override
virtual Base::Column *	next (cid_t cid) noexcept override
virtual void	error (cid_t cid, int err) noexcept override
SWC_CAN_INLINE size_t	size () noexcept
Public Member Functions inherited from SWC::client::Query::Update::Handlers::Base
SWC_CAN_INLINE	Base (const Clients::Ptr &a_clients, Clients::Flag a_executor=Clients::Flag::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	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
ConnHandlerPtr	conn
Event::Ptr	ev
Public Attributes inherited from SWC::client::Query::Update::Handlers::BaseSingleColumn
ColumnMutable	column
Public Attributes inherited from SWC::client::Query::Update::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 >	timeout_ratio
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::Update::Handlers::Base
virtual void	_execute (Column *colp)
virtual	~Base () noexcept

Detailed Description

Definition at line 20 of file CellsUpdate.h.

Member Typedef Documentation

Ptr

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

Definition at line 23 of file CellsUpdate.h.

Constructor & Destructor Documentation

Updater()

SWC_CAN_INLINE SWC::Comm::Protocol::Bkr::Handler::Updater::Updater ( const DB::Schema::Ptr &  schema, const ConnHandlerPtr &  a_conn, const Event::Ptr &  a_ev  )

inline

Definition at line 29 of file CellsUpdate.h.

References ev.

~Updater()

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

inlinevirtualnoexcept

Definition at line 41 of file CellsUpdate.h.

Member Function Documentation

response()

void SWC::Comm::Protocol::Bkr::Handler::Updater::response ( int  err = Error::OK )

inlineoverridevirtual

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

Definition at line 48 of file CellsUpdate.h.

References SWC::client::Query::Update::Handlers::ColumnMutable::cid, SWC::Error::CLIENT_DATA_REMAINED, SWC::Error::CLIENT_STOPPING, SWC::client::Query::Update::Handlers::BaseSingleColumn::column, SWC::client::Query::Update::Handlers::Base::completion, conn, SWC::client::Query::Update::Handlers::BaseSingleColumn::empty(), SWC::client::Query::Update::Handlers::Base::error(), ev, SWC::client::Query::Profiling::finished(), SWC::Env::Bkr::is_accepting(), SWC::Core::CompletionCounter< CountT >::is_last(), SWC::LOG_DEBUG, SWC::Comm::Buffers::make(), SWC::Env::Bkr::post(), SWC::client::Query::Profiling::print(), SWC::Error::print(), SWC::Env::Bkr::processed(), SWC::client::Query::Update::Handlers::Base::profile, SWC::client::Query::Update::Handlers::BaseSingleColumn::requires_commit(), SWC::Error::SERVER_SHUTTING_DOWN, SWC_CAN_INLINE, SWC_LOG_OSTREAM, and SWC_LOG_OUT.

Here is the call graph for this function:

valid()

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

inlineoverridevirtualnoexcept

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

Definition at line 43 of file CellsUpdate.h.

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

Here is the call graph for this function:

Member Data Documentation

conn

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

Definition at line 25 of file CellsUpdate.h.

Referenced by response(), and valid().

ev

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

Definition at line 26 of file CellsUpdate.h.

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

---

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

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