ColumnCompact_Sync.h

Go to the documentation of this file.

/*
 * SWC-DB© Copyright since 2019 Alex Kashirin <kashirin.alex@gmail.com>
 * License details at <https://github.com/kashirin-alex/swc-db/#license>
 */
 
#ifndef swcdb_db_protocol_bkr_req_ColumnCompact_Sync_h
#define swcdb_db_protocol_bkr_req_ColumnCompact_Sync_h
 
 
#include "swcdb/db/Protocol/Bkr/req/ColumnCompact.h"
#include "swcdb/core/StateSynchronization.h"
 
 
namespace SWC { namespace Comm { namespace Protocol {
namespace Bkr { namespace Req {
 
 
class ColumnCompact_Sync {
  public:
 
  template<typename... DataArgsT>
  SWC_CAN_INLINE
  static std::shared_ptr<ColumnCompact<ColumnCompact_Sync>>
  make(const Mngr::Params::ColumnCompactReq& params,
       const uint32_t timeout,
       DataArgsT&&... args) {
    return ColumnCompact<ColumnCompact_Sync>::make(params, timeout, args...);
  }
 
  template<typename... DataArgsT>
  SWC_CAN_INLINE
  static void request(const Mngr::Params::ColumnCompactReq& params,
                      const uint32_t timeout,
                      DataArgsT&&... args) {
    auto req = make(params, timeout, args...);
    req->run();
    req->data.await.wait();
  }
 
  template<typename... DataArgsT>
  SWC_CAN_INLINE
  static void request(cid_t cid,
                      const uint32_t timeout,
                      DataArgsT&&... args) {
    request(Mngr::Params::ColumnCompactReq(cid), timeout, args...);
  }
 
  Core::StateSynchronization        await;
 
  SWC_CAN_INLINE
  ColumnCompact_Sync(const SWC::client::Clients::Ptr& a_clients,
                     int& a_err) noexcept
                    : await(),
                      clients(a_clients), err(a_err) {
  }
 
  ~ColumnCompact_Sync() noexcept { }
 
  SWC_CAN_INLINE
  SWC::client::Clients::Ptr& get_clients() noexcept {
    return clients;
  }
 
  SWC_CAN_INLINE
  bool valid() {
    return true;
  }
 
  SWC_CAN_INLINE
  void callback(const client::ConnQueue::ReqBase::Ptr&,
                const Mngr::Params::ColumnCompactRsp& rsp) {
    err = rsp.err;
    await.acknowledge();
  }
 
  private:
  SWC::client::Clients::Ptr clients;
  int&                       err;
 
};
 
 
 
}}}}}
 
 
 
#endif // swcdb_db_protocol_bkr_req_ColumnCompact_Sync_h