dandri/i2p.i2p
1
0
Fork 0
mirror of https://github.com/i2p/i2p.i2p.git synced 2026-06-08 00:01:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Streaming: Allow configured max window size higher than default

Browse Source 
to allow testing of larger sizes
This commit is contained in:
zzz
2025-07-01 08:12:41 -04:00
parent 5a1f01d81d
commit 4e0d67ef23
2 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/streaming/java/src/net/i2p/client/streaming/impl/Connection.java
+4
View File
@@ -110,6 +110,10 @@ class Connection {
public static final int DEFAULT_CONNECT_TIMEOUT = 60*1000;
private static final long MAX_CONNECT_TIMEOUT = 2*60*1000;
/**
* This is the default maximum. See ConnectionOptions.setMaxWindowSize()
* where the configured maximum is enforced.
*/
public static final int MAX_WINDOW_SIZE = 128;
private static final int UNCHOKES_TO_SEND = 8;
apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionOptions.java
+6 -6
View File
@@ -425,7 +425,7 @@ class ConnectionOptions extends I2PSocketOptionsImpl {
//setWriteTimeout(getInt(opts, PROP_WRITE_TIMEOUT, -1));
setInactivityTimeout(getInt(opts, PROP_INACTIVITY_TIMEOUT, DEFAULT_INACTIVITY_TIMEOUT));
setInactivityAction(getInt(opts, PROP_INACTIVITY_ACTION, DEFAULT_INACTIVITY_ACTION));
setInboundBufferSize(getMaxMessageSize() * (Connection.MAX_WINDOW_SIZE + 2));
setInboundBufferSize(getMaxMessageSize() * (getMaxWindowSize() + 2));
setCongestionAvoidanceGrowthRateFactor(getInt(opts, PROP_CONGESTION_AVOIDANCE_GROWTH_RATE_FACTOR,
DEFAULT_CONGESTION_AVOIDANCE_GROWTH_RATE_FACTOR));
setSlowStartGrowthRateFactor(getInt(opts, PROP_SLOW_START_GROWTH_RATE_FACTOR,
@@ -487,7 +487,7 @@ class ConnectionOptions extends I2PSocketOptionsImpl {
setInactivityTimeout(getInt(opts, PROP_INACTIVITY_TIMEOUT, DEFAULT_INACTIVITY_TIMEOUT));
if (opts.getProperty(PROP_INACTIVITY_ACTION) != null)
setInactivityAction(getInt(opts, PROP_INACTIVITY_ACTION, DEFAULT_INACTIVITY_ACTION));
setInboundBufferSize(getMaxMessageSize() * (Connection.MAX_WINDOW_SIZE + 2));
setInboundBufferSize(getMaxMessageSize() * (getMaxWindowSize() + 2));
if (opts.getProperty(PROP_CONGESTION_AVOIDANCE_GROWTH_RATE_FACTOR) != null)
setCongestionAvoidanceGrowthRateFactor(getInt(opts, PROP_CONGESTION_AVOIDANCE_GROWTH_RATE_FACTOR,
DEFAULT_CONGESTION_AVOIDANCE_GROWTH_RATE_FACTOR));
@@ -843,10 +843,10 @@ class ConnectionOptions extends I2PSocketOptionsImpl {
public int getMaxWindowSize() { return _maxWindowSize; }
public void setMaxWindowSize(int msgs) {
if (msgs > Connection.MAX_WINDOW_SIZE)
_maxWindowSize = Connection.MAX_WINDOW_SIZE;
else if (msgs < 1)
_maxWindowSize = 1;
if (msgs > 2 * Connection.MAX_WINDOW_SIZE)
_maxWindowSize = 2 * Connection.MAX_WINDOW_SIZE;
else if (msgs < 2)
_maxWindowSize = 2;
else
_maxWindowSize = msgs;
}