From 5381d15a5e04156c9ca554693211cabdd3a195c8 Mon Sep 17 00:00:00 2001
From: adash <adash>
Date: Wed, 25 Oct 2006 00:02:31 +0000
Subject: [PATCH] Test file added - adash

---
 Robust/src/Tests/WebServerExample.java | 47 +++++++++++++++++++++++++
 Robust/src/Tests/WebServerSocket.java  | 48 ++++++++++++++++++++++++++
 2 files changed, 95 insertions(+)
 create mode 100644 Robust/src/Tests/WebServerExample.java
 create mode 100644 Robust/src/Tests/WebServerSocket.java

diff --git a/Robust/src/Tests/WebServerExample.java b/Robust/src/Tests/WebServerExample.java
new file mode 100644
index 00000000..c863d920
--- /dev/null
+++ b/Robust/src/Tests/WebServerExample.java
@@ -0,0 +1,47 @@
+/* Startup object is generated with the initialstate flag set by the
+ *  system to start the computation up */
+
+
+/* Create New ServerSocket*/
+
+task Startup(StartupObject s {initialstate}) {
+	System.printString("W> Starting\n");
+	ServerSocket ss=new ServerSocket(9000);
+	System.printString("W> Creating ServerSocket\n");
+	taskexit(s {!initialstate}); /* Turns initial state flag off, so this task won't refire */
+}
+
+/*Listen for a request and accept request*/ 
+task AcceptConnection(ServerSocket ss{SocketPending}) {
+	System.printString("W> Waiting for connection...\n");
+	WebServerSocket web = new WebServerSocket() {WritePending};
+	ss.accept(web);
+	System.printString("W> Connected... \n");
+}
+
+/*
+task Request(Socket s{IOPending}) {
+
+} 
+*/
+
+/* Send a Write Request to Client*/
+
+task WriteIO(WebServerSocket web{WritePending}) {
+	System.printString("W> Before doing WriteIO 0\n");
+	web.datawrite();
+	System.printString("W> After doing WriteIO\n");
+	
+//	taskexit(s {!WritePending});
+}
+
+//task ReadIO(WebServerSocket web{ReadPending}, Socket s {IOPending}) {
+/*	web.datawrite();
+	System.printString("Reading String\n");
+	taskexit(s {!ReadPending});
+}
+
+task CloseSocket(WebServerSocket web{WritePending}) {
+	web.close();
+}
+*/
diff --git a/Robust/src/Tests/WebServerSocket.java b/Robust/src/Tests/WebServerSocket.java
new file mode 100644
index 00000000..629a5785
--- /dev/null
+++ b/Robust/src/Tests/WebServerSocket.java
@@ -0,0 +1,48 @@
+public class WebServerSocket extends Socket {
+	// Websocket flag
+	flag ReadPending;
+	flag WritePending;
+	//File Descriptor
+	int fd;
+	// Buffer to store String/  
+	public byte[] buffer;
+	
+	
+
+	//Constructor
+	public WebServerSocket(){
+		System.printString("DEBUG : Calling WebServerSocket constructor\n");
+	}
+	
+	public void dataread(){		
+
+	}
+	
+	public void datawrite(){ 
+		byte[] b = new byte[10];
+		//byte x=(byte)'x'
+		b[0] =(byte)'h';
+		b[1] =(byte)'h';
+		b[2] =(byte)'e';
+		b[3] =(byte)'e';
+		b[4] =(byte)'l';
+		b[5] =(byte)'l';
+		b[6] =(byte)'l';
+		b[7] =(byte)'o';
+//		b[0] = '65';
+//		b[1] = '66';
+//		b[2] =	'67';
+//		b[3] = '68';
+//		b[4] = '69';
+		write(b);
+	}
+
+	public void responseclient(byte b){
+	//	buffer = b;
+	//	while( buffer!= null && buffer!= " ")
+	//	if (
+	}
+
+	public void close();   
+}
+
-- 
2.34.1