From 12625a46c2b4d25f307c8c4d4a1ec53cc9014f69 Mon Sep 17 00:00:00 2001 From: mkvore-commit Date: Mon, 6 Apr 2009 07:54:19 +0000 Subject: [PATCH] comment added in net.i2p.client.streaming.ConnectionHanler --- .../java/src/net/i2p/client/streaming/ConnectionHandler.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/apps/streaming/java/src/net/i2p/client/streaming/ConnectionHandler.java b/apps/streaming/java/src/net/i2p/client/streaming/ConnectionHandler.java index e53e701a1..c42491379 100644 --- a/apps/streaming/java/src/net/i2p/client/streaming/ConnectionHandler.java +++ b/apps/streaming/java/src/net/i2p/client/streaming/ConnectionHandler.java @@ -81,6 +81,8 @@ class ConnectionHandler { boolean success = _synQueue.offer(packet); // fail immediately if full if (success) { SimpleScheduler.getInstance().addEvent(new TimeoutSyn(packet), _acceptTimeout); + // advertise the new syn packet to threads that could be waiting + // (by calling waitSyn(long) if (packet.isFlagSet(Packet.FLAG_SYNCHRONIZE)) synchronized (this._synSignal) {this._synSignal.notifyAll();} } else { @@ -103,8 +105,7 @@ class ConnectionHandler { long now = this._context.clock().now() ; long expiration = now + ms ; while ( expiration > now || ms<=0 ) { - // check we have not missed a SYN packet before entering - // the lock + // check if there is a SYN packet in the queue for ( Packet p : this._synQueue ) { if ( p.isFlagSet(Packet.FLAG_SYNCHRONIZE) ) return ; }