SWC::client::Query::Update::BrokerCommitter Class Reference

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

Inheritance diagram for SWC::client::Query::Update::BrokerCommitter:

Collaboration diagram for SWC::client::Query::Update::BrokerCommitter:

Public Types
typedef std::shared_ptr< BrokerCommitter >	Ptr

Public Member Functions
SWC_CAN_INLINE	BrokerCommitter (const Query::Update::Handlers::Base::Ptr &a_hdlr, Query::Update::Handlers::Base::Column *a_colp) noexcept
	BrokerCommitter (const BrokerCommitter &)=delete
BrokerCommitter &	operator= (const BrokerCommitter &)=delete
	~BrokerCommitter () noexcept
void	print (std::ostream &out)

Static Public Member Functions
static SWC_CAN_INLINE void	execute (const Handlers::Base::Ptr &hdlr, Handlers::Base::Column *colp)

Public Attributes
Query::Update::Handlers::Base::Ptr	hdlr
Query::Update::Handlers::Base::Column *	colp
Core::CompletionCounter	workload

Private Member Functions
void	commit ()
void	committed (ReqBase::Ptr req, const Comm::Protocol::Bkr::Params::CellsUpdateRsp &rsp, const DynamicBuffer &cells_buff)

Detailed Description

Definition at line 20 of file BrokerCommitter.h.

Member Typedef Documentation

Ptr

typedef std::shared_ptr<BrokerCommitter> SWC::client::Query::Update::BrokerCommitter::Ptr

Definition at line 31 of file BrokerCommitter.h.

Constructor & Destructor Documentation

BrokerCommitter() [1/2]

SWC_CAN_INLINE SWC::client::Query::Update::BrokerCommitter::BrokerCommitter ( const Query::Update::Handlers::Base::Ptr &  a_hdlr, Query::Update::Handlers::Base::Column *  a_colp  )

inlinenoexcept

Definition at line 37 of file BrokerCommitter.h.

Referenced by execute().

Here is the caller graph for this function:

BrokerCommitter() [2/2]

SWC::client::Query::Update::BrokerCommitter::BrokerCommitter ( const BrokerCommitter &  )

delete

~BrokerCommitter()

SWC::client::Query::Update::BrokerCommitter::~BrokerCommitter ( )

noexcept

Definition at line 22 of file BrokerCommitter.cc.

Member Function Documentation

commit()

void SWC::client::Query::Update::BrokerCommitter::commit ( )

private

Definition at line 30 of file BrokerCommitter.cc.

References SWC::client::Query::Profiling::Component::Start::add(), colp, SWC::Comm::Protocol::Bkr::Params::CellsUpdateRsp::err, SWC::Core::BufferDyn< BufferT >::fill(), SWC::client::Query::Update::Handlers::Base::Column::get_buff(), SWC::client::Query::Update::Handlers::Base::Column::get_cid(), hdlr, SWC::Core::CompletionCounter< CountT >::increment(), SWC::Core::CompletionCounter< CountT >::is_last(), SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::request(), SWC_CAN_INLINE, and workload.

Referenced by committed().

Here is the call graph for this function:

Here is the caller graph for this function:

committed()

void SWC::client::Query::Update::BrokerCommitter::committed ( ReqBase::Ptr  req, const Comm::Protocol::Bkr::Params::CellsUpdateRsp &  rsp, const DynamicBuffer &  cells_buff  )

private

Definition at line 85 of file BrokerCommitter.cc.

References SWC::client::Query::Update::Handlers::Base::Column::add(), SWC::Error::CLIENT_STOPPING, colp, SWC::Error::COLUMN_NOT_EXISTS, SWC::Error::COMM_NOT_CONNECTED, commit(), SWC::Comm::Protocol::Bkr::Params::CellsUpdateRsp::err, SWC::client::Query::Update::Handlers::Base::Column::get_cid(), hdlr, SWC::Core::CompletionCounter< CountT >::is_last(), SWC::Error::OK, SWC::Error::REQUEST_TIMEOUT, SWC_BROKER_COMMIT_RSP_DEBUG, and workload.

Here is the call graph for this function:

execute()

static SWC_CAN_INLINE void SWC::client::Query::Update::BrokerCommitter::execute ( const Handlers::Base::Ptr &  hdlr, Handlers::Base::Column *  colp  )

inlinestatic

Definition at line 25 of file BrokerCommitter.h.

References BrokerCommitter(), colp, and hdlr.

Referenced by SWC::client::Query::Update::Handlers::Base::default_executor().

Here is the call graph for this function:

Here is the caller graph for this function:

operator=()

BrokerCommitter& SWC::client::Query::Update::BrokerCommitter::operator= ( const BrokerCommitter &  )

delete

print()

void SWC::client::Query::Update::BrokerCommitter::print

(

std::ostream &

out

)

Definition at line 24 of file BrokerCommitter.cc.

References colp, SWC::client::Query::Update::Handlers::Base::Column::get_cid(), and hdlr.

Here is the call graph for this function:

Member Data Documentation

colp

Query::Update::Handlers::Base::Column* SWC::client::Query::Update::BrokerCommitter::colp

Definition at line 33 of file BrokerCommitter.h.

Referenced by commit(), committed(), execute(), and print().

hdlr

Query::Update::Handlers::Base::Ptr SWC::client::Query::Update::BrokerCommitter::hdlr

Definition at line 32 of file BrokerCommitter.h.

Referenced by commit(), committed(), execute(), and print().

workload

Core::CompletionCounter SWC::client::Query::Update::BrokerCommitter::workload

Definition at line 34 of file BrokerCommitter.h.

Referenced by commit(), and committed().

---

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

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