Compare commits
2 Commits
660996a133
...
77b7984517
Author | SHA1 | Date |
---|---|---|
Mark Nellemann | 77b7984517 | |
Mark Nellemann | 9f67f98fec |
|
@ -1,3 +1,3 @@
|
||||||
projectId = jnetperf
|
projectId = jnetperf
|
||||||
projectGroup = biz.nellemann.jnetperf
|
projectGroup = biz.nellemann.jnetperf
|
||||||
projectVersion = 0.0.6
|
projectVersion = 0.0.7
|
||||||
|
|
|
@ -54,12 +54,16 @@ public class Application implements Callable<Integer> {
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Integer call() throws Exception {
|
public Integer call() {
|
||||||
|
|
||||||
if(runMode.runServer) {
|
try {
|
||||||
runServer();
|
if (runMode.runServer) {
|
||||||
} else if(runMode.remoteServer != null) {
|
runServer();
|
||||||
runClient(runMode.remoteServer);
|
} else if (runMode.remoteServer != null) {
|
||||||
|
runClient(runMode.remoteServer);
|
||||||
|
}
|
||||||
|
} catch (IOException | InterruptedException e) {
|
||||||
|
System.err.println(e.getMessage());
|
||||||
}
|
}
|
||||||
|
|
||||||
return 0;
|
return 0;
|
||||||
|
|
|
@ -22,7 +22,8 @@ public class TcpServer extends Thread {
|
||||||
log.info("TcpServer()");
|
log.info("TcpServer()");
|
||||||
|
|
||||||
socket = new ServerSocket(port);
|
socket = new ServerSocket(port);
|
||||||
socket.setSoTimeout(10000);
|
socket.setSoTimeout(0); // Wait indefinitely
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue