From: bdemsky <bdemsky>
Date: Fri, 25 Jun 2010 20:05:43 +0000 (+0000)
Subject: updates to transsim for journal submission
X-Git-Url: http://plrg.eecs.uci.edu/git/?p=IRC.git;a=commitdiff_plain;h=4d5e76706d06e3cf8ff4baf7fe08c203cfe893c7

updates to transsim for journal submission
---

diff --git a/Robust/TransSim/FileSim.java b/Robust/TransSim/FileSim.java
index 4154e772..f7825847 100644
--- 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 d1d9ef02..af8f40d8 100644
--- 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 9509ea05..92dc9ae1 100644
--- 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 48812c5d..8deff3f0 100644
--- 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 896b8bd8..8e2cb951 100644
--- 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