From 72a9515ebd940f805d043dc0148cf21aed2837f9 Mon Sep 17 00:00:00 2001
From: bdemsky <bdemsky>
Date: Wed, 6 Aug 2008 04:12:00 +0000
Subject: [PATCH] new Barrier class

---
 Robust/src/ClassLibrary/Barrier.java | 45 ++++++++++++++++++++++++++++
 1 file changed, 45 insertions(+)
 create mode 100644 Robust/src/ClassLibrary/Barrier.java

diff --git a/Robust/src/ClassLibrary/Barrier.java b/Robust/src/ClassLibrary/Barrier.java
new file mode 100644
index 00000000..2be5dc9e
--- /dev/null
+++ b/Robust/src/ClassLibrary/Barrier.java
@@ -0,0 +1,45 @@
+public class BarrierServer extends Thread {
+    int numthreads;
+    
+    public BarrierServer(int n) {
+	numthreads=n;
+    }
+    
+    public run() {
+	atomic {
+	    n=numthreads;
+	}
+	ServerSocket ss=new ServerSocket(2000);
+	Socket ar[]=new Socket[numthreads];
+	for(int i=0;i<numthreads;i++) {
+	    ar[i]=ss.accept();
+	}
+	
+	while(true) {
+	    for(int j=0;j<numthreads;j++) {
+		Socket s=ar[j];
+		byte b[]=new byte[1];
+		while(s.read(b)!=1)
+		    ;
+	    }
+	    byte b[]=new byte[1];
+	    b[0]='A';
+	    for(int j=0;j<numthreads;j++)
+		ar[j].write(b);
+	}
+    }
+}
+
+public class Barrier {
+    Socket s;
+    public Barrier(String name) {
+	s=new Socket(name, 2000);
+    }
+    
+    public static void enterBarrier(Barrier b) {
+	byte b[]=new byte[1];
+	s.write(b);
+	while(s.read(b)!=1)
+	    ;
+    }
+}
\ No newline at end of file
-- 
2.34.1