From e601cedbb834cc3c4296deaecf0a3024222f0be3 Mon Sep 17 00:00:00 2001
From: jrandom <jrandom>
Date: Tue, 7 Dec 2004 01:35:53 +0000
Subject: [PATCH] 2004-12-06 jrandom * 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!)
---
.../src/net/i2p/client/streaming/ConnectionDataReceiver.java | 4 ++++
.../net/i2p/client/streaming/MessageOutputStreamTest.java | 1 +
2 files changed, 5 insertions(+)
diff --git a/apps/streaming/java/src/net/i2p/client/streaming/ConnectionDataReceiver.java b/apps/streaming/java/src/net/i2p/client/streaming/ConnectionDataReceiver.java
index 4acb1049ae..2454d5a774 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/ConnectionDataReceiver.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/ConnectionDataReceiver.java
@@ -26,6 +26,10 @@ class ConnectionDataReceiver implements MessageOutputStream.DataReceiver {
_dummyStatus = new DummyStatus();
}
+ public boolean writeInProcess() {
+ return _connection.getUnackedPacketsSent() > 0;
+ }
+
/**
* 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
diff --git a/apps/streaming/java/test/net/i2p/client/streaming/MessageOutputStreamTest.java b/apps/streaming/java/test/net/i2p/client/streaming/MessageOutputStreamTest.java
index 59386c1c99..4748440ac3 100644
--- a/apps/streaming/java/test/net/i2p/client/streaming/MessageOutputStreamTest.java
+++ b/apps/streaming/java/test/net/i2p/client/streaming/MessageOutputStreamTest.java
@@ -57,6 +57,7 @@ public class MessageOutputStreamTest {
_data.write(buf, off, size);
return new DummyWriteStatus();
}
+ public boolean writeInProcess() { return false; }
public byte[] getData() { return _data.toByteArray(); }
}
--
GitLab