geode-client-native/src/tests/testobject/PSTObject.cpp

/*=========================================================================
 * Copyright (c) 2010-2014 Pivotal Software, Inc. All Rights Reserved.
 * This product is protected by U.S. and international copyright
 * and intellectual property laws. Pivotal products are covered by
 * one or more patents listed at http://www.pivotal.io/patents.
 *=========================================================================
 */
#include "PSTObject.hpp"
#include "fwklib/GsRandom.hpp"
#include "ArrayOfByte.hpp"

using namespace gemfire;
using namespace testframework;
using namespace testobject;

PSTObject::PSTObject(int size, bool encodeKey,bool encodeTimestamp)
{
  ACE_Time_Value startTime;
  startTime = ACE_OS::gettimeofday();
  ACE_UINT64 tusec = 0;
  startTime.to_usec(tusec);
  timestamp = tusec*1000;
  field1 = 1234;
  field2 = '*';
  if(size == 0 ) {
    valueData = NULLPTR;
  }else {
    encodeKey = true;
    valueData = ArrayOfByte::init(size,encodeKey,false);
  }
}

PSTObject::~PSTObject() {
}
void PSTObject::toData( gemfire::DataOutput& output ) const {
  output.writeInt((int64_t)timestamp);
  output.writeInt((int32_t)field1);
  output.write(field2);
  output.writeObject(valueData);
}

gemfire::Serializable* PSTObject::fromData( gemfire::DataInput& input ){
  input.readInt((int64_t*)&timestamp);
  input.readInt((int32_t*)&field1);
  input.read(&field2);
  input.readObject(valueData);
  return this;
}
CacheableStringPtr PSTObject::toString() const {
  char buf[102500];
  sprintf(buf, "PSTObject:[timestamp = %lld field1 = %d field2 = %c valueData=%d ]", timestamp,field1,field2,valueData->length());
  return CacheableString::create( buf );
}