SWC-DB  v0.5.9 C++ documentations
SWC-DB© (Super Wide Column Database) - High Performance Scalable Database (https://github.com/kashirin-alex/swc-db)
SWC::client::Query::Update::BrokerCommitter Class Referencefinal

#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< BrokerCommitterPtr
 

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::Columncolp
 
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

Definition at line 31 of file BrokerCommitter.h.

Constructor & Destructor Documentation

◆ BrokerCommitter()

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()

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

◆ 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:

◆ 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: