correction
authorbdemsky <bdemsky>
Wed, 6 Aug 2008 07:39:07 +0000 (07:39 +0000)
committerbdemsky <bdemsky>
Wed, 6 Aug 2008 07:39:07 +0000 (07:39 +0000)
Robust/src/ClassLibrary/Barrier.java

index 35556326ba614ab3c500b1776e050e56a4a29859..66404cbd3757c4d7e7a3213fa5c005d0e82d81bd 100644 (file)
@@ -5,8 +5,8 @@ public class BarrierServer extends Thread {
        numthreads=n;
     }
     
-    public run() {
-      int n;
+    public void run() {
+       int n;
        atomic {
            n=numthreads;
        }
@@ -34,13 +34,14 @@ public class BarrierServer extends Thread {
 public class Barrier {
     Socket s;
     public Barrier(String name) {
-      s=new Socket(name, 2000);
+       s=new Socket(name, 2000);
     }
     
     public static void enterBarrier(Barrier barr) {
-      byte b[]=new byte[1];
-      s.write(b);
-      while(s.read(b)!=1)
-        ;
+       byte b[]=new byte[1];
+       b[0]=(byte)'A';
+       barr.s.write(b);
+       while(barr.s.read(b)!=1)
+           ;
     }
 }