Merge branch 'master' of github.com:nikiroo/nikiroo-utils

[fanfix.git] / src / be / nikiroo / utils / test_code / SerialServerTest.java

diff --git a/src/be/nikiroo/utils/test_code/SerialServerTest.java b/src/be/nikiroo/utils/test_code/SerialServerTest.java
index 382d9a6b5a11a7b29edc1242a58fa132bc8d3165..956499a40f3e43cac07998ffa5f9c20764b7bc70 100644 (file)
--- a/src/be/nikiroo/utils/test_code/SerialServerTest.java
+++ b/src/be/nikiroo/utils/test_code/SerialServerTest.java
@@ -43,63 +43,63 @@ class SerialServerTest extends TestLauncher {
 
                super(title + " " + skey + sbridge, args);
 
-               // addTest(new TestCase("Simple connection " + skey) {
-               // @Override
-               // public void test() throws Exception {
-               // final String[] rec = new String[1];
-               //
-               // ServerString server = new ServerString(this.getName(), 0, key) {
-               // @Override
-               // protected String onRequest(
-               // ConnectActionServerString action, String data)
-               // throws Exception {
-               // return null;
-               // }
-               //
-               // @Override
-               // protected void onError(Exception e) {
-               // }
-               // };
-               //
-               // int port = server.getPort();
-               // assertEquals("A port should have been assigned", true, port > 0);
-               //
-               // server.start();
-               //
-               // ServerBridge br = null;
-               // if (bridge) {
-               // br = new ServerBridge(0, key, "", port, key);
-               // br.setTraceHandler(null);
-               //
-               // port = br.getPort();
-               // assertEquals(
-               // "A port should have been assigned to the bridge",
-               // true, port > 0);
-               //
-               // br.start();
-               // }
-               //
-               // try {
-               // try {
-               // new ConnectActionClientObject(null, port, key) {
-               // @Override
-               // public void action() throws Exception {
-               // rec[0] = "ok";
-               // }
-               // }.connect();
-               // } finally {
-               // server.stop();
-               // }
-               // } finally {
-               // if (br != null) {
-               // br.stop();
-               // }
-               // }
-               //
-               // assertNotNull("The client action was not run", rec[0]);
-               // assertEquals("ok", rec[0]);
-               // }
-               // });
+               addTest(new TestCase("Simple connection " + skey) {
+                       @Override
+                       public void test() throws Exception {
+                               final String[] rec = new String[1];
+
+                               ServerString server = new ServerString(this.getName(), 0, key) {
+                                       @Override
+                                       protected String onRequest(
+                                                       ConnectActionServerString action, String data,
+                                                       long id) throws Exception {
+                                               return null;
+                                       }
+
+                                       @Override
+                                       protected void onError(Exception e) {
+                                       }
+                               };
+
+                               int port = server.getPort();
+                               assertEquals("A port should have been assigned", true, port > 0);
+
+                               server.start();
+
+                               ServerBridge br = null;
+                               if (bridge) {
+                                       br = new ServerBridge(0, key, "", port, key);
+                                       br.setTraceHandler(null);
+
+                                       port = br.getPort();
+                                       assertEquals(
+                                                       "A port should have been assigned to the bridge",
+                                                       true, port > 0);
+
+                                       br.start();
+                               }
+
+                               try {
+                                       try {
+                                               new ConnectActionClientObject(null, port, key) {
+                                                       @Override
+                                                       public void action() throws Exception {
+                                                               rec[0] = "ok";
+                                                       }
+                                               }.connect();
+                                       } finally {
+                                               server.stop();
+                                       }
+                               } finally {
+                                       if (br != null) {
+                                               br.stop();
+                                       }
+                               }
+
+                               assertNotNull("The client action was not run", rec[0]);
+                               assertEquals("ok", rec[0]);
+                       }
+               });
 
                addTest(new TestCase("Simple exchange " + skey) {
                        final String[] sent = new String[1];
@@ -111,8 +111,8 @@ class SerialServerTest extends TestLauncher {
                                ServerString server = new ServerString(this.getName(), 0, key) {
                                        @Override
                                        protected String onRequest(
-                                                       ConnectActionServerString action, String data)
-                                                       throws Exception {
+                                                       ConnectActionServerString action, String data,
+                                                       long id) throws Exception {
                                                sent[0] = data;
                                                return "pong";
                                        }
@@ -172,8 +172,8 @@ class SerialServerTest extends TestLauncher {
                                ServerString server = new ServerString(this.getName(), 0, key) {
                                        @Override
                                        protected String onRequest(
-                                                       ConnectActionServerString action, String data)
-                                                       throws Exception {
+                                                       ConnectActionServerString action, String data,
+                                                       long id) throws Exception {
                                                sent[0] = data;
                                                action.send("pong");
                                                sent[1] = action.rec();
@@ -238,8 +238,8 @@ class SerialServerTest extends TestLauncher {
                                ServerString server = new ServerString(this.getName(), 0, key) {
                                        @Override
                                        protected String onRequest(
-                                                       ConnectActionServerString action, String data)
-                                                       throws Exception {
+                                                       ConnectActionServerString action, String data,
+                                                       long id) throws Exception {
                                                sent[Integer.parseInt(data)] = data;
                                                return "" + (Integer.parseInt(data) * 2);
                                        }
@@ -310,8 +310,8 @@ class SerialServerTest extends TestLauncher {
                                ServerObject server = new ServerObject(this.getName(), 0, key) {
                                        @Override
                                        protected Object onRequest(
-                                                       ConnectActionServerObject action, Object data)
-                                                       throws Exception {
+                                                       ConnectActionServerObject action, Object data,
+                                                       long id) throws Exception {
                                                return null;
                                        }
 
@@ -369,8 +369,8 @@ class SerialServerTest extends TestLauncher {
                                ServerObject server = new ServerObject(this.getName(), 0, key) {
                                        @Override
                                        protected Object onRequest(
-                                                       ConnectActionServerObject action, Object data)
-                                                       throws Exception {
+                                                       ConnectActionServerObject action, Object data,
+                                                       long id) throws Exception {
                                                sent[0] = data;
                                                return "pong";
                                        }
@@ -430,8 +430,8 @@ class SerialServerTest extends TestLauncher {
                                ServerObject server = new ServerObject(this.getName(), 0, key) {
                                        @Override
                                        protected Object onRequest(
-                                                       ConnectActionServerObject action, Object data)
-                                                       throws Exception {
+                                                       ConnectActionServerObject action, Object data,
+                                                       long id) throws Exception {
                                                sent[0] = data;
                                                action.send("pong");
                                                sent[1] = action.rec();
@@ -496,8 +496,8 @@ class SerialServerTest extends TestLauncher {
                                ServerObject server = new ServerObject(this.getName(), 0, key) {
                                        @Override
                                        protected Object onRequest(
-                                                       ConnectActionServerObject action, Object data)
-                                                       throws Exception {
+                                                       ConnectActionServerObject action, Object data,
+                                                       long id) throws Exception {
                                                sent[0] = data;
                                                return new Object[] { "ACK" };
                                        }
@@ -567,8 +567,8 @@ class SerialServerTest extends TestLauncher {
                                ServerObject server = new ServerObject(this.getName(), 0, key) {
                                        @Override
                                        protected Object onRequest(
-                                                       ConnectActionServerObject action, Object data)
-                                                       throws Exception {
+                                                       ConnectActionServerObject action, Object data,
+                                                       long id) throws Exception {
                                                sent[(Integer) data] = data;
                                                return ((Integer) data) * 2;
                                        }