|
SWC-DB
v0.5.12 C++ documentations
SWC-DB© (Super Wide Column Database) - High Performance Scalable Database (https://github.com/kashirin-alex/swc-db)
|
Go to the documentation of this file.
6 #ifndef swcdb_db_protocol_bkr_req_Committer_CellsUpdate_h
7 #define swcdb_db_protocol_bkr_req_Committer_CellsUpdate_h
15 namespace SWC {
namespace Comm {
namespace Protocol {
16 namespace Bkr {
namespace Req {
19 template<
typename DataT>
23 typedef std::shared_ptr<CellsUpdate>
Ptr;
26 template<
typename... DataArgsT>
31 const uint32_t timeout,
32 DataArgsT&&... args) {
39 template<
typename... DataArgsT>
44 const uint32_t timeout,
45 DataArgsT&&... args) {
47 return make(params, snd_buf, timeout, args...);
50 template<
typename... DataArgsT>
55 const uint32_t timeout,
56 DataArgsT&&... args) {
57 make(params, snd_buf, timeout, args...)->run();
60 template<
typename... DataArgsT>
65 const uint32_t timeout,
66 DataArgsT&&... args) {
67 make(params, buffer, timeout, args...)->run();
82 return data.valid() && !
data.get_clients()->stopping();
102 template<
typename... DataArgsT>
105 : client::ConnQueue::
ReqBase(std::move(a_cbp)),
145 #endif // swcdb_db_protocol_bkr_req_Committer_CellsUpdate_h
CellsUpdate(const CellsUpdate &)=delete
SWC_CAN_INLINE Ptr req() noexcept
std::shared_ptr< Buffers > Ptr
static SWC_CAN_INLINE void request(const Params::CellsUpdateReq ¶ms, const DynamicBuffer &buffer, const uint32_t timeout, DataArgsT &&... args)
Common::Req::function< std::function< void(void *, const client::ConnQueue::ReqBase::Ptr &, const Params::CellsUpdateRsp &)>> Functional_CellsUpdate
void handle(ConnHandlerPtr, const Event::Ptr &ev) override
Comm::client::ConnQueue::ReqBase ReqBase
void handle_no_conn() override
SWC_CAN_INLINE CellsUpdate(Buffers::Ptr &&a_cbp, DataArgsT &&... args)
CellsUpdate(CellsUpdate &&)=delete
static SWC_CAN_INLINE void request(const Params::CellsUpdateReq ¶ms, StaticBuffer &snd_buf, const uint32_t timeout, DataArgsT &&... args)
The SWC-DB C++ namespace 'SWC'.
SWC::client::Brokers::BrokerIdx _bkr_idx
static SWC_CAN_INLINE Ptr make(const Params::CellsUpdateReq ¶ms, const DynamicBuffer &buffer, const uint32_t timeout, DataArgsT &&... args)
std::shared_ptr< ConnHandler > ConnHandlerPtr
bool turn_around(Brokers &brks) noexcept
constexpr SWC_CAN_INLINE size_t fill() const noexcept
static SWC_CAN_INLINE Ptr make(const Params::CellsUpdateReq ¶ms, StaticBuffer &snd_buf, const uint32_t timeout, DataArgsT &&... args)
static SWC_CAN_INLINE Ptr make(uint32_t reserve=0)
CellsUpdate & operator=(const CellsUpdate &)=delete
CellsUpdate & operator=(CellsUpdate &&)=delete
std::shared_ptr< Event > Ptr
std::shared_ptr< ConnQueueReqBase > Ptr
std::shared_ptr< CellsUpdate > Ptr
virtual ~CellsUpdate() noexcept