tests/javaobject/EqStruct.java - geode-native - Git at Google

 /*
  * 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.
  */
 /*
  * 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 java.io.*;

 import org.apache.geode.DataSerializable;
 //import org.apache.geode.Instantiator;
 import org.apache.geode.internal.NanoTimer;
 import org.apache.geode.cache.Declarable;
 import org.apache.geode.*;
 import java.util.Properties;
 import java.lang.Exception;
 /**
  * The EqStruct is based on the Lehman Benchmark and provides us with
  * a flat object graph with many fields that implements the DataSerializable
  * interface and avoids the overhead associated with reflection during
  * seralization.
  *
  *
  */
 public class EqStruct implements Declarable,Serializable,DataSerializable {

   private int myIndex;
   private String state;
   private long timestamp;
   private double executedPriceSum;
   private int cxlQty;
   private int isSyntheticOrder;
   private long availQty;
   private double positionQty;
   private int isRestricted;
   private String demandInd;
   private String side;
   private int orderQty;
   private double price;
   private String ordType;
   private double stopPx;
   private String senderCompID;
   private String tarCompID;
   private String tarSubID;
   private String handlInst;
   private String orderID;
   private String timeInForce;
   private String clOrdID;
   private String orderCapacity;
   private int  cumQty;
   private String symbol;
   private String  symbolSfx;
   private String  execInst;
   private String oldClOrdID;
   private double pegDifference;
   private String  discretionInst;
   private double discretionOffset;
   private String  financeInd;
   private String  securityID;
   private String  targetCompID;
   private String targetSubID;
   private int isDoneForDay;
   private int revisionSeqNum;
   private int replaceQty;
   private long usedClientAvailability;
   private String clientAvailabilityKey;
   private int isIrregularSettlmnt;

   private String var1;
   private String var2;
   private String var3;
   private String var4;
   private String var5;
   private String var6;
   private String var7;
   private String var8;
   private String var9;


   static {
 	Instantiator.register(new Instantiator(EqStruct.class, (byte)101) {
 	  public DataSerializable newInstance() {
 	    return new EqStruct();
 	  }
 	});
    }

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

   /**
    * Returns the index encoded in the give <code>byte</code> array.
    *
    * @throws ObjectAccessException
    *         The index cannot be decoded from <code>bytes</code>
    */
   public int getIndex( ) {
     return this.myIndex;
   }


   //--------------------------------------------------------------------------
   // Implementation of UpdatableObject interface
   //--------------------------------------------------------------------------

     public void update()
     {
        var1 = "abcdefghi";
        cumQty = 39;
        usedClientAvailability = 0x8000000000001234L;
        discretionOffset = 12.3456789;
        resetTimestamp();
     }

   //--------------------------------------------------------------------------
   // Implementation of DataSerializable interface
   //--------------------------------------------------------------------------


     // INSTANTIATORS DISABLED due to bug 35646
     //
     // Avoid overhead of reflection via the org.apache.geode.Instantiator class
     //static {
     //  Instantiator.register(new Instantiator(EqStruct.class, (byte) 5) {
     //    public DataSerializable newInstance() {
     //      return new EqStruct();
     //    }
     //  });
     //}

     public void toData(DataOutput out) throws IOException {

       //Strings
       out.writeUTF( state );
       out.writeUTF( demandInd );
       out.writeUTF( side );
       out.writeUTF( ordType );
       out.writeUTF( senderCompID  );
       out.writeUTF( tarCompID );
       out.writeUTF( tarSubID );
       out.writeUTF( handlInst );
       out.writeUTF( orderID );
       out.writeUTF( timeInForce   );
       out.writeUTF( clOrdID );
       out.writeUTF( orderCapacity );
       out.writeUTF( symbol );
       out.writeUTF( symbolSfx  );
       out.writeUTF( execInst );
       out.writeUTF( oldClOrdID );
       out.writeUTF( discretionInst );
       out.writeUTF( financeInd );
       out.writeUTF( securityID );
       out.writeUTF( targetCompID );
       out.writeUTF( targetSubID  );
       out.writeUTF( clientAvailabilityKey );
       out.writeUTF( var1 );
       out.writeUTF( var2 );
       out.writeUTF( var3 );
       out.writeUTF( var4 );
       out.writeUTF( var5 );
       out.writeUTF( var6 );
       out.writeUTF( var7 );
       out.writeUTF( var8 );
       out.writeUTF( var9 );

       //ints
       out.writeInt( myIndex );
       out.writeInt( cxlQty );
       out.writeInt( isSyntheticOrder );
       out.writeInt( isRestricted );
       out.writeInt( orderQty );
       out.writeInt( cumQty );
       out.writeInt( isDoneForDay );
       out.writeInt( revisionSeqNum );
       out.writeInt( replaceQty );
       out.writeInt( isIrregularSettlmnt );

       //longs
       out.writeLong( timestamp );
       out.writeLong( availQty );
       out.writeLong( usedClientAvailability );

       //doubles
       out.writeDouble( executedPriceSum );
       out.writeDouble( positionQty );
       out.writeDouble( price );
       out.writeDouble( stopPx );
       out.writeDouble( pegDifference );
       out.writeDouble( discretionOffset );

     }

     public void fromData(DataInput in) throws IOException, ClassNotFoundException {

       //Strings
       state = in.readUTF();
       demandInd = in.readUTF();
       side = in.readUTF();
       ordType = in.readUTF();
       senderCompID  = in.readUTF();
       tarCompID = in.readUTF();
       tarSubID = in.readUTF();
       handlInst = in.readUTF();
       orderID = in.readUTF();
       timeInForce   = in.readUTF();
       clOrdID = in.readUTF();
       orderCapacity = in.readUTF();
       symbol = in.readUTF();
       symbolSfx  = in.readUTF();
       execInst = in.readUTF();
       oldClOrdID = in.readUTF();
       discretionInst = in.readUTF();
       financeInd = in.readUTF();
       securityID = in.readUTF();
       targetCompID = in.readUTF();
       targetSubID  = in.readUTF();
       clientAvailabilityKey = in.readUTF();
       var1 = in.readUTF();
       var2 = in.readUTF();
       var3 = in.readUTF();
       var4 = in.readUTF();
       var5 = in.readUTF();
       var6 = in.readUTF();
       var7 = in.readUTF();
       var8 = in.readUTF();
       var9 = in.readUTF();

       //ints
       myIndex = in.readInt();
       cxlQty = in.readInt();
       isSyntheticOrder = in.readInt();
       isRestricted = in.readInt();
       orderQty = in.readInt();
       cumQty = in.readInt();
       isDoneForDay = in.readInt();
       revisionSeqNum = in.readInt();
       replaceQty = in.readInt();
       isIrregularSettlmnt = in.readInt();

       //longs
       timestamp = in.readLong();
       availQty = in.readLong();
       usedClientAvailability = in.readLong();

       //doubles
       executedPriceSum = in.readDouble();
       positionQty = in.readDouble();
       price = in.readDouble();
       stopPx = in.readDouble();
       pegDifference = in.readDouble();
       discretionOffset = in.readDouble();

     }

   //--------------------------------------------------------------------------
   // Implementation of TimestampedObject interface
   //--------------------------------------------------------------------------

   public long getTimestamp() {
     return this.timestamp;
   }

   public void resetTimestamp() {
     this.timestamp = NanoTimer.getTime();
   }
 }
	/*
	* 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.
	*/
	/*
	* 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 java.io.*;

	import org.apache.geode.DataSerializable;
	//import org.apache.geode.Instantiator;
	import org.apache.geode.internal.NanoTimer;
	import org.apache.geode.cache.Declarable;
	import org.apache.geode.*;
	import java.util.Properties;
	import java.lang.Exception;
	/**
	* The EqStruct is based on the Lehman Benchmark and provides us with
	* a flat object graph with many fields that implements the DataSerializable
	* interface and avoids the overhead associated with reflection during
	* seralization.
	*
	*
	*/
	public class EqStruct implements Declarable,Serializable,DataSerializable {

	private int myIndex;
	private String state;
	private long timestamp;
	private double executedPriceSum;
	private int cxlQty;
	private int isSyntheticOrder;
	private long availQty;
	private double positionQty;
	private int isRestricted;
	private String demandInd;
	private String side;
	private int orderQty;
	private double price;
	private String ordType;
	private double stopPx;
	private String senderCompID;
	private String tarCompID;
	private String tarSubID;
	private String handlInst;
	private String orderID;
	private String timeInForce;
	private String clOrdID;
	private String orderCapacity;
	private int cumQty;
	private String symbol;
	private String symbolSfx;
	private String execInst;
	private String oldClOrdID;
	private double pegDifference;
	private String discretionInst;
	private double discretionOffset;
	private String financeInd;
	private String securityID;
	private String targetCompID;
	private String targetSubID;
	private int isDoneForDay;
	private int revisionSeqNum;
	private int replaceQty;
	private long usedClientAvailability;
	private String clientAvailabilityKey;
	private int isIrregularSettlmnt;

	private String var1;
	private String var2;
	private String var3;
	private String var4;
	private String var5;
	private String var6;
	private String var7;
	private String var8;
	private String var9;



	static {
	Instantiator.register(new Instantiator(EqStruct.class, (byte)101) {
	public DataSerializable newInstance() {
	return new EqStruct();
	}
	});
	}

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

	/**
	* Returns the index encoded in the give <code>byte</code> array.
	*
	* @throws ObjectAccessException
	* The index cannot be decoded from <code>bytes</code>
	*/
	public int getIndex( ) {
	return this.myIndex;
	}


	//--------------------------------------------------------------------------
	// Implementation of UpdatableObject interface
	//--------------------------------------------------------------------------

	public void update()
	{
	var1 = "abcdefghi";
	cumQty = 39;
	usedClientAvailability = 0x8000000000001234L;
	discretionOffset = 12.3456789;
	resetTimestamp();
	}

	//--------------------------------------------------------------------------
	// Implementation of DataSerializable interface
	//--------------------------------------------------------------------------


	// INSTANTIATORS DISABLED due to bug 35646
	//
	// Avoid overhead of reflection via the org.apache.geode.Instantiator class
	//static {
	// Instantiator.register(new Instantiator(EqStruct.class, (byte) 5) {
	// public DataSerializable newInstance() {
	// return new EqStruct();
	// }
	// });
	//}

	public void toData(DataOutput out) throws IOException {

	//Strings
	out.writeUTF( state );
	out.writeUTF( demandInd );
	out.writeUTF( side );
	out.writeUTF( ordType );
	out.writeUTF( senderCompID );
	out.writeUTF( tarCompID );
	out.writeUTF( tarSubID );
	out.writeUTF( handlInst );
	out.writeUTF( orderID );
	out.writeUTF( timeInForce );
	out.writeUTF( clOrdID );
	out.writeUTF( orderCapacity );
	out.writeUTF( symbol );
	out.writeUTF( symbolSfx );
	out.writeUTF( execInst );
	out.writeUTF( oldClOrdID );
	out.writeUTF( discretionInst );
	out.writeUTF( financeInd );
	out.writeUTF( securityID );
	out.writeUTF( targetCompID );
	out.writeUTF( targetSubID );
	out.writeUTF( clientAvailabilityKey );
	out.writeUTF( var1 );
	out.writeUTF( var2 );
	out.writeUTF( var3 );
	out.writeUTF( var4 );
	out.writeUTF( var5 );
	out.writeUTF( var6 );
	out.writeUTF( var7 );
	out.writeUTF( var8 );
	out.writeUTF( var9 );

	//ints
	out.writeInt( myIndex );
	out.writeInt( cxlQty );
	out.writeInt( isSyntheticOrder );
	out.writeInt( isRestricted );
	out.writeInt( orderQty );
	out.writeInt( cumQty );
	out.writeInt( isDoneForDay );
	out.writeInt( revisionSeqNum );
	out.writeInt( replaceQty );
	out.writeInt( isIrregularSettlmnt );

	//longs
	out.writeLong( timestamp );
	out.writeLong( availQty );
	out.writeLong( usedClientAvailability );

	//doubles
	out.writeDouble( executedPriceSum );
	out.writeDouble( positionQty );
	out.writeDouble( price );
	out.writeDouble( stopPx );
	out.writeDouble( pegDifference );
	out.writeDouble( discretionOffset );

	}

	public void fromData(DataInput in) throws IOException, ClassNotFoundException {

	//Strings
	state = in.readUTF();
	demandInd = in.readUTF();
	side = in.readUTF();
	ordType = in.readUTF();
	senderCompID = in.readUTF();
	tarCompID = in.readUTF();
	tarSubID = in.readUTF();
	handlInst = in.readUTF();
	orderID = in.readUTF();
	timeInForce = in.readUTF();
	clOrdID = in.readUTF();
	orderCapacity = in.readUTF();
	symbol = in.readUTF();
	symbolSfx = in.readUTF();
	execInst = in.readUTF();
	oldClOrdID = in.readUTF();
	discretionInst = in.readUTF();
	financeInd = in.readUTF();
	securityID = in.readUTF();
	targetCompID = in.readUTF();
	targetSubID = in.readUTF();
	clientAvailabilityKey = in.readUTF();
	var1 = in.readUTF();
	var2 = in.readUTF();
	var3 = in.readUTF();
	var4 = in.readUTF();
	var5 = in.readUTF();
	var6 = in.readUTF();
	var7 = in.readUTF();
	var8 = in.readUTF();
	var9 = in.readUTF();

	//ints
	myIndex = in.readInt();
	cxlQty = in.readInt();
	isSyntheticOrder = in.readInt();
	isRestricted = in.readInt();
	orderQty = in.readInt();
	cumQty = in.readInt();
	isDoneForDay = in.readInt();
	revisionSeqNum = in.readInt();
	replaceQty = in.readInt();
	isIrregularSettlmnt = in.readInt();

	//longs
	timestamp = in.readLong();
	availQty = in.readLong();
	usedClientAvailability = in.readLong();

	//doubles
	executedPriceSum = in.readDouble();
	positionQty = in.readDouble();
	price = in.readDouble();
	stopPx = in.readDouble();
	pegDifference = in.readDouble();
	discretionOffset = in.readDouble();

	}

	//--------------------------------------------------------------------------
	// Implementation of TimestampedObject interface
	//--------------------------------------------------------------------------

	public long getTimestamp() {
	return this.timestamp;
	}

	public void resetTimestamp() {
	this.timestamp = NanoTimer.getTime();
	}
	}