image files

test files
source files

1 files changed, 76 insertions, 0 deletions

diff --git a/java/tests/Connection/ClientHandler.java b/java/tests/Connection/ClientHandler.java
new file mode 100644
index 00000000000..cb2bde1df85
--- /dev/null
+++ b/java/tests/Connection/ClientHandler.java
@@ -0,0 +1,76 @@
+// ============================================================================
+//
+// = PACKAGE
+//    tests.Connection
+// 
+// = FILENAME
+//    ClientHandler.java
+//
+// = AUTHOR
+//    Prashant Jain
+// 
+// ============================================================================
+package tests.Connection;
+
+import java.io.*;
+import java.net.*;
+import ACE.OS.*;
+import ACE.Connection.*;
+
+public class ClientHandler extends SvcHandler
+{
+  public ClientHandler ()
+    {
+    }
+  
+  public int open (Object obj)
+  {
+    new Thread (this).start ();
+    return 0;
+  }
+
+  public void run ()
+    {
+      DataInputStream in = new DataInputStream (System.in);
+      String msg;
+      StringBuffer ack = new StringBuffer ();
+      int ack_len;
+      try
+	{
+	  while (true)
+	    {
+	      System.out.print ("Enter input: ");
+	      System.out.flush ();
+	      msg = in.readLine ();
+	      if (msg == null)
+		break;
+	      this.peer ().send (new StringBuffer (msg));
+	      System.out.println ("Waiting for ack...");
+	      ack_len = this.peer ().recv (ack);
+	      if (ack_len == 0)
+		break;
+	      else
+		System.out.println (ack);
+	    }
+	}
+      catch (NullPointerException e)
+	{
+	  ACE.ERROR ("connection reset by peer");
+	}
+      catch (IOException e)
+	{
+	  ACE.ERROR (e);
+	}
+      finally
+	{
+	  try 
+	    {
+	      this.peer ().close ();
+	    }
+	  catch (IOException e)
+	    {
+	    }
+	}
+      
+    }
+}