bug fix

diff --git a/Robust/src/ClassLibrary/Barrier.java b/Robust/src/ClassLibrary/Barrier.java
index 66404cbd3757c4d7e7a3213fa5c005d0e82d81bd..3f549f042ff203de3eda8f24ab37780d938304e1 100644 (file)
--- a/Robust/src/ClassLibrary/Barrier.java
+++ b/Robust/src/ClassLibrary/Barrier.java
@@ -1,16 +1,19 @@
 public class BarrierServer extends Thread {
     int numthreads;
-    
+    int done;
+
     public BarrierServer(int n) {
        numthreads=n;
+       done=0;
     }
     
     public void run() {
        int n;
+       ServerSocket ss=new ServerSocket(2000);
        atomic {
            n=numthreads;
+           done=1;
        }
-       ServerSocket ss=new ServerSocket(2000);
        Socket ar[]=new Socket[n];
        for(int i=0;i<n;i++) {
            ar[i]=ss.accept();