RangeMoveSpec.cc

Go to the documentation of this file.

#include "Common/Compat.h"
#include "Common/Serialization.h"

#include <cstring>
#include <iostream>

#include "KeySpec.h"
#include "RangeMoveSpec.h"

using namespace std;
using namespace Hypertable;

uint8_t RangeMoveSpec::encoding_version() const {
  return 1;
}

size_t RangeMoveSpec::encoded_length_internal() const {
  return table.encoded_length() + range.encoded_length() +
    Serialization::encoded_length_vstr(source_location) +
    Serialization::encoded_length_vstr(dest_location) + 5;
}

void RangeMoveSpec::encode_internal(uint8_t **bufp) const {
  table.encode(bufp);
  range.encode(bufp);
  Serialization::encode_vstr(bufp, source_location);
  Serialization::encode_vstr(bufp, dest_location);
  Serialization::encode_i32(bufp, error);
  Serialization::encode_bool(bufp, complete);
}

void RangeMoveSpec::decode_internal(uint8_t version, const uint8_t **bufp,
                                      size_t *remainp) {
  table.decode(bufp, remainp);
  range.decode(bufp, remainp);
  source_location = Serialization::decode_vstr(bufp, remainp);
  dest_location = Serialization::decode_vstr(bufp, remainp);
  error = Serialization::decode_i32(bufp, remainp);
  complete = Serialization::decode_bool(bufp, remainp);
}

ostream &Hypertable::operator<<(ostream &os, const RangeMoveSpec &move_spec) {
  os <<"{RangeMoveSpec: " << move_spec.table << " " << move_spec.range
     <<" source_location="<< move_spec.source_location
     <<" dest_location="<< move_spec.dest_location
     <<" error='" << Error::get_text(move_spec.error)
     << "' complete=" << (move_spec.complete ? "true" : "false") << "}";
  return os;
}