RangeReplayBuffer.cc

Go to the documentation of this file.

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

using namespace std;
using namespace Hypertable;
using namespace Hypertable::Property;

size_t RangeReplayBuffer::add(SerializedKey &key, ByteString &value) {
  const uint8_t *ptr = key.ptr;
  size_t len = Serialization::decode_vi32(&ptr);
  size_t incr_mem = m_accum.fill();
  m_accum.add(key.ptr, (ptr-key.ptr)+len);
  m_accum.add(value.ptr, value.length());
  incr_mem = m_accum.fill() - incr_mem;
  return incr_mem;
}

void RangeReplayBuffer::clear() {
  m_accum.clear();
}