dandri/i2p.i2p
1
0 Fork 0
mirror of https://github.com/i2p/i2p.i2p.git synced 2026-10-22 21:53:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

2005-02-07 jrandom

Browse Source 
* Fixed a race in the streaming lib's delayed flush algorithm (thanks anon!)
This commit is contained in:
jrandom authored and zzz committed 2005-02-07 10:04:23 +00:00
1 parent 27e92653fe
commit b366a4b942
3 files changed
+7 -4
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

apps/streaming/java/src/net/i2p/client/streaming/MessageOutputStream.java
+1 -1
View File
@@ -198,7 +198,7 @@ public class MessageOutputStream extends OutputStream {
WriteStatus ws = null;
synchronized (_dataLock) {
long flushTime = _lastBuffered + _passiveFlushDelay;
if ( (_valid > 0) && (flushTime < _context.clock().now()) ) {
if ( (_valid > 0) && (flushTime <= _context.clock().now()) ) {
if (_log.shouldLog(Log.DEBUG))
_log.debug("doFlush() valid = " + _valid);
if ( (_buf != null) && (_dataReceiver != null) ) {