From 13222238ac2f86db9a15f032a2bfb052af0cface Mon Sep 17 00:00:00 2001 From: bdemsky Date: Wed, 6 Aug 2008 07:39:07 +0000 Subject: [PATCH] correction --- Robust/src/ClassLibrary/Barrier.java | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/Robust/src/ClassLibrary/Barrier.java b/Robust/src/ClassLibrary/Barrier.java index 35556326..66404cbd 100644 --- a/Robust/src/ClassLibrary/Barrier.java +++ b/Robust/src/ClassLibrary/Barrier.java @@ -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) + ; } } -- 2.34.1