zzz/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Packages Projects Releases Wiki Activity

handle reclose, logging, more clear notification

Browse Source
This commit is contained in:
jrandom
2004-05-04 05:53:11 +00:00
committed by zzz
parent b04512a4f6
commit 3cac1238ed
2 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketImpl.java
View File

@@ -242,7 +242,12 @@ class I2PSocketImpl implements I2PSocket {
} }
public synchronized void notifyClosed() { public synchronized void notifyClosed() {
notifyAll(); I2PInputStream.this.notifyAll();
}
public void close() throws IOException {
super.close();
notifyClosed();
} }
} }

6
apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketManager.java
View File

@@ -322,8 +322,10 @@ public class I2PSocketManager implements I2PSessionListener {
s.internalClose(); s.internalClose();
return; return;
} else { } else {
if ( (payload.length > 0) && (_log.shouldLog(Log.WARN)) ) if ( (payload.length > 0) && (_log.shouldLog(Log.ERROR)) )
_log.warn("Disconnect packet had " + payload.length + " bytes"); _log.error("Disconnect packet had " + payload.length + " bytes");
if (s != null)
s.internalClose();
return; return;
} }
} catch (Exception t) { } catch (Exception t) {