Fixed bug

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

diff --git a/version2/src/java/iotcloud/Test.java b/version2/src/java/iotcloud/Test.java
index bfe0f871cf73ec17b4f943977e8a55b32e1afc65..99babcbe450b5501fa46e9430f4f1fd432b80f40 100644 (file)
--- a/version2/src/java/iotcloud/Test.java
+++ b/version2/src/java/iotcloud/Test.java
@@ -11,7 +11,7 @@ import java.util.ArrayList;
 
 public class Test {
 
-    public static final  int NUMBER_OF_TESTS = 1000;
+    public static final  int NUMBER_OF_TESTS = 15;
 
     public static void main(String[] args)  throws ServerException {
         if (args[0].equals("2")) {
@@ -144,18 +144,23 @@ public class Test {
             IoTString iValueCPrev = new IoTString(valueCPrev);
             IoTString iValueDPrev = new IoTString(valueDPrev);
 
+
+            System.out.println("t1 A");
             t1.startTransaction();
             t1.addKV(iKeyA, iValueA);
             transStatusList.add(t1.commitTransaction());
 
+            System.out.println("t1 B");
             t1.startTransaction();
             t1.addKV(iKeyB, iValueB);
             transStatusList.add(t1.commitTransaction());
 
+            System.out.println("t2 C");
             t2.startTransaction();
             t2.addKV(iKeyC, iValueC);
             transStatusList.add(t2.commitTransaction());
 
+            System.out.println("t2 D");
             t2.startTransaction();
             t2.addKV(iKeyD, iValueD);
             transStatusList.add(t2.commitTransaction());
@@ -849,10 +854,14 @@ public class Test {
             }
         }
 
+        int count = 0;
         for (TransactionStatus status : transStatusList) {
             if (status.getStatus() != TransactionStatus.StatusCommitted) {
                 foundError = true;
+                System.out.println("Status: " + status.getStatus() + "   " + status.getTransactionSequenceNumber());
             }
+
+            count++;
         }
 
         if (foundError) {
@@ -863,6 +872,14 @@ public class Test {
 
         t1.close();
         t2.close();
+
+        System.out.println();
+        System.out.println();
+        t1.printSlots();
+
+        System.out.println();
+        System.out.println();
+        t2.printSlots();
     }
 
     static void test7() throws ServerException {
@@ -1880,40 +1897,22 @@ public class Test {
             IoTString iValueD = new IoTString(valueD);
 
 
-            System.out.println("===============================================================================");
-            System.out.println("AAAAAAAA");
-            System.out.println("===============================================================================");
             t1.startTransaction();
             t1.addKV(iKeyA, iValueA);
             transStatusList.add(t1.commitTransaction());
-            System.out.println();
 
 
-            System.out.println("===============================================================================");
-            System.out.println("BBBBBBB");
-            System.out.println("===============================================================================");
             t1.startTransaction();
             t1.addKV(iKeyB, iValueB);
             transStatusList.add(t1.commitTransaction());
-            System.out.println();
-
 
-            System.out.println("===============================================================================");
-            System.out.println("CCCCCCC");
-            System.out.println("===============================================================================");
             t2.startTransaction();
             t2.addKV(iKeyC, iValueC);
             transStatusList.add(t2.commitTransaction());
-            System.out.println();
-
 
-            System.out.println("===============================================================================");
-            System.out.println("DDDDDDDDDD");
-            System.out.println("===============================================================================");
             t2.startTransaction();
             t2.addKV(iKeyD, iValueD);
             transStatusList.add(t2.commitTransaction());
-            System.out.println();
 
         }
         endTime = System.currentTimeMillis();
@@ -2014,12 +2013,12 @@ public class Test {
             System.out.println("No Errors Found...");
         }
 
-        System.out.println();
-        System.out.println();
-        t1.printSlots();
+        // System.out.println();
+        // System.out.println();
+        // t1.printSlots();
 
-        System.out.println();
-        System.out.println();
-        t2.printSlots();
+        // System.out.println();
+        // System.out.println();
+        // t2.printSlots();
     }
 }