From bd9c6ff46320742484603ca16a0af29a909fab4e Mon Sep 17 00:00:00 2001
From: jrandom <jrandom>
Date: Tue, 25 Oct 2005 20:19:49 +0000
Subject: [PATCH] oops (allow cwin=1 for interactive streams)
---
.../src/net/i2p/client/streaming/ConnectionOptions.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/apps/streaming/java/src/net/i2p/client/streaming/ConnectionOptions.java b/apps/streaming/java/src/net/i2p/client/streaming/ConnectionOptions.java
index d75cb45759..c8babe8f4a 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/ConnectionOptions.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/ConnectionOptions.java
@@ -181,12 +181,15 @@ public class ConnectionOptions extends I2PSocketOptionsImpl {
*/
public int getWindowSize() { return _windowSize; }
public void setWindowSize(int numMsgs) {
- if (numMsgs > _maxWindowSize)
- numMsgs = _maxWindowSize;
- else if (numMsgs <= 0)
+ if (numMsgs <= 0)
numMsgs = 1;
if (numMsgs < MIN_WINDOW_SIZE)
numMsgs = MIN_WINDOW_SIZE;
+ // the stream's max window size may be less than the min window size, for
+ // instance, with interactive streams of cwin=1. This is why we test it here
+ // after checking MIN_WINDOW_SIZE
+ if (numMsgs > _maxWindowSize)
+ numMsgs = _maxWindowSize;
_windowSize = numMsgs;
}
--
GitLab