From f64eacefe324aa61e7d3abb568fcafa82d5f5d24 Mon Sep 17 00:00:00 2001 From: zzz Date: Mon, 19 Nov 2012 16:06:59 +0000 Subject: [PATCH] * BuildHandler: Disable CoDel, wasn't helping --- router/java/src/net/i2p/router/tunnel/pool/BuildHandler.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/router/java/src/net/i2p/router/tunnel/pool/BuildHandler.java b/router/java/src/net/i2p/router/tunnel/pool/BuildHandler.java index 64f2cb41b..ba0b0e56b 100644 --- a/router/java/src/net/i2p/router/tunnel/pool/BuildHandler.java +++ b/router/java/src/net/i2p/router/tunnel/pool/BuildHandler.java @@ -2,6 +2,7 @@ package net.i2p.router.tunnel.pool; import java.util.List; import java.util.concurrent.BlockingQueue; +import java.util.concurrent.LinkedBlockingQueue; import net.i2p.data.Base64; import net.i2p.data.ByteArray; @@ -81,7 +82,8 @@ class BuildHandler implements Runnable { _exec = exec; // Queue size = 12 * share BW / 48K int sz = Math.min(MAX_QUEUE, Math.max(MIN_QUEUE, TunnelDispatcher.getShareBandwidth(ctx) * MIN_QUEUE / 48)); - _inboundBuildMessages = new CoDelBlockingQueue(ctx, "BuildHandler", sz); + //_inboundBuildMessages = new CoDelBlockingQueue(ctx, "BuildHandler", sz); + _inboundBuildMessages = new LinkedBlockingQueue(sz); _context.statManager().createRateStat("tunnel.reject.10", "How often we reject a tunnel probabalistically", "Tunnels", new long[] { 60*1000, 10*60*1000 }); _context.statManager().createRateStat("tunnel.reject.20", "How often we reject a tunnel because of transient overload", "Tunnels", new long[] { 60*1000, 10*60*1000 });