X-Git-Url: http://plrg.eecs.uci.edu/git/?p=iotcloud.git;a=blobdiff_plain;f=version2%2Fsrc%2FC%2FTransaction.cc;h=d5abcc136dadad144542a2424f711c5a8101fba6;hp=532d6e571e0b81e16457755af8f29ffcfb2ac83c;hb=41ff9c95ca5d4b707386c1b7e66df033169bf68d;hpb=4087b948a1cb6980a347cbc5ceebd40fade99b82

diff --git a/version2/src/C/Transaction.cc b/version2/src/C/Transaction.cc
index 532d6e5..d5abcc1 100644
--- a/version2/src/C/Transaction.cc
+++ b/version2/src/C/Transaction.cc
@@ -2,9 +2,9 @@
 
 class Transaction {
 
-    Hashtable<Integer, TransactionPart> parts = NULL;
-    Set<Integer> missingParts = NULL;
-    List<Integer> partsPendingSend = NULL;
+    Hashtable<int32_t, TransactionPart> parts = NULL;
+    Set<int32_t> missingParts = NULL;
+    Vector<int32_t> partsPendingSend = NULL;
     bool isComplete = false;
     bool hasLastPart = false;
     Set<KeyValue> keyValueGuardSet = NULL;
@@ -24,10 +24,10 @@ class Transaction {
     bool hadServerFailure = false;
 
     Transaction() {
-        parts = new Hashtable<Integer, TransactionPart>();
+        parts = new Hashtable<int32_t, TransactionPart>();
         keyValueGuardSet = new HashSet<KeyValue>();
         keyValueUpdateSet = new HashSet<KeyValue>();
-        partsPendingSend = new ArrayList<Integer>();
+        partsPendingSend = new Vector<int32_t>();
     }
 
     void addPartEncode(TransactionPart newPart) {
@@ -63,7 +63,7 @@ class Transaction {
             // Set dead the old one since the new one is a rescued version of this part
             previoslySeenPart.setDead();
         } else if (newPart.isLastPart()) {
-            missingParts = new HashSet<Integer>();
+            missingParts = new HashSet<int32_t>();
             hasLastPart = true;
 
             for (int i = 0; i < newPart.getPartNumber(); i++) {
@@ -106,7 +106,7 @@ class Transaction {
     void setSequenceNumber(int64_t _sequenceNumber) {
         sequenceNumber = _sequenceNumber;
 
-        for (Integer i : parts.keySet()) {
+        for (int32_t i : parts.keySet()) {
             parts.get(i).setSequenceNumber(sequenceNumber);
         }
     }
@@ -115,7 +115,7 @@ class Transaction {
         return clientLocalSequenceNumber;
     }
 
-    Hashtable<Integer, TransactionPart> getParts() {
+    Hashtable<int32_t, TransactionPart> getParts() {
         return parts;
     }
 
@@ -159,7 +159,7 @@ class Transaction {
         return transactionStatus;
     }
 
-    void removeSentParts(List<Integer> sentParts) {
+    void removeSentParts(Vector<int32_t> sentParts) {
         nextPartToSend = 0;
         if(partsPendingSend.removeAll(sentParts))
         {
@@ -206,7 +206,7 @@ class Transaction {
         isDead = true;
 
         // Make all the parts of this transaction dead
-        for (Integer partNumber : parts.keySet()) {
+        for (int32_t partNumber : parts.keySet()) {
             TransactionPart part = parts.get(partNumber);
             part.setDead();
         }