Skip to content

Commit efe8561

Browse files
committed
multichannel works - close to finish this one - make a snapshot
1 parent c250aa7 commit efe8561

3 files changed

Lines changed: 7 additions & 2 deletions

File tree

src/net/sharksystem/hub/hubside/MultipleTCPChannelsConnectorHubSideImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ private ServerSocket getServerSocket() throws IOException {
9494
public void newConnectionCreated(CharSequence sourcePeerID, CharSequence targetPeerID,
9595
StreamPair streamPair, int timeOutDataConnection) {
9696
// tell hub - we have a new data connection and are eager to be connected with other peer
97-
Log.writeLog(this, this.toString(),"newConnectionCreated: " + sourcePeerID + "-->" + targetPeerID);
97+
Log.writeLog(this, this.toString(),"newConnectionCreated: " + sourcePeerID + " --> " + targetPeerID);
9898
try {
9999
IdleStreamPairCloser.getIdleStreamsCloser(streamPair, timeOutDataConnection).start();
100100
// a preparer would fit

src/net/sharksystem/hub/peerside/SharedTCPChannelConnectorPeerSide.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,11 @@ public final void run() {
6868
} catch (IOException e) {
6969
Log.writeLog(this, this.toString(), "newly created socket died before first usage");
7070
return;
71+
}
72+
try {
73+
Thread.sleep(100);
74+
} catch (InterruptedException e) {
75+
// ignore
7176
}
7277
*/
7378
String s = SharedTCPChannelConnectorPeerSide.this.getPeerID() + " --> " + this.peerID;

tests/net/sharksystem/hub/HubConnectorTester.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ public void notifyPeerConnected(CharSequence targetPeerID, StreamPair streamPair
7474
streamPair.getOutputStream().write(testBytes);
7575
byte[] receivedBytes = new byte[10];
7676
System.out.println(peerID + " available: " + streamPair.getInputStream().available());
77-
Thread.sleep(100); // give other process a moment
77+
//Thread.sleep(100); // give other process a moment
7878
System.out.println(peerID + " available #2: " + streamPair.getInputStream().available());
7979
streamPair.getInputStream().read(receivedBytes);
8080
System.out.println(peerID + " available #3: " + streamPair.getInputStream().available());

0 commit comments

Comments
 (0)