X-Git-Url: http://demsky.eecs.uci.edu/git/?a=blobdiff_plain;f=Robust%2Fsrc%2FBenchmarks%2FChatTag%2FChatServer.java;fp=Robust%2Fsrc%2FBenchmarks%2FChatTag%2FChatServer.java;h=0000000000000000000000000000000000000000;hb=refs%2Ftags%2Fbuildscript;hp=184d75bbd756ea02c6fddb4c31edbca342e0d47a;hpb=2f2cbbbc9385b82d891fabf62ab7e0c5cf364658;p=IRC.git diff --git a/Robust/src/Benchmarks/ChatTag/ChatServer.java b/Robust/src/Benchmarks/ChatTag/ChatServer.java deleted file mode 100644 index 184d75bb..00000000 --- a/Robust/src/Benchmarks/ChatTag/ChatServer.java +++ /dev/null @@ -1,36 +0,0 @@ -task Startup(StartupObject s{initialstate}) { - System.printString("Chat Server Benchmark"); - RoomObject ro=new RoomObject() {Initialized}; - ServerSocket ss=new ServerSocket(8000); - taskexit(s{!initialstate}); -} - -task AcceptConnection(ServerSocket ss{SocketPending}) { - tag t=new tag(link); - ChatSocket cs=new ChatSocket() {Initialized}{t}; - cs.sock=ss.accept(t); - cs.sock.write("Please choose a chatroom".getBytes()); -} - -task ReadRequest(ChatSocket cs{Initialized}{link l}, Socket s{IOPending}{link l}) { - if (cs.processRead(s)) { - taskexit(cs{!Initialized, ProcessRoom}); - } -} - -task ProcessRoom(ChatSocket cs{ProcessRoom}, RoomObject ro{Initialized}) { - cs.processRoom(ro); - taskexit(cs{!ProcessRoom, InRoom}); -} - -task Message(ChatSocket cs{InRoom}{link l}, Socket s{IOPending}{link l}) { - byte buffer[]=new byte[1024]; - int length=s.read(buffer); - Message m=new Message(buffer, length, cs){}; -} - -task SendMessage(Message m{!Sent}) { - String st=(new String(m.buffer)).subString(0, m.length); - m.cs.room.sendToRoom(m.cs,st.getBytes()); - taskexit(m {Sent}); -}