ColumnUpdate.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_manager_Protocol_mngr_req_ColumnUpdate_h
#define swcdb_manager_Protocol_mngr_req_ColumnUpdate_h
 
#include "swcdb/db/Protocol/Mngr/params/ColumnMng.h"
#include "swcdb/manager/Protocol/Mngr/params/ColumnUpdate.h"
 
namespace SWC { namespace Comm { namespace Protocol {
namespace Mngr { namespace Req {
 
class ColumnUpdate : public client::ConnQueue::ReqBase {
  public:
  typedef std::shared_ptr<ColumnUpdate> Ptr;
 
  SWC_CAN_INLINE
  ColumnUpdate(Params::ColumnMng::Function function,
               const DB::Schema::Ptr& schema,
               int err, uint64_t id)
              : client::ConnQueue::ReqBase(
                  Buffers::make(
                    Params::ColumnUpdate(function, schema, err, id),
                    0,
                    COLUMN_UPDATE, 60000
                  )) {
  }
 
  SWC_CAN_INLINE
  ColumnUpdate(cid_t cid_begin, cid_t cid_end, uint64_t total,
               cids_t&& columns)
              : client::ConnQueue::ReqBase(
                  Buffers::make(
                    Params::ColumnUpdate(
                      Params::ColumnMng::Function::INTERNAL_EXPECT,
                      cid_begin, cid_end, total, std::move(columns)
                    ),
                    0,
                    COLUMN_UPDATE, 60000
                  )
                ) {
  }
 
  ColumnUpdate(ColumnUpdate&&) = delete;
  ColumnUpdate(const ColumnUpdate&) = delete;
  ColumnUpdate& operator=(ColumnUpdate&&) = delete;
  ColumnUpdate& operator=(const ColumnUpdate&) = delete;
 
  virtual ~ColumnUpdate() noexcept { }
 
  bool insistent() noexcept override { return true; }
 
  void handle_no_conn() override { }
 
  void handle(ConnHandlerPtr conn, const Event::Ptr& ev) override {
    if(ev->response_code()) {
      conn->do_close();
      request_again();
    }
  }
 
};
 
}}}}}
 
#endif // swcdb_manager_Protocol_mngr_req_ColumnUpdate_h