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

2004-12-06 jrandom

Browse Source 
* Don't do a 'passive flush' while there are already outbound messages
      unacked.
    * Show the reseed link if up to 10 peers profiles are active (thanks
      dburton!)
This commit is contained in:
jrandom
2004-12-07 01:35:53 +00:00
committed by zzz
parent fa12dc867f
commit e601cedbb8
2 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
apps/streaming/java/src/net/i2p/client/streaming/ConnectionDataReceiver.java
View File

@@ -26,6 +26,10 @@ class ConnectionDataReceiver implements MessageOutputStream.DataReceiver {
_dummyStatus = new DummyStatus(); _dummyStatus = new DummyStatus();
} }
public boolean writeInProcess() {
return _connection.getUnackedPacketsSent() > 0;
}
/** /**
* Send some data through the connection, or if there is no new data, this * Send some data through the connection, or if there is no new data, this
* may generate a packet with a plain ACK/NACK or CLOSE, or nothing whatsoever * may generate a packet with a plain ACK/NACK or CLOSE, or nothing whatsoever

1
apps/streaming/java/test/net/i2p/client/streaming/MessageOutputStreamTest.java
View File

@@ -57,6 +57,7 @@ public class MessageOutputStreamTest {
_data.write(buf, off, size); _data.write(buf, off, size);
return new DummyWriteStatus(); return new DummyWriteStatus();
} }
public boolean writeInProcess() { return false; }
public byte[] getData() { return _data.toByteArray(); } public byte[] getData() { return _data.toByteArray(); }
} }