PhantomUpdate.cc

Go to the documentation of this file.

#include <Common/Compat.h>

#include "PhantomUpdate.h"

#include <AsyncComm/CommBuf.h>
#include <AsyncComm/CommHeader.h>

#include <Common/Error.h>

using namespace Hypertable;
using namespace Hypertable::RangeServer::Response::Callback;
using namespace std;

int PhantomUpdate::response() {
  CommHeader header;
  header.initialize_from_request_header(m_event->header);
  size_t len = m_range.encoded_length() + 4 + 4;
  CommBufPtr cbp(new CommBuf(header, len));
  cbp->append_i32(Error::OK);
  m_range.encode(cbp->get_data_ptr_address());
  cbp->append_i32(m_fragment);
  return m_comm->send_response(m_event->addr, cbp);
}

int PhantomUpdate::response_ok() {
  return response();
}

int PhantomUpdate::error(int error, const String &msg) {
  CommHeader header;
  header.initialize_from_request_header(m_event->header);
  CommBufPtr cbp;
  String message;
  size_t max_msg_size = std::numeric_limits<int16_t>::max();
  size_t len = 4 + m_range.encoded_length() + 4;

  if (msg.length() < max_msg_size) {
    len += Serialization::encoded_length_str16(msg);
    cbp = make_shared<CommBuf>(header, len);
    cbp->append_i32(error);
    cbp->append_str16(msg.c_str());
  }
  else {
    String substr = msg.substr(0, max_msg_size);
    len += Serialization::encoded_length_str16(substr);
    cbp = make_shared<CommBuf>(header, len);
    cbp->append_i32(error);
    cbp->append_str16(substr.c_str());
  }
  m_range.encode(cbp->get_data_ptr_address());
  cbp->append_i32(m_fragment);

  return m_comm->send_response(m_event->addr, cbp);
}