updates to transsim for journal submission

diff --git a/Robust/TransSim/FileSim.java b/Robust/TransSim/FileSim.java
index 4154e7725feda503d838b08ea5bf45f667eb743a..f782584718ca57ad0567e20847790dc222542102 100644 (file)
--- a/Robust/TransSim/FileSim.java
+++ b/Robust/TransSim/FileSim.java
@@ -69,7 +69,6 @@ public class FileSim {
     ls9.join();
     System.out.println("Karma Abort="+ls9.getTime());
     System.out.println("Aborts="+ls9.getAborts()+" Commit="+ls9.getCommits());
-    System.out.println("atime="+ls9.aborttime+" stalltime="+ls9.stalltime);
     ls9=null;
 
     ls10.join();
@@ -79,7 +78,6 @@ public class FileSim {
 
     ls11.join();
     System.out.println("Eruption Abort="+ls11.getTime());
-    System.out.println("atime="+ls11.aborttime+" stalltime="+ls11.stalltime);
     System.out.println("Aborts="+ls11.getAborts()+" Commit="+ls11.getCommits());
   }
 
@@ -90,7 +88,6 @@ public class FileSim {
     ls9.join();
     System.out.println("Karma Abort="+ls9.getTime());
     System.out.println("Aborts="+ls9.getAborts()+" Commit="+ls9.getCommits());
-    System.out.println("atime="+ls9.aborttime+" stalltime="+ls9.stalltime);
     ls9=null;
   }
 

diff --git a/Robust/TransSim/FlexScheduler.java b/Robust/TransSim/FlexScheduler.java
index d1d9ef02881d9f4dec2dd1d595f0b6a4661c71bd..af8f40d820bc353e9da27722d266ab32ca177b68 100644 (file)
--- a/Robust/TransSim/FlexScheduler.java
+++ b/Robust/TransSim/FlexScheduler.java
@@ -14,7 +14,7 @@ public class FlexScheduler extends Thread {
     this.abortRatio=abortRatio;
     this.checkdepth=checkdepth;
   }
-  
+
   public void run() {
     dosim();
   }
@@ -79,6 +79,8 @@ public class FlexScheduler extends Thread {
   public static final int POLITE=9;
   public static final int ERUPTION=10;
   public static final int THREAD=11;
+  public static final int ATTACKTIME=12;
+  public static final int ATTACKTHREAD=13;
 
   PriorityQueue eq;
   int policy;
@@ -89,6 +91,9 @@ public class FlexScheduler extends Thread {
   Hashtable wrobjmap;
   int abortcount;
   int commitcount;
+  long backoffcycles;
+  long stallcycles;
+  long abortedcycles;
   Event[] currentevents;
   Random r;
   int[] backoff;
@@ -100,7 +105,7 @@ public class FlexScheduler extends Thread {
   boolean[] blocked;
 
   public boolean isEager() {
-    return policy==ATTACK||policy==SUICIDE||policy==TIMESTAMP||policy==RANDOM||policy==KARMA||policy==POLITE||policy==ERUPTION||policy==THREAD;
+    return policy==ATTACK||policy==SUICIDE||policy==TIMESTAMP||policy==RANDOM||policy==KARMA||policy==POLITE||policy==ERUPTION||policy==THREAD||policy==ATTACKTIME||policy==ATTACKTHREAD;
   }
 
   public boolean countObjects() {
@@ -123,8 +128,18 @@ public class FlexScheduler extends Thread {
     return shorttesttime-starttime;
   }
 
+  public long getStallTime() {
+    return stallcycles;
+  }
+
+  public long getBackoffTime() {
+    return backoffcycles;
+  }
+
   //Aborts another thread...
-  public void reschedule(int currthread, long time) {
+  public void reschedule(int currthread, long currtime, long backofftime) {
+    long time=currtime+backofftime;
+    backoffcycles+=backofftime;
     currentevents[currthread].makeInvalid();
     if (threadinfo[currthread].isStalled()) {
       //remove from waiter list
@@ -143,12 +158,12 @@ public class FlexScheduler extends Thread {
   }
 
   //Aborts another thread...
-  public void stall(Event ev, long time) {
-    ev.setTime(time);
+  public void stall(Event ev, long time, long delay) {
+    stallcycles+=delay;
+    ev.setTime(time+delay);
     eq.add(ev);
   }
 
-
   private void releaseObjects(Transaction trans, int currthread, long time) {
     //remove all events
     for(int i=0;i<trans.numEvents();i++) {
@@ -255,6 +270,7 @@ public class FlexScheduler extends Thread {
       }
       //Reset our backoff counter
       threadinfo[ev.getThread()].priority=0;
+      threadinfo[ev.getThread()].aborted=false;
       backoff[ev.getThread()]=BACKOFFSTART;
       retrycount[ev.getThread()]=0;
       transferred[ev.getThread()]=0;
@@ -304,7 +320,7 @@ public class FlexScheduler extends Thread {
                serAbort.addPoint(currtime, threadid);
            } else if (policy==COMMIT||policy==LOCKCOMMIT) {
              //abort it immediately
-             reschedule(threadid, currtime);
+             reschedule(threadid, currtime, 0);
              abortcount++;
            }
          }
@@ -368,8 +384,6 @@ public class FlexScheduler extends Thread {
   //Takes as parameter -- current transaction read event ev, conflicting
   //set of threads, and the current time
   //Returning false causes current transaction not continue to be scheduled
-  long stalltime=0;
-  long aborttime=0;
 
 
   public boolean handleConflicts(Event ev, Set threadstokill, long time) {
@@ -381,13 +395,13 @@ public class FlexScheduler extends Thread {
        int dback=backoff[thread]*2;
        if (dback>0)
          backoff[thread]=dback;
-       stall(ev, time+r.nextInt(backoff[thread]));
+       stall(ev, time, r.nextInt(backoff[thread]));
        return false;
       } else {
        //abort other transactions
        for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
          Integer thread=(Integer)thit.next();
-         reschedule(thread, time);
+         reschedule(thread, time, 0);
          abortcount++;
        }
        return true;
@@ -404,8 +418,7 @@ public class FlexScheduler extends Thread {
        threadinfo[ev.getThread()].priority--;
        retrycount[ev.getThread()]++;
        int rtime=r.nextInt(3000);
-       stall(ev, time+rtime);
-       stalltime+=rtime;
+       stall(ev, time, rtime);
        return false;
       } else {
        //we win
@@ -415,8 +428,7 @@ public class FlexScheduler extends Thread {
          if (dback>0)
            backoff[thread]=dback;
          int atime=r.nextInt(backoff[thread]);
-         reschedule(thread, time+atime);
-         aborttime+=atime;
+         reschedule(thread, time, atime);
          abortcount++;
        }
        return true;
@@ -434,8 +446,7 @@ public class FlexScheduler extends Thread {
        threadinfo[ev.getThread()].priority--;
        //stall for a little while
        int rtime=r.nextInt(3000);
-       stall(ev, time+rtime);
-       stalltime+=rtime;
+       stall(ev, time, rtime);
        int ourpriority=threadinfo[ev.getThread()].priority;
        ourpriority-=transferred[ev.getThread()];
        for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
@@ -454,8 +465,7 @@ public class FlexScheduler extends Thread {
          if (dback>0)
            backoff[thread]=dback;
          int atime=r.nextInt(backoff[thread]);
-         reschedule(thread, time+atime);
-         aborttime+=atime;
+         reschedule(thread, time, atime);
          abortcount++;
        }
        return true;
@@ -466,7 +476,7 @@ public class FlexScheduler extends Thread {
        retrycount[ev.getThread()]=0;
        for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
          Integer thread=(Integer)thit.next();
-         reschedule(thread, time);
+         reschedule(thread, time, 0);
          abortcount++;
        }
        return true;
@@ -475,13 +485,13 @@ public class FlexScheduler extends Thread {
        int stalltime=(1<<(retry-1))*12;
        if (stalltime<0)
          stalltime=1<<30;
-       stall(ev, time+r.nextInt(stalltime));
+       stall(ev, time, r.nextInt(stalltime));
        return false;
       }
     } else if (policy==ATTACK) {
       for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
        Integer thread=(Integer)thit.next();
-       reschedule(thread, time+r.nextInt(backoff[thread.intValue()]));
+       reschedule(thread, time, r.nextInt(backoff[thread.intValue()]));
        int dback=backoff[thread.intValue()]*2;
        if (dback>0)
          backoff[thread.intValue()]=dback;
@@ -489,7 +499,7 @@ public class FlexScheduler extends Thread {
       }
       return true;
     } else if (policy==SUICIDE) {
-      reschedule(ev.getThread(), time+r.nextInt(backoff[ev.getThread()]));
+      reschedule(ev.getThread(), time, r.nextInt(backoff[ev.getThread()]));
       int dback=backoff[ev.getThread()]*2;
       if (dback>0)
        backoff[ev.getThread()]=dback;
@@ -508,71 +518,133 @@ public class FlexScheduler extends Thread {
       }
       if (opponenttime>ev.getTransaction().getTime(ev.getEvent())) {
        //kill ourself
-       reschedule(ev.getThread(), time+r.nextInt(backoff[ev.getThread()]));
+       reschedule(ev.getThread(), time, 0);
        abortcount++;
        return false;
       } else {
        //kill the opponents
        for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
          Integer thread=(Integer)thit.next();
-         reschedule(thread, time+r.nextInt(backoff[thread.intValue()]));
+         reschedule(thread, time, 0);
          abortcount++;
        }
        return true;    
       }
-    } else if (policy==TIMESTAMP) {
-      long opponenttime=0;
+    } else if (policy==THREAD) {
+      long tid=1000;
 
       for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
        Integer thread=(Integer)thit.next();
        Event other=currentevents[thread.intValue()];
        int eventnum=other.getEvent();
-       long otime=other.getTransaction().getTime(other.getEvent());
-       if (otime>opponenttime)
-         opponenttime=otime;
+       long otid=thread.intValue();
+       if (tid>otid)
+         tid=otid;
       }
-      if (opponenttime>ev.getTransaction().getTime(ev.getEvent())) {
+      if (ev.getThread()>tid) {
        //kill ourself
-       reschedule(ev.getThread(), time+r.nextInt(backoff[ev.getThread()]));
+       reschedule(ev.getThread(), time, 0);
        abortcount++;
        return false;
       } else {
        //kill the opponents
        for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
          Integer thread=(Integer)thit.next();
-         reschedule(thread, time+r.nextInt(backoff[thread.intValue()]));
+         reschedule(thread, time, 0);
          abortcount++;
        }
        return true;    
       }
-    } else if (policy==THREAD) {
-      long tid=1000;
-
+    } else if (policy==ATTACKTIME) {
+      boolean timebased=false;
+      int tev=ev.getThread();
+      timebased|=threadinfo[tev].aborted;
       for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
        Integer thread=(Integer)thit.next();
-       Event other=currentevents[thread.intValue()];
-       int eventnum=other.getEvent();
-       long otid=thread.intValue();
-       if (tid>otid)
-         tid=otid;
+       timebased|=threadinfo[thread.intValue()].aborted;
       }
-      if (ev.getThread()>tid) {
-       //kill ourself
-       reschedule(ev.getThread(), time+r.nextInt(backoff[ev.getThread()]));
-       abortcount++;
-       return false;
+      if (timebased) {
+       long opponenttime=0;
+       
+       for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
+         Integer thread=(Integer)thit.next();
+         Event other=currentevents[thread.intValue()];
+         int eventnum=other.getEvent();
+         long otime=other.getTransaction().getTime(other.getEvent());
+         if (otime>opponenttime)
+           opponenttime=otime;
+       }
+       if (opponenttime>ev.getTransaction().getTime(ev.getEvent())) {
+         //kill ourself
+         reschedule(ev.getThread(), time, 0);
+         threadinfo[ev.getThread()].aborted=true;
+         abortcount++;
+         return false;
+       } else {
+         //kill the opponents
+         for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
+           Integer thread=(Integer)thit.next();
+           reschedule(thread, time, 0);
+           threadinfo[thread.intValue()].aborted=true;
+           abortcount++;
+         }
+         return true;  
+       }
       } else {
-       //kill the opponents
        for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
          Integer thread=(Integer)thit.next();
-         reschedule(thread, time+r.nextInt(backoff[thread.intValue()]));
+         reschedule(thread, time, 0);
+         threadinfo[thread.intValue()].aborted=true;
          abortcount++;
        }
-       return true;    
+       return true;
+      }
+    } else if (policy==ATTACKTHREAD) {
+      boolean threadbased=false;
+      int tev=ev.getThread();
+      threadbased|=threadinfo[tev].aborted;
+      for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
+       Integer thread=(Integer)thit.next();
+       threadbased|=threadinfo[thread.intValue()].aborted;
+      }
+      if (threadbased) {
+       long opponentthr=1000;
+       
+       for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
+         Integer thread=(Integer)thit.next();
+         Event other=currentevents[thread.intValue()];
+         int eventnum=other.getEvent();
+         long othr=thread.intValue();
+         if (othr<opponentthr)
+           opponentthr=othr;
+       }
+       if (opponentthr<tev) {
+         //kill ourself
+         reschedule(ev.getThread(), time, 0);
+         threadinfo[ev.getThread()].aborted=true;
+         abortcount++;
+         return false;
+       } else {
+         //kill the opponents
+         for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
+           Integer thread=(Integer)thit.next();
+           reschedule(thread, time, 0);
+           threadinfo[thread.intValue()].aborted=true;
+           abortcount++;
+         }
+         return true;  
+       }
+      } else {
+       for(Iterator thit=threadstokill.iterator();thit.hasNext();) {
+         Integer thread=(Integer)thit.next();
+         reschedule(thread, time, 0);
+         threadinfo[thread.intValue()].aborted=true;
+         abortcount++;
+       }
+       return true;
       }
     }
 
-
     //Not eager
     return true;
   }

diff --git a/Robust/TransSim/Series.java b/Robust/TransSim/Series.java
index 9509ea05ae0b9f2636a77674017add37c252bd80..92dc9ae153fbf2a07a7739c6c9e63b5a360347a3 100644 (file)
--- a/Robust/TransSim/Series.java
+++ b/Robust/TransSim/Series.java
@@ -10,6 +10,10 @@ public class Series {
     addPoint(Long.toString(x), Integer.toString(y));
   }
 
+  public void addPoint(int x, double y) {
+    addPoint(Integer.toString(x), Double.toString(y));
+  }
+
   public void addPoint(int x, long y) {
     addPoint(Integer.toString(x), Long.toString(y));
   }

diff --git a/Robust/TransSim/ThreadInfo.java b/Robust/TransSim/ThreadInfo.java
index 48812c5d2398b8f0101ea8a9e11db0f1459ee578..8deff3f08ccd9a5a42ddb4f50e4a5d07a9807370 100644 (file)
--- a/Robust/TransSim/ThreadInfo.java
+++ b/Robust/TransSim/ThreadInfo.java
@@ -9,6 +9,7 @@ public class ThreadInfo {
   int oid;
   int index;
   int priority;
+  boolean aborted;
 
   public void setObject(int oid) {
     this.oid=oid;

diff --git a/Robust/TransSim/TransSim.java b/Robust/TransSim/TransSim.java
index 896b8bd8ef001f77b43e98f8c1c923ab3f8eefe6..8e2cb951f2049048519de625a0f65df312663924 100644 (file)
--- a/Robust/TransSim/TransSim.java
+++ b/Robust/TransSim/TransSim.java
@@ -3,10 +3,10 @@ public class TransSim {
     int numThreads=20;
     int numTrans=40;
     int deltaTrans=0;
-    int numObjects=200;
+    int numObjects=400;
     int numAccesses=20;
-    int deltaAccesses=0;
-    int readPercent=0;
+    int deltaAccesses=3;
+    int readPercent=80; //80 percent read
     //time for operation
     int delay=20;
     int deltaDelay=4;
@@ -14,16 +14,17 @@ public class TransSim {
     int nonTrans=20;
     int deltaNonTrans=4;
     //split objects
-    int splitobjects=200;//10 percent of objects special
-    int splitaccesses=100;//40 percent of accesses to special objects
-    int readPercentSecond=30;//20 percent of accesses are reads
+    int splitobjects=100;//100 percent normal objects
+    int splitaccesses=100;//100 percent access to normal objects
+    int readPercentSecond=80;//20 percent of accesses are reads
     int abortThreshold=0; //need 4 aborts to declare risky
     int abortRatio=0;//need 40% aborts vs commits to declare risky
     int deadlockdepth=10;
 
     Plot p=new Plot("plot");
+    Plot pa=new Plot("plotabort");
 
-    for(int i=1;i<30;i++) {
+    for(int i=1;i<40;i++) {
       System.out.println("i="+i);
       numThreads=i;
       Executor e=new Executor(numThreads, numTrans, deltaTrans, numObjects, numAccesses, deltaAccesses, readPercent, delay, deltaDelay, nonTrans, deltaNonTrans, splitobjects, splitaccesses, readPercentSecond);
@@ -33,7 +34,7 @@ public class TransSim {
       System.out.println("Lazy Time="+ls.getTime());
       System.out.println("Aborts="+ls.getAborts()+" Commit="+ls.getCommits());
       p.getSeries("LAZY").addPoint(i, ls.getTime());
-
+      pa.getSeries("LAZY").addPoint(i, 100.0*((double)ls.getAborts())/((double)(ls.getAborts()+ls.getCommits())));
 
       //Lock object accesses
       ls=new FlexScheduler(e, FlexScheduler.LOCK, abortThreshold, abortRatio, deadlockdepth, null);
@@ -42,6 +43,7 @@ public class TransSim {
       System.out.println("Lock Abort="+ls.getTime());
       System.out.println("Aborts="+ls.getAborts()+" Commit="+ls.getCommits());
       p.getSeries("LOCK").addPoint(i, ls.getTime());
+      pa.getSeries("LOCK").addPoint(i, 100.0*((double)ls.getAborts())/((double)(ls.getAborts()+ls.getCommits())));
 
       //Lock Commit object accesses
       ls=new FlexScheduler(e, FlexScheduler.LOCKCOMMIT, abortThreshold, abortRatio, deadlockdepth, null);
@@ -50,6 +52,7 @@ public class TransSim {
       System.out.println("LockCommit Abort="+ls.getTime());
       System.out.println("Aborts="+ls.getAborts()+" Commit="+ls.getCommits());
       p.getSeries("LOCKCOMMIT").addPoint(i, ls.getTime());
+      pa.getSeries("LOCKCOMMIT").addPoint(i, 100.0*((double)ls.getAborts())/((double)(ls.getAborts()+ls.getCommits())));
 
       //Kill others at commit
       ls=new FlexScheduler(e, FlexScheduler.COMMIT, null);
@@ -57,13 +60,15 @@ public class TransSim {
       System.out.println("Fast Abort="+ls.getTime());
       System.out.println("Aborts="+ls.getAborts()+" Commit="+ls.getCommits());
       p.getSeries("COMMIT").addPoint(i, ls.getTime());
-      
+      pa.getSeries("COMMIT").addPoint(i, 100.0*((double)ls.getAborts())/((double)(ls.getAborts()+ls.getCommits())));      
+
       //Eager attack
       ls=new FlexScheduler(e, FlexScheduler.ATTACK, null);
       ls.dosim();
       System.out.println("Attack Abort="+ls.getTime());
       System.out.println("Aborts="+ls.getAborts()+" Commit="+ls.getCommits());
       p.getSeries("ATTACK").addPoint(i, ls.getTime());
+      pa.getSeries("ATTACK").addPoint(i, 100.0*((double)ls.getAborts())/((double)(ls.getAborts()+ls.getCommits())));
 
       //Eager polite
       ls=new FlexScheduler(e, FlexScheduler.SUICIDE, null);
@@ -71,6 +76,7 @@ public class TransSim {
       System.out.println("Suicide Abort="+ls.getTime());
       System.out.println("Aborts="+ls.getAborts()+" Commit="+ls.getCommits());
       p.getSeries("SUICIDE").addPoint(i, ls.getTime());
+      pa.getSeries("SUICIDE").addPoint(i, 100.0*((double)ls.getAborts())/((double)(ls.getAborts()+ls.getCommits())));
 
       //Karma
       ls=new FlexScheduler(e, FlexScheduler.TIMESTAMP, null);
@@ -78,6 +84,7 @@ public class TransSim {
       System.out.println("Timestamp Abort="+ls.getTime());
       System.out.println("Aborts="+ls.getAborts()+" Commit="+ls.getCommits());
       p.getSeries("TIMESTAMP").addPoint(i, ls.getTime());
+      pa.getSeries("TIMESTAMP").addPoint(i, 100.0*((double)ls.getAborts())/((double)(ls.getAborts()+ls.getCommits())));
 
       //Karma
       ls=new FlexScheduler(e, FlexScheduler.RANDOM, null);
@@ -85,6 +92,7 @@ public class TransSim {
       System.out.println("Random Abort="+ls.getTime());
       System.out.println("Aborts="+ls.getAborts()+" Commit="+ls.getCommits());
       p.getSeries("RANDOM").addPoint(i, ls.getTime());
+      pa.getSeries("RANDOM").addPoint(i, 100.0*((double)ls.getAborts())/((double)(ls.getAborts()+ls.getCommits())));
 
       //Karma
       ls=new FlexScheduler(e, FlexScheduler.KARMA, null);
@@ -92,6 +100,7 @@ public class TransSim {
       System.out.println("Karma Abort="+ls.getTime());
       System.out.println("Aborts="+ls.getAborts()+" Commit="+ls.getCommits());
       p.getSeries("KARMA").addPoint(i, ls.getTime());
+      pa.getSeries("KARMA").addPoint(i, 100.0*((double)ls.getAborts())/((double)(ls.getAborts()+ls.getCommits())));
 
       //Karma
       ls=new FlexScheduler(e, FlexScheduler.POLITE, null);
@@ -99,6 +108,7 @@ public class TransSim {
       System.out.println("Polit Abort="+ls.getTime());
       System.out.println("Aborts="+ls.getAborts()+" Commit="+ls.getCommits());
       p.getSeries("POLITE").addPoint(i, ls.getTime());
+      pa.getSeries("POLITE").addPoint(i, 100.0*((double)ls.getAborts())/((double)(ls.getAborts()+ls.getCommits())));
 
       //Karma
       ls=new FlexScheduler(e, FlexScheduler.ERUPTION, null);
@@ -106,11 +116,40 @@ public class TransSim {
       System.out.println("Eruption Abort="+ls.getTime());
       System.out.println("Aborts="+ls.getAborts()+" Commit="+ls.getCommits());
       p.getSeries("ERUPTION").addPoint(i, ls.getTime());
+      pa.getSeries("ERUPTION").addPoint(i, 100.0*((double)ls.getAborts())/((double)(ls.getAborts()+ls.getCommits())));
+
+
+      //Karma
+      ls=new FlexScheduler(e, FlexScheduler.THREAD, null);
+      ls.dosim();
+      System.out.println("ThreadPriority Abort="+ls.getTime());
+      System.out.println("Aborts="+ls.getAborts()+" Commit="+ls.getCommits());
+      p.getSeries("THPRIORITY").addPoint(i, ls.getTime());
+      pa.getSeries("THPRIORITY").addPoint(i, 100.0*((double)ls.getAborts())/((double)(ls.getAborts()+ls.getCommits())));
+
+
+      //attack time
+      ls=new FlexScheduler(e, FlexScheduler.ATTACKTIME, null);
+      ls.dosim();
+      System.out.println("ThreadPriority Abort="+ls.getTime());
+      System.out.println("Aborts="+ls.getAborts()+" Commit="+ls.getCommits());
+      p.getSeries("ATTACKTIME").addPoint(i, ls.getTime());
+      pa.getSeries("ATTACKTIME").addPoint(i, 100.0*((double)ls.getAborts())/((double)(ls.getAborts()+ls.getCommits())));
+
+
+      //attack thread
+      ls=new FlexScheduler(e, FlexScheduler.ATTACKTHREAD, null);
+      ls.dosim();
+      System.out.println("ThreadPriority Abort="+ls.getTime());
+      System.out.println("Aborts="+ls.getAborts()+" Commit="+ls.getCommits());
+      p.getSeries("ATTACKTHREAD").addPoint(i, ls.getTime());
+      pa.getSeries("ATTACKTHREAD").addPoint(i, 100.0*((double)ls.getAborts())/((double)(ls.getAborts()+ls.getCommits())));
 
       //    Scheduler s=new Scheduler(e, besttime);
       //s.dosim();
       //System.out.println("Optimal Time="+s.getTime());
     }
     p.close();
+    pa.close();
   }
 }
\ No newline at end of file