Fixing Bugs

[iotcloud.git] / version2 / src / java / iotcloud / Abort.java

diff --git a/version2/src/java/iotcloud/Abort.java b/version2/src/java/iotcloud/Abort.java
index 4d0c59bde39d443e214d46522fc5c370109d02f2..f27c787d1a8b60d9861b58f52f6c10371600ffdf 100644 (file)
--- a/version2/src/java/iotcloud/Abort.java
+++ b/version2/src/java/iotcloud/Abort.java
@@ -12,42 +12,52 @@ import java.nio.ByteBuffer;
 class Abort extends Entry {
        private long seqnumtrans;
        private long machineid;
+       private long transarbitrator;
 
-       Abort(Slot slot, long _seqnumtrans, long _machineid) {
+
+       public Abort(Slot slot, long _seqnumtrans, long _machineid, long _transarbitrator) {
                super(slot);
-               seqnumtrans=_seqnumtrans;
-               machineid=_machineid;
+               seqnumtrans = _seqnumtrans;
+               machineid = _machineid;
+               transarbitrator = _transarbitrator;
        }
 
-       long getMachineID() {
+       public long getMachineID() {
                return machineid;
        }
 
-       long getTransSequenceNumber() {
+       public long getTransSequenceNumber() {
                return seqnumtrans;
        }
 
+       public long getTransArbitrator() {
+               return transarbitrator;
+       }
+
+
        static Entry decode(Slot slot, ByteBuffer bb) {
-               long seqnumtrans=bb.getLong();
-               long machineid=bb.getLong();
-               return new Abort(slot, seqnumtrans, machineid);
+               long seqnumtrans = bb.getLong();
+               long machineid = bb.getLong();
+               long transarbitrator = bb.getLong();
+               return new Abort(slot, seqnumtrans, machineid, transarbitrator);
        }
 
-       void encode(ByteBuffer bb) {
+       public void encode(ByteBuffer bb) {
                bb.put(Entry.TypeAbort);
                bb.putLong(seqnumtrans);
                bb.putLong(machineid);
+               bb.putLong(transarbitrator);
        }
 
-       int getSize() {
-               return (2 * Long.BYTES) + Byte.BYTES;
+       public int getSize() {
+               return (3 * Long.BYTES) + Byte.BYTES;
        }
 
-       byte getType() {
+       public byte getType() {
                return Entry.TypeAbort;
        }
 
-       Entry getCopy(Slot s) {
-               return new Abort(s, seqnumtrans, machineid);
+       public Entry getCopy(Slot s) {
+               return new Abort(s, seqnumtrans, machineid, transarbitrator);
        }
 }
\ No newline at end of file