[jbossnative-commits] JBoss Native SVN: r1964 - sandbox/mod_jk.
Author: jfrederic.clere(a)jboss.com
Date: 2008-10-20 07:53:50 -0400 (Mon, 20 Oct 2008)
New Revision: 1964
Added:
sandbox/mod_jk/PongServ.java
Log:
Server to test cping/cpong interaction.
Added: sandbox/mod_jk/PongServ.java
===================================================================
--- sandbox/mod_jk/PongServ.java (rev 0)
+++ sandbox/mod_jk/PongServ.java 2008-10-20 11:53:50 UTC (rev 1964)
@@ -0,0 +1,54 @@
+import java.io.*;
+import java.net.*;
+
+class PongServ {
+ public static void main(String[] argv)
+ {
+ int wait = 3000;
+ if (argv.length == 1)
+ wait = Integer.parseInt(argv[0]);
+ System.out.println("PongServ wait: " + wait);
+ ServerSocket serverSocket = null;
+ try {
+ serverSocket = new ServerSocket(8009);
+ } catch (IOException e) {
+ System.out.println("Could not listen on port: 8009");
+ System.exit(-1);
+ }
+ Socket clientSocket = null;
+ try {
+ clientSocket = serverSocket.accept();
+ } catch (IOException e) {
+ System.out.println("Accept failed: 8009");
+ System.exit(-1);
+ }
+ byte[] buf = new byte[1024];
+ int num;
+ byte cpong[] = { 'A' , 'B', '\0' , (byte)0x02 , (byte)0x09 };
+ InputStream clientInput = null;
+ OutputStream clientOutput = null;
+ try {
+ clientSocket.setSoTimeout(wait);
+ clientInput = clientSocket.getInputStream();
+ clientOutput = clientSocket.getOutputStream();
+ while ((num = clientInput.read(buf)) != -1) {
+ System.out.println(".");
+ }
+ System.out.println("num " + num);
+ } catch (InterruptedIOException e) {
+ e.printStackTrace();
+ } catch (IOException e) {
+ e.printStackTrace();
+ System.out.println("Could not read from port: 8009");
+ System.exit(-1);
+ }
+
+ /* write cpong */
+ try {
+ clientOutput.write(cpong);
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+
+ }
+}