diff options
| author | Christoph Schulthess | 2017-02-13 13:18:26 +0100 |
|---|---|---|
| committer | Christoph Schulthess | 2017-02-13 13:18:26 +0100 |
| commit | df2618e13546c727895cf8038b273a778ba04182 (patch) | |
| tree | 3cec45fe94ba1e2c7c17f309e002a6387eba2758 | |
| parent | DispatchRelay class/task (diff) | |
| download | tmlite-bwlp-df2618e13546c727895cf8038b273a778ba04182.tar.gz tmlite-bwlp-df2618e13546c727895cf8038b273a778ba04182.tar.xz tmlite-bwlp-df2618e13546c727895cf8038b273a778ba04182.zip | |
DispatchRelay class/task sockets fixed
| -rw-r--r-- | src/main/java/org/openslx/taskmanager/tasks/DispatchRelay.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/main/java/org/openslx/taskmanager/tasks/DispatchRelay.java b/src/main/java/org/openslx/taskmanager/tasks/DispatchRelay.java index 4c0f6e9..470134d 100644 --- a/src/main/java/org/openslx/taskmanager/tasks/DispatchRelay.java +++ b/src/main/java/org/openslx/taskmanager/tasks/DispatchRelay.java @@ -55,7 +55,7 @@ public class DispatchRelay extends AbstractTask { } status.addMessage( "Sockets closed properly." ); } catch ( IOException iox ) { - status.addMessage( "Failed to close Sockets." + iox.getMessage() ); + status.addMessage( "Failed to close Sockets. " + iox.getMessage() ); } } return true; @@ -77,9 +77,10 @@ public class DispatchRelay extends AbstractTask { protected Thread[] createRelayThreads ( Socket[] sockets) throws IOException { Thread[] t = new Thread[2]; + Socket[][] s = {sockets, {sockets[1], sockets[0]}}; for ( int i = 0; i < 2; i++ ) { - t[i] = new Thread( new Relay( sockets, status, descs[i] )); + t[i] = new Thread( new Relay( s[i], status, descs[i] )); } return t; } |