fixed

diff --git a/Robust/src/Benchmarks/Recovery/MatrixMultiply/recovery/MatrixMultiply.java b/Robust/src/Benchmarks/Recovery/MatrixMultiply/recovery/MatrixMultiply.java
index 25c8d328d87fa03bf29aed829f3d694f5ac9d6fe..58f1e15f680f2b378e1dcbf63452574c54273b61 100644 (file)
--- a/Robust/src/Benchmarks/Recovery/MatrixMultiply/recovery/MatrixMultiply.java
+++ b/Robust/src/Benchmarks/Recovery/MatrixMultiply/recovery/MatrixMultiply.java
@@ -115,7 +115,8 @@ public class MatrixMultiply extends Task {
       ts = global new TaskSet(NUM_THREADS);
 
       for( i = 0; i< NUM_THREADS; i++) {
-        ts.threads[i] = global new Worker(ts);
+//        ts.threads[i] = global new Worker(ts);
+        ts.threads[i] = global new Worker(ts,i);
       }
     }
 
@@ -139,6 +140,7 @@ public class MatrixMultiply extends Task {
     //long st = System.currentTimeMillis();
     //long fi;
 
+    System.out.println("Starting threads...");
     Worker tmp;
     for (i = 0; i < NUM_THREADS; i++) {
       atomic {

diff --git a/Robust/src/Benchmarks/Recovery/MatrixMultiply/recovery/Worker.java b/Robust/src/Benchmarks/Recovery/MatrixMultiply/recovery/Worker.java
index 287704db75e3e47840db98d1a18cbfeffde7c327..f021f3a3dec5f69486b33af749672519c9f0f720 100644 (file)
--- a/Robust/src/Benchmarks/Recovery/MatrixMultiply/recovery/Worker.java
+++ b/Robust/src/Benchmarks/Recovery/MatrixMultiply/recovery/Worker.java
@@ -2,8 +2,9 @@ public class Worker extends Thread {
   TaskSet tasks;
   Task workingtask;
 
-  Worker(TaskSet tasks) {
+  Worker(TaskSet tasks,int mid) {
     this.tasks = tasks;
+    this.mid = mid;
   }
   
   public void run() {
@@ -11,6 +12,8 @@ public class Worker extends Thread {
     long fi = 0;
     boolean notdone=true;
 
+    System.out.println("Starts");
+
     while(notdone) {
       Task t=null;
       atomic {