/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package javaobject;

import org.apache.geode.DataSerializable;
import org.apache.geode.Delta;
import org.apache.geode.DataSerializer;
import org.apache.geode.Instantiator;
import org.apache.geode.InvalidDeltaException;
import org.apache.geode.cache.util.ObjectSizer;
import org.apache.geode.cache.Declarable;
import org.apache.geode.internal.NanoTimer;
import org.apache.geode.*;
import java.io.*;
import java.util.*;


public class DeltaPSTObject implements Declarable,Serializable, DataSerializable, Delta, Cloneable
{
	private long timestamp;
	private int field1;
	private char field2;
	private byte[] byteArray;
	
	static {
	     Instantiator.register(new Instantiator(DeltaPSTObject.class, (byte) 42) {
	       public DataSerializable newInstance() {
	           return new DeltaPSTObject();
	       }
	    });
	  }

	  public void init(Properties props) {
	    this.field1 = Integer.parseInt(props.getProperty("field1"));
	  }

 public DeltaPSTObject() {
 }
 // no need to write init or other constructor . 
 // we just need to register the PSTObject/ DeltaPSTObject at server side via cache xml.
	  public boolean equals(Object o) {
	    if (o instanceof DeltaPSTObject) {
	    	DeltaPSTObject other = (DeltaPSTObject) o;
	      if (this.timestamp == other.timestamp) {
		if ((this.field1 == other.field1) &&
		    (this.field2 == other.field2) ) {
		  return true;
		}
	      }
	    }

	    return false;
	  }

	  // ObjectSizer
	  public int sizeof(Object o) {
	    if (o instanceof DeltaPSTObject) {
	    	DeltaPSTObject obj = (DeltaPSTObject)o;
	      return ObjectSizer.DEFAULT.sizeof(obj.timestamp)
	                   + ObjectSizer.DEFAULT.sizeof(obj.field1)
	                   + ObjectSizer.DEFAULT.sizeof(obj.field2)
	                   + ObjectSizer.DEFAULT.sizeof(obj.byteArray);
	    } else {
	      return ObjectSizer.DEFAULT.sizeof(o);
	    }
	  }

	  // DataSerializable
	  public void toData( DataOutput out )
	  throws IOException {
	    out.writeLong( this.timestamp );
	    out.writeInt( this.field1 );
	    out.writeChar( this.field2 );
	    DataSerializer.writeByteArray(this.byteArray, out);
	  }
	  public void fromData( DataInput in )
	  throws IOException, ClassNotFoundException {
	    this.timestamp = in.readLong();
	    this.field1 = in.readInt();
	    this.field2 = in.readChar();
	    this.byteArray = DataSerializer.readByteArray( in );
	  }
//------------------------------------------------------------------------------
//Delta

 public boolean hasDelta() {
   return true;
 }

 public void toDelta(DataOutput out)
 throws IOException {
   out.writeInt(this.field1);
   out.writeLong(this.timestamp);
 }

 public void fromDelta(DataInput in)
 throws IOException {
   this.field1 = in.readInt();
   this.timestamp = in.readLong();
 }

 
//------------------------------------------------------------------------------
//Cloneable

 /**
  * Makes a deep copy of this object.
  */
 public Object clone() throws CloneNotSupportedException {
   DeltaPSTObject obj = (DeltaPSTObject)super.clone();
   this.byteArray = new byte[this.byteArray.length];
   System.arraycopy(this.byteArray, 0, obj.byteArray, 0,
                    this.byteArray.length);
   return obj;
 }
}