SWC-DB  v0.5.12 C++ documentations
SWC-DB© (Super Wide Column Database) - High Performance Scalable Database (https://github.com/kashirin-alex/swc-db)
Public Types | Public Member Functions | Static Public Member Functions | Public Attributes | Protected Member Functions | Private Attributes | List of all members
SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT > Class Template Referencefinal

#include <swcdb/db/Protocol/Bkr/req/CellsUpdate.h>

+ Inheritance diagram for SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >:
+ Collaboration diagram for SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >:

Public Types

typedef std::shared_ptr< CellsUpdate > Ptr
 
- Public Types inherited from SWC::Comm::client::ConnQueueReqBase
typedef std::shared_ptr< ConnQueueReqBase > Ptr
 
- Public Types inherited from SWC::Comm::DispatchHandler
typedef std::shared_ptr< DispatchHandler > Ptr
 

Public Member Functions

 CellsUpdate (CellsUpdate &&)=delete
 
 CellsUpdate (const CellsUpdate &)=delete
 
CellsUpdate & operator= (CellsUpdate &&)=delete
 
CellsUpdate & operator= (const CellsUpdate &)=delete
 
virtual ~CellsUpdate () noexcept
 
bool run () override
 
bool valid () override
 
void handle_no_conn () override
 
void handle (ConnHandlerPtr, const Event::Ptr &ev) override
 
- Public Member Functions inherited from SWC::Comm::client::ConnQueueReqBase
SWC_CAN_INLINE ConnQueueReqBase (Buffers::Ptr &&a_cbp) noexcept
 
SWC_CAN_INLINE ConnQueueReqBase (Buffers::Ptr &&a_cbp, const ConnQueuePtr &a_queue) noexcept
 
SWC_CAN_INLINE Ptr req () noexcept
 
virtual bool insistent () noexcept
 
void request_again ()
 
void print (std::ostream &out)
 

Static Public Member Functions

template<typename... DataArgsT>
static SWC_CAN_INLINE Ptr make (const Params::CellsUpdateReq &params, StaticBuffer &snd_buf, const uint32_t timeout, DataArgsT &&... args)
 
template<typename... DataArgsT>
static SWC_CAN_INLINE Ptr make (const Params::CellsUpdateReq &params, const DynamicBuffer &buffer, const uint32_t timeout, DataArgsT &&... args)
 
template<typename... DataArgsT>
static SWC_CAN_INLINE void request (const Params::CellsUpdateReq &params, StaticBuffer &snd_buf, const uint32_t timeout, DataArgsT &&... args)
 
template<typename... DataArgsT>
static SWC_CAN_INLINE void request (const Params::CellsUpdateReq &params, const DynamicBuffer &buffer, const uint32_t timeout, DataArgsT &&... args)
 

Public Attributes

DataT data
 
- Public Attributes inherited from SWC::Comm::client::ConnQueueReqBase
Buffers::Ptr cbp
 
ConnQueuePtr queue
 

Protected Member Functions

template<typename... DataArgsT>
SWC_CAN_INLINE CellsUpdate (Buffers::Ptr &&a_cbp, DataArgsT &&... args)
 
- Protected Member Functions inherited from SWC::Comm::client::ConnQueueReqBase
virtual ~ConnQueueReqBase () noexcept
 
- Protected Member Functions inherited from SWC::Comm::DispatchHandler
virtual ~DispatchHandler () noexcept
 

Private Attributes

SWC::client::Brokers::BrokerIdx _bkr_idx
 

Detailed Description

template<typename DataT>
class SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >

Definition at line 20 of file CellsUpdate.h.

Member Typedef Documentation

◆ Ptr

template<typename DataT >
typedef std::shared_ptr<CellsUpdate> SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::Ptr

Definition at line 23 of file CellsUpdate.h.

Constructor & Destructor Documentation

◆ CellsUpdate() [1/3]

template<typename DataT >
SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::CellsUpdate ( CellsUpdate< DataT > &&  )
delete

Referenced by SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::make().

+ Here is the caller graph for this function:

◆ CellsUpdate() [2/3]

template<typename DataT >
SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::CellsUpdate ( const CellsUpdate< DataT > &  )
delete

◆ ~CellsUpdate()

template<typename DataT >
virtual SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::~CellsUpdate ( )
inlinevirtualnoexcept

Definition at line 75 of file CellsUpdate.h.

◆ CellsUpdate() [3/3]

template<typename DataT >
template<typename... DataArgsT>
SWC_CAN_INLINE SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::CellsUpdate ( Buffers::Ptr &&  a_cbp,
DataArgsT &&...  args 
)
inlineprotected

Definition at line 104 of file CellsUpdate.h.

Member Function Documentation

◆ handle()

template<typename DataT >
void SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::handle ( ConnHandlerPtr  ,
const Event::Ptr &  ev 
)
inlineoverridevirtual

Implements SWC::Comm::DispatchHandler.

Definition at line 93 of file CellsUpdate.h.

References SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::data, and SWC::Comm::client::ConnQueueReqBase::req().

+ Here is the call graph for this function:

◆ handle_no_conn()

template<typename DataT >
void SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::handle_no_conn ( )
inlineoverridevirtual

Implements SWC::Comm::DispatchHandler.

Definition at line 85 of file CellsUpdate.h.

References SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::_bkr_idx, SWC::Error::COMM_NOT_CONNECTED, SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::data, SWC::Comm::client::ConnQueueReqBase::req(), SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::run(), and SWC::client::Brokers::BrokerIdx::turn_around().

+ Here is the call graph for this function:

◆ make() [1/2]

template<typename DataT >
template<typename... DataArgsT>
static SWC_CAN_INLINE Ptr SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::make ( const Params::CellsUpdateReq &  params,
const DynamicBuffer &  buffer,
const uint32_t  timeout,
DataArgsT &&...  args 
)
inlinestatic

Definition at line 41 of file CellsUpdate.h.

References SWC::Core::Buffer< T >::base, SWC::Core::BufferDyn< BufferT >::fill(), and SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::make().

+ Here is the call graph for this function:

◆ make() [2/2]

template<typename DataT >
template<typename... DataArgsT>
static SWC_CAN_INLINE Ptr SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::make ( const Params::CellsUpdateReq &  params,
StaticBuffer &  snd_buf,
const uint32_t  timeout,
DataArgsT &&...  args 
)
inlinestatic

Definition at line 28 of file CellsUpdate.h.

References SWC::Comm::Protocol::Bkr::CELLS_UPDATE, SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::CellsUpdate(), and SWC::Comm::Buffers::make().

Referenced by SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::make(), and SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::request().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ operator=() [1/2]

template<typename DataT >
CellsUpdate& SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::operator= ( CellsUpdate< DataT > &&  )
delete

◆ operator=() [2/2]

template<typename DataT >
CellsUpdate& SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::operator= ( const CellsUpdate< DataT > &  )
delete

◆ request() [1/2]

template<typename DataT >
template<typename... DataArgsT>
static SWC_CAN_INLINE void SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::request ( const Params::CellsUpdateReq &  params,
const DynamicBuffer &  buffer,
const uint32_t  timeout,
DataArgsT &&...  args 
)
inlinestatic

Definition at line 62 of file CellsUpdate.h.

References SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::make().

+ Here is the call graph for this function:

◆ request() [2/2]

template<typename DataT >
template<typename... DataArgsT>
static SWC_CAN_INLINE void SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::request ( const Params::CellsUpdateReq &  params,
StaticBuffer &  snd_buf,
const uint32_t  timeout,
DataArgsT &&...  args 
)
inlinestatic

Definition at line 52 of file CellsUpdate.h.

References SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::make().

Referenced by SWC::client::Query::Update::BrokerCommitter::commit().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ run()

template<typename DataT >
bool SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::run ( )
inlineoverridevirtual

Reimplemented from SWC::Comm::DispatchHandler.

Definition at line 77 of file CellsUpdate.h.

References SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::_bkr_idx, SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::data, and SWC::Comm::client::ConnQueueReqBase::req().

Referenced by SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::handle_no_conn().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ valid()

template<typename DataT >
bool SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::valid ( )
inlineoverridevirtual

Reimplemented from SWC::Comm::DispatchHandler.

Definition at line 81 of file CellsUpdate.h.

References SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::data.

Member Data Documentation

◆ _bkr_idx

template<typename DataT >
SWC::client::Brokers::BrokerIdx SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::_bkr_idx
private

Definition at line 110 of file CellsUpdate.h.

Referenced by SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::handle_no_conn(), and SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::run().

◆ data

template<typename DataT >
DataT SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::data

Definition at line 24 of file CellsUpdate.h.

Referenced by SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::handle(), SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::handle_no_conn(), SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::run(), and SWC::Comm::Protocol::Bkr::Req::CellsUpdate< DataT >::valid().

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