#include <swcdb/db/client/Query/Update/BrokerCommitter.h>
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 () 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) |
Definition at line 20 of file BrokerCommitter.h.
typedef std::shared_ptr<BrokerCommitter> SWC::client::Query::Update::BrokerCommitter::Ptr |
Definition at line 31 of file BrokerCommitter.h.
|
inlinenoexcept |
Definition at line 37 of file BrokerCommitter.h.
Referenced by execute().
|
noexcept |
Definition at line 22 of file BrokerCommitter.cc.
|
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().
|
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.
|
inlinestatic |
Definition at line 25 of file BrokerCommitter.h.
References BrokerCommitter(), colp, and hdlr.
Referenced by SWC::client::Query::Update::Handlers::Base::default_executor().
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.
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().
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().
Core::CompletionCounter SWC::client::Query::Update::BrokerCommitter::workload |
Definition at line 34 of file BrokerCommitter.h.
Referenced by commit(), and committed().