Working version

to test

./Intruder.bin -a 10 -l 32 -n 100000 -s 1

diff --git a/Robust/src/Benchmarks/SingleTM/Intruder/Decoder.java b/Robust/src/Benchmarks/SingleTM/Intruder/Decoder.java
index 4733da878e5bb967f450ff78f5fbb78706751ce2..fcbfdb0583c7c07dd00ce9062be45a2f20f21186 100644 (file)
--- a/Robust/src/Benchmarks/SingleTM/Intruder/Decoder.java
+++ b/Robust/src/Benchmarks/SingleTM/Intruder/Decoder.java
@@ -126,26 +126,25 @@ public class Decoder {
  * =============================================================================
  er_t decoder_process (decoder_t* decoderPtr, char* bytes, long numByte);
  */
-    public int process(Packet bytes,int numByte)
+    public int process(Packet packetPtr,int numByte)
     {
         boolean status;
-        ERROR er;
+        ERROR er = new ERROR();
 
         /*
-         * Basic er checing
+         * Basic error checking
          */
 
         if (numByte < 0) {
             return er.SHORT;
         }
 
-        /* need to look into it later */
-        Packet packetPtr = (Packet)bytes;
         int flowId = packetPtr.flowId;
         int fragmentId = packetPtr.fragmentId;
         int numFragment = packetPtr.numFragment;
         int length = packetPtr.length;
 
+
         if (flowId < 0) {
             return er.FLOWID;
         }
@@ -171,21 +170,29 @@ public class Decoder {
 
                 fragmentListPtr = List_t.alloc(1);      // packet_compareFragmentId
                 if(fragmentListPtr == null) {
-                    System.out.println("Assertion in process");
+                    System.out.println("Assertion in Decoder1.process");
+                    System.exit(1);
+                }
+                status = fragmentListPtr.insert(packetPtr);
+                
+                if(!status) {
+                    System.out.println("Assertion Decoer.process");
                     System.exit(1);
                 }
 
                 status = MAP_INSERT(fragmentedMapPtr,flowId,fragmentListPtr);
-                if(status) {
-                    System.out.println("Assertion in process");
+                if(!status) {
+                    System.out.println("Assertion Decoder!!!!.process");
                     System.exit(1);                                
                 }
+
             } else {
-                List_Iter it;
+
+                List_Iter it = new List_Iter();
                 it.reset(fragmentListPtr);
                 
-                if(it.hasNext(fragmentListPtr)) {
-                    System.out.println("Assertion in process");
+                if(!it.hasNext(fragmentListPtr)) {
+                    System.out.println("Assertion in Decoder2.process");
                     System.exit(1);
                 }
 
@@ -194,92 +201,82 @@ public class Decoder {
 
                 if (numFragment != expectedNumFragment) {
                     status = MAP_REMOVE(fragmentedMapPtr,flowId);
-                    if(status) {
-                        System.out.println("Assertion in process");
+                    if(!status) {
+                        System.out.println("Assertion in process1");
                         System.exit(1);
                     }
+                    return er.NUMFRAGMENT;
+                }
 
-                    status = fragmentListPtr.insert(packetPtr);
-                    if(status) {
-                        System.out.println("Assertion in process");
-                        System.exit(1);
-                    }
+                status = fragmentListPtr.insert(packetPtr);
+                
+                if(!status) {
+                    System.out.println("Assertion in process2");
+                    System.exit(1);
+                }
 
-                    /*
-                     * If we have all thefragments we can reassemble them
-                     */
+                   
 
-                    if(fragmentListPtr.getSize() ==  numFragment) {
+                /*
+                 * If we have all thefragments we can reassemble them
+                 */
 
+                if(fragmentListPtr.getSize() ==  numFragment) {
 
-                        int numBytes = 0;
-                        int i = 0;
-                        it.reset(fragmentListPtr);
+                    int numBytes = 0;
+                    int i = 0;
+                    it.reset(fragmentListPtr);
 
-                        while (it.hasNext(fragmentListPtr)) {
-                            Packet fragmentPtr = (Packet)it.next(fragmentListPtr);
+                    while (it.hasNext(fragmentListPtr)) {
+                        Packet fragmentPtr = (Packet)it.next(fragmentListPtr);
 
-                            if(fragmentPtr.fragmentId != i) {
-                                status = MAP_REMOVE(fragmentedMapPtr,flowId);
+                        if(fragmentPtr.fragmentId != i) {
+                            status = MAP_REMOVE(fragmentedMapPtr,flowId);
                                 
-                                if(status) {
-                                    System.out.println("Assertion in process");
-                                    System.exit(1);
-                                }
-                               return er.INCOMPLETE; /* should be sequential */
-                            }
-                                numBytes += fragmentPtr.length;
-                                i++;
+                            if(!status) {
+                                System.out.println("Assertion in process3");
+                                System.exit(1);
+                             }
+                            return er.INCOMPLETE; /* should be sequential */
                         }
+                            numBytes += fragmentPtr.length;
+                            i++;
+                    }
 
-                        char[] data = new char[numBytes+1];
-                        if(data == null) {
-                             System.out.println("Assertion in process");
-                             System.exit(1);
-                        }
+                    String data;
 
-                        data[numBytes] = '\0';
-                        int dst = 0;            // index of data
-                        it.reset(fragmentListPtr);
-                        while(it.hasNext(fragmentListPtr)) {
-                            Packet fragmentPtr = (Packet)it.next(fragmentListPtr);
+                    it.reset(fragmentListPtr);
+                    while(it.hasNext(fragmentListPtr)) {
 
-                            for(i=0;i<fragmentPtr.length;i++) {                      
-                                data[dst++] = fragmentPtr.data.charAt(i);
-                            }
-                        }
+                        Packet fragmentPtr = (Packet)it.next(fragmentListPtr);
                         
-                        if(dst != (numBytes)) {
-                            System.out.println("Assertion in process");                         
-                            System.exit(1);
-                        }
-
-                        Decoded decodedPtr = new Decoded();
-                        if(decodedPtr == null) {
-                             System.out.println("Assertion in process");                    
-                             System.exit(1);
-                        }
+                        data = new String(fragmentPtr.data);
+                    }
+                        
+                    Decoded decodedPtr = new Decoded();
+                    if(decodedPtr == null) {
+                         System.out.println("Assertion in process6");                    
+                         System.exit(1);
+                    }
 
-                        decodedPtr.flowId = flowId;
-                        decodedPtr.data = new String(data);
+                    decodedPtr.flowId = flowId;
+                    decodedPtr.data = new String(data);
 
-                        status = decodedQueuePtr.queue_push(decodedPtr);
+                    status = decodedQueuePtr.queue_push(decodedPtr);
 
-                        if(status) {
-                            System.out.println("Assertion in process");  
-                            System.exit(1);
-                        }
+                    if(!status) {
+                        System.out.println("Assertion in process7");  
+                        System.exit(1);
+                    }
 
-                        status = MAP_REMOVE(fragmentedMapPtr,flowId);
+                    status = MAP_REMOVE(fragmentedMapPtr,flowId);
 
-                        if(status) {
-                            System.out.println("Assertion in process");                         
-                            System.exit(1);
-                        }
-                    }                
+                    if(!status) {
+                        System.out.println("Assertion in process8");                         
+                        System.exit(1);
+                    }   
                 } 
             }
-
         }else {
 
                 /*
@@ -290,18 +287,16 @@ public class Decoder {
                     return er.FRAGMENTID;
                 }
 
-                String data = new String();
+                String data = new String(packetPtr.data);
                 if(data == null) {
-                    System.out.println("Assertion in process");                           
+                    System.out.println("Assertion in proces9");                           
                     System.exit(1);
                 }
 
-                data.concat(packetPtr.data);
-
                Decoded decodedPtr = new Decoded();
 
                 if(decodedPtr == null) {
-                    System.out.println("Assertion in process");                           
+                    System.out.println("Assertion in process0");                           
                     System.exit(1);
                 }
 
@@ -310,13 +305,12 @@ public class Decoder {
 
                 status = decodedQueuePtr.queue_push(decodedPtr);
                 
-                if(status) {
-                    System.out.println("Assertion in process");                           
+                if(!status) {
+                    System.out.println("Assertion in process10");                           
                     System.exit(1);
                 }
             }
 
-    
         return er.NONE;
 
             
@@ -343,7 +337,6 @@ public class Decoder {
         if(decodedPtr != null) {
             decodedFlowId[0] = decodedPtr.flowId;
             data = decodedPtr.data;
-            decodedPtr = null;
         } else {
             decodedFlowId[0] = -1;
             data= null;

diff --git a/Robust/src/Benchmarks/SingleTM/Intruder/ERROR.java b/Robust/src/Benchmarks/SingleTM/Intruder/ERROR.java
index 2c004e6e177e1a3c30f4fb32dbadb061d598aa5e..7afd734258ad9d9ff33a0f2e81c84d5e5be23ae6 100644 (file)
--- a/Robust/src/Benchmarks/SingleTM/Intruder/ERROR.java
+++ b/Robust/src/Benchmarks/SingleTM/Intruder/ERROR.java
@@ -69,14 +69,14 @@
  */
 
 public static class ERROR {
-    static int NONE;
-    static int SHORT;
-    static int FLOWID;
-    static int FRAGMENTID;
-    static int LENGTH;
-    static int NUMFRAGMENT;
-    static int INCOMPLETE;
-    static int SIGNATURE;
+    int NONE;
+    int SHORT;
+    int FLOWID;
+    int FRAGMENTID;
+    int LENGTH;
+    int NUMFRAGMENT;
+    int INCOMPLETE;
+    int SIGNATURE;
 
     public ERROR() {
 

diff --git a/Robust/src/Benchmarks/SingleTM/Intruder/toLower.java b/Robust/src/Benchmarks/SingleTM/Intruder/toLower.java
index 69ad36b533743eca313595a101ad90f58539592f..70dc021a34346be11e94224a7c2679eecb593678 100644 (file)
--- a/Robust/src/Benchmarks/SingleTM/Intruder/toLower.java
+++ b/Robust/src/Benchmarks/SingleTM/Intruder/toLower.java
@@ -4,9 +4,11 @@ public class toLower extends Preprocessor
     public toLower() {
         super();
     }
-    public static void process(String str)
+    public static String process(String str)
     {
-       str =  str.toLowerCase();
+       str=  str.toLowerCase();
+
+       return str;
     }
 
 }