RangeQueryUpdate.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_ranger_callbacks_RangeQueryUpdate_h
#define swcdb_ranger_callbacks_RangeQueryUpdate_h
 
 
#include "swcdb/db/Protocol/Rgr/params/RangeQueryUpdate.h"
 
 
namespace SWC { namespace Ranger { namespace Callback {
 
 
 
struct RangeQueryUpdate : Core::QueuePointer<RangeQueryUpdate*>::Pointer {
 
  Comm::ConnHandlerPtr  conn;
  Comm::Event::Ptr      ev;
  Comm::Protocol::Rgr::Params::RangeQueryUpdateRsp  rsp;
 
  SWC_CAN_INLINE
  RangeQueryUpdate(const Comm::ConnHandlerPtr& a_conn,
                   const Comm::Event::Ptr& a_ev)
                  : conn(a_conn), ev(a_ev), rsp(Error::OK) {
    Env::Rgr::res().more_mem_future(ev->data_ext.size);
  }
 
  SWC_CAN_INLINE
  ~RangeQueryUpdate() noexcept {
    Env::Rgr::res().less_mem_future(ev->data_ext.size);
  }
 
  SWC_CAN_INLINE
  bool expired() const {
    return ev->expired(ev->data_ext.size/100000) || !conn->is_open();
  }
 
  SWC_CAN_INLINE
  void response() {
    conn->send_response(Comm::Buffers::make(ev, rsp));
  }
 
 
};
 
 
 
}}}
 
 
#endif // swcdb_ranger_callbacks_RangeQueryUpdate_h