X-Git-Url: http://plrg.eecs.uci.edu/git/?p=IRC.git;a=blobdiff_plain;f=Robust%2Fsrc%2FBenchmarks%2FChatJava%2FChatThread.java;fp=Robust%2Fsrc%2FBenchmarks%2FChatJava%2FChatThread.java;h=0000000000000000000000000000000000000000;hp=af0d5ade74403c5fd33e4429d76b1c9081703acd;hb=refs%2Ftags%2Fbuildscript;hpb=2f2cbbbc9385b82d891fabf62ab7e0c5cf364658

diff --git a/Robust/src/Benchmarks/ChatJava/ChatThread.java b/Robust/src/Benchmarks/ChatJava/ChatThread.java
deleted file mode 100644
index af0d5ade..00000000
--- a/Robust/src/Benchmarks/ChatJava/ChatThread.java
+++ /dev/null
@@ -1,57 +0,0 @@
-public class ChatThread extends Thread {
-    Room room;
-    String roomrequest;
-    Socket sock;
-    RoomObject ro;
-
-    public ChatThread(Socket sock, RoomObject ro) {
-	this.sock=sock;
-	this.ro=ro;
-    }
-
-    public void run() {
-	sock.write("Please choose a chatroom".getBytes());
-	ReadRequest();
-	ProcessRoom();
-	while(true)
-	    Message();
-    }
-
-    public void ReadRequest() {
-	while (!processRead())
-	    ;
-    }
-
-    private void ProcessRoom() {
-	processRoom(ro);
-    }
-
-    public void Message() {
-	byte buffer[]=new byte[1024];
-	int length=sock.read(buffer);
-	if (length>0) {
-	String st=(new String(buffer)).subString(0, length);
-	room.sendToRoom(this, st.getBytes());
-	}
-    }
-    
-    public boolean processRead() {
-        byte buffer[]=new byte[1024];
-        int length=sock.read(buffer);
-        String st=new String(buffer);
-        String curr=st.subString(0, length);
-        if (roomrequest!=null) {
-            StringBuffer sb=new StringBuffer(roomrequest);
-            sb.append(curr);
-            curr=sb.toString();
-        }
-        roomrequest=curr;
-        if (roomrequest.indexOf("\n")>=0) {
-	    return true;
-        }
-        return false;
-    }
-    public void processRoom(RoomObject ro) {
-	ro.getChatRoom(roomrequest).addParticipant(this);
-    }
-}