import java.net.URL;
+import be.nikiroo.utils.Version;
import be.nikiroo.utils.serial.server.ConnectActionClientObject;
import be.nikiroo.utils.serial.server.ConnectActionClientString;
import be.nikiroo.utils.serial.server.ConnectActionServerObject;
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, Version version,
+ 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 ConnectActionClientString(null, port, key) {
+ @Override
+ public void action(Version version)
+ 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];
ServerString server = new ServerString(this.getName(), 0, key) {
@Override
protected String onRequest(
- ConnectActionServerString action, String data)
- throws Exception {
+ ConnectActionServerString action, Version version,
+ String data, long id) throws Exception {
sent[0] = data;
return "pong";
}
try {
new ConnectActionClientString(null, port, key) {
@Override
- public void action() throws Exception {
+ public void action(Version version)
+ throws Exception {
recd[0] = send("ping");
}
}.connect();
ServerString server = new ServerString(this.getName(), 0, key) {
@Override
protected String onRequest(
- ConnectActionServerString action, String data)
- throws Exception {
+ ConnectActionServerString action, Version version,
+ String data, long id) throws Exception {
sent[0] = data;
action.send("pong");
sent[1] = action.rec();
try {
new ConnectActionClientString(null, port, key) {
@Override
- public void action() throws Exception {
+ public void action(Version version)
+ throws Exception {
recd[0] = send("ping");
recd[1] = send("ping2");
}
ServerString server = new ServerString(this.getName(), 0, key) {
@Override
protected String onRequest(
- ConnectActionServerString action, String data)
- throws Exception {
+ ConnectActionServerString action, Version version,
+ String data, long id) throws Exception {
sent[Integer.parseInt(data)] = data;
return "" + (Integer.parseInt(data) * 2);
}
try {
new ConnectActionClientString(null, port, key) {
@Override
- public void action() throws Exception {
+ public void action(Version version)
+ throws Exception {
for (int i = 0; i < 3; i++) {
recd[i] = send("" + i);
}
ServerObject server = new ServerObject(this.getName(), 0, key) {
@Override
protected Object onRequest(
- ConnectActionServerObject action, Object data)
- throws Exception {
+ ConnectActionServerObject action, Version version,
+ Object data, long id) throws Exception {
return null;
}
try {
new ConnectActionClientObject(null, port, key) {
@Override
- public void action() throws Exception {
+ public void action(Version version)
+ throws Exception {
rec[0] = true;
}
ServerObject server = new ServerObject(this.getName(), 0, key) {
@Override
protected Object onRequest(
- ConnectActionServerObject action, Object data)
- throws Exception {
+ ConnectActionServerObject action, Version version,
+ Object data, long id) throws Exception {
sent[0] = data;
return "pong";
}
try {
new ConnectActionClientObject(null, port, key) {
@Override
- public void action() throws Exception {
+ public void action(Version version)
+ throws Exception {
recd[0] = send("ping");
}
}.connect();
ServerObject server = new ServerObject(this.getName(), 0, key) {
@Override
protected Object onRequest(
- ConnectActionServerObject action, Object data)
- throws Exception {
+ ConnectActionServerObject action, Version version,
+ Object data, long id) throws Exception {
sent[0] = data;
action.send("pong");
sent[1] = action.rec();
try {
new ConnectActionClientObject(null, port, key) {
@Override
- public void action() throws Exception {
+ public void action(Version version)
+ throws Exception {
recd[0] = send("ping");
recd[1] = send("ping2");
}
ServerObject server = new ServerObject(this.getName(), 0, key) {
@Override
protected Object onRequest(
- ConnectActionServerObject action, Object data)
- throws Exception {
+ ConnectActionServerObject action, Version version,
+ Object data, long id) throws Exception {
sent[0] = data;
return new Object[] { "ACK" };
}
try {
new ConnectActionClientObject(null, port, key) {
@Override
- public void action() throws Exception {
+ public void action(Version version)
+ throws Exception {
recd[0] = send(new Object[] {
"key",
new URL(
ServerObject server = new ServerObject(this.getName(), 0, key) {
@Override
protected Object onRequest(
- ConnectActionServerObject action, Object data)
- throws Exception {
+ ConnectActionServerObject action, Version version,
+ Object data, long id) throws Exception {
sent[(Integer) data] = data;
return ((Integer) data) * 2;
}
try {
new ConnectActionClientObject(null, port, key) {
@Override
- public void action() throws Exception {
+ public void action(Version version)
+ throws Exception {
for (int i = 0; i < 3; i++) {
recd[i] = send(i);
}