diff --git a/apps/desktopgui/bundle-messages.sh b/apps/desktopgui/bundle-messages.sh index 22b6038ce..957199923 100644 --- a/apps/desktopgui/bundle-messages.sh +++ b/apps/desktopgui/bundle-messages.sh @@ -26,7 +26,7 @@ then fi # on windows, one must specify the path of commnad find -# since windows has its own retarded version of find. +# since windows has its own version of find. if which find|grep -q -i windows ; then export PATH=.:/bin:/usr/local/bin:$PATH fi diff --git a/apps/i2psnark/java/bundle-messages.sh b/apps/i2psnark/java/bundle-messages.sh index c301622ed..033e1195b 100755 --- a/apps/i2psnark/java/bundle-messages.sh +++ b/apps/i2psnark/java/bundle-messages.sh @@ -25,7 +25,7 @@ then fi # on windows, one must specify the path of commnad find -# since windows has its own retarded version of find. +# since windows has its own version of find. if which find|grep -q -i windows ; then export PATH=.:/bin:/usr/local/bin:$PATH fi diff --git a/apps/i2ptunnel/java/bundle-messages-proxy.sh b/apps/i2ptunnel/java/bundle-messages-proxy.sh index 6ee98f314..8ffdc5a9e 100755 --- a/apps/i2ptunnel/java/bundle-messages-proxy.sh +++ b/apps/i2ptunnel/java/bundle-messages-proxy.sh @@ -25,7 +25,7 @@ then fi # on windows, one must specify the path of commnad find -# since windows has its own retarded version of find. +# since windows has its own version of find. if which find|grep -q -i windows ; then export PATH=.:/bin:/usr/local/bin:$PATH fi diff --git a/apps/i2ptunnel/java/bundle-messages.sh b/apps/i2ptunnel/java/bundle-messages.sh index 9d38feebb..a8769f0dc 100755 --- a/apps/i2ptunnel/java/bundle-messages.sh +++ b/apps/i2ptunnel/java/bundle-messages.sh @@ -24,7 +24,7 @@ then fi # on windows, one must specify the path of commnad find -# since windows has its own retarded version of find. +# since windows has its own version of find. if which find|grep -q -i windows ; then export PATH=.:/bin:/usr/local/bin:$PATH fi diff --git a/apps/ministreaming/java/bundle-messages.sh b/apps/ministreaming/java/bundle-messages.sh index 37d9ae465..062deb2c8 100755 --- a/apps/ministreaming/java/bundle-messages.sh +++ b/apps/ministreaming/java/bundle-messages.sh @@ -25,7 +25,7 @@ then fi # on windows, one must specify the path of commnad find -# since windows has its own retarded version of find. +# since windows has its own version of find. if which find|grep -q -i windows ; then export PATH=.:/bin:/usr/local/bin:$PATH fi diff --git a/apps/routerconsole/java/bundle-messages-countries.sh b/apps/routerconsole/java/bundle-messages-countries.sh index aea6bf753..38bd5d186 100755 --- a/apps/routerconsole/java/bundle-messages-countries.sh +++ b/apps/routerconsole/java/bundle-messages-countries.sh @@ -25,7 +25,7 @@ then fi # on windows, one must specify the path of commnad find -# since windows has its own retarded version of find. +# since windows has its own version of find. if which find|grep -q -i windows ; then export PATH=.:/bin:/usr/local/bin:$PATH fi diff --git a/apps/routerconsole/java/bundle-messages-news.sh b/apps/routerconsole/java/bundle-messages-news.sh index e794d775c..01bf73402 100755 --- a/apps/routerconsole/java/bundle-messages-news.sh +++ b/apps/routerconsole/java/bundle-messages-news.sh @@ -25,7 +25,7 @@ then fi # on windows, one must specify the path of commnad find -# since windows has its own retarded version of find. +# since windows has its own version of find. if which find|grep -q -i windows ; then export PATH=.:/bin:/usr/local/bin:$PATH fi diff --git a/apps/routerconsole/java/bundle-messages.sh b/apps/routerconsole/java/bundle-messages.sh index 90a8a391a..d6e44060d 100755 --- a/apps/routerconsole/java/bundle-messages.sh +++ b/apps/routerconsole/java/bundle-messages.sh @@ -25,7 +25,7 @@ then fi # on windows, one must specify the path of commnad find -# since windows has its own retarded version of find. +# since windows has its own version of find. if which find|grep -q -i windows ; then export PATH=.:/bin:/usr/local/bin:$PATH fi diff --git a/apps/sam/c/src/sam.c b/apps/sam/c/src/sam.c index d95355885..d3ed8b78d 100644 --- a/apps/sam/c/src/sam.c +++ b/apps/sam/c/src/sam.c @@ -1173,9 +1173,6 @@ samerr_t sam_winsock_cleanup() */ samerr_t sam_winsock_startup() { - /* - * Is Windows retarded or what? - */ WORD wVersionRequested; WSADATA wsaData; int rc; @@ -1292,7 +1289,7 @@ const char *sam_winsock_strerror(int code) return "This is a nonrecoverable error"; case WSANO_DATA: return "Valid name, no data record of requested type"; - /* None of this shit compiles under Mingw - who knows why... + /* None of this compiles under Mingw - who knows why... case WSA_INVALID_HANDLE: return "Specified event object handle is invalid"; case WSA_INVALID_PARAMETER: diff --git a/apps/sam/perl/SAM.pm b/apps/sam/perl/SAM.pm index 54ffdc048..04b6d8eca 100644 --- a/apps/sam/perl/SAM.pm +++ b/apps/sam/perl/SAM.pm @@ -758,7 +758,7 @@ sub recv { # this means we can load more. Dangerous loop but well... while(length($self->{inbuffer}) < $self->{bytestoread}) { - # this should definately end some day + # this should definitely end some day $counter++; if($counter > 10000) { $self->log("Error: SAM::recv(): WTF, could not fill inbuffer as predicted by SAM header"); diff --git a/apps/susidns/src/bundle-messages.sh b/apps/susidns/src/bundle-messages.sh index b16b59878..02b13080b 100755 --- a/apps/susidns/src/bundle-messages.sh +++ b/apps/susidns/src/bundle-messages.sh @@ -25,7 +25,7 @@ then fi # on windows, one must specify the path of commnad find -# since windows has its own retarded version of find. +# since windows has its own version of find. if which find|grep -q -i windows ; then export PATH=.:/bin:/usr/local/bin:$PATH fi diff --git a/apps/susimail/bundle-messages.sh b/apps/susimail/bundle-messages.sh index bb57c9bea..115aafe72 100644 --- a/apps/susimail/bundle-messages.sh +++ b/apps/susimail/bundle-messages.sh @@ -25,7 +25,7 @@ then fi # on windows, one must specify the path of commnad find -# since windows has its own retarded version of find. +# since windows has its own version of find. if which find|grep -q -i windows ; then export PATH=.:/bin:/usr/local/bin:$PATH fi diff --git a/core/java/src/net/i2p/client/I2PSessionImpl.java b/core/java/src/net/i2p/client/I2PSessionImpl.java index ca193f77f..597c0af36 100644 --- a/core/java/src/net/i2p/client/I2PSessionImpl.java +++ b/core/java/src/net/i2p/client/I2PSessionImpl.java @@ -60,7 +60,7 @@ import net.i2p.util.VersionComparator; * only one thread should send messages at any given time * * Public only for clearCache(). - * Except for methods definied in I2PSession and I2CPMessageEventListener, + * Except for methods defined in I2PSession and I2CPMessageEventListener, * not maintained as a public API, not for external use. * Use I2PClientFactory to get an I2PClient and then createSession(). * diff --git a/history.txt b/history.txt index dee09afc2..79b0fdfd3 100644 --- a/history.txt +++ b/history.txt @@ -1,3 +1,9 @@ +2015-02-12 dg + * Job Queue/stats: add stat/graph for amount of scheduled jobs (router.tunnelBacklog) + * FloodfillMonitorJob: + - Use avg of router.tunnelBacklog instead of current backlog + * Some language/spelling fixes + 2015-05-11 zzz * Util: Fix corruption of cached ReusableGZIPInputStreams diff --git a/installer/resources/locale/bundle-messages.sh b/installer/resources/locale/bundle-messages.sh index bd4d5ab01..d49b553b0 100755 --- a/installer/resources/locale/bundle-messages.sh +++ b/installer/resources/locale/bundle-messages.sh @@ -19,7 +19,7 @@ then fi # on windows, one must specify the path of commnad find -# since windows has its own retarded version of find. +# since windows has its own version of find. if which find|grep -q -i windows ; then export PATH=.:/bin:/usr/local/bin:$PATH fi diff --git a/router/java/src/net/i2p/data/i2np/TunnelDataMessage.java b/router/java/src/net/i2p/data/i2np/TunnelDataMessage.java index bac9b5b3f..ce47e6aac 100644 --- a/router/java/src/net/i2p/data/i2np/TunnelDataMessage.java +++ b/router/java/src/net/i2p/data/i2np/TunnelDataMessage.java @@ -31,7 +31,7 @@ public class TunnelDataMessage extends FastI2NPMessageImpl { public final static int MESSAGE_TYPE = 18; public static final int DATA_SIZE = 1024; - /** if we can't deliver a tunnel message in 10s, fuck it */ + /** if we can't deliver a tunnel message in 10s, forget it */ private static final int EXPIRATION_PERIOD = 10*1000; private static final ByteCache _cache; diff --git a/router/java/src/net/i2p/data/i2np/TunnelGatewayMessage.java b/router/java/src/net/i2p/data/i2np/TunnelGatewayMessage.java index 7952c6df0..b25e3fccc 100644 --- a/router/java/src/net/i2p/data/i2np/TunnelGatewayMessage.java +++ b/router/java/src/net/i2p/data/i2np/TunnelGatewayMessage.java @@ -25,7 +25,7 @@ public class TunnelGatewayMessage extends FastI2NPMessageImpl { //private Exception _creator; public final static int MESSAGE_TYPE = 19; - /** if we can't deliver a tunnel message in 10s, fuck it */ + /** if we can't deliver a tunnel message in 10s, forget it */ private static final int EXPIRATION_PERIOD = 10*1000; public TunnelGatewayMessage(I2PAppContext context) { diff --git a/router/java/src/net/i2p/router/Router.java b/router/java/src/net/i2p/router/Router.java index e7e8db67e..c7db5040b 100644 --- a/router/java/src/net/i2p/router/Router.java +++ b/router/java/src/net/i2p/router/Router.java @@ -642,7 +642,6 @@ public class Router implements RouterClock.ClockShiftListener { File f = new File(filename); if (f.canRead()) { DataHelper.loadProps(props, f); - // dont be a wanker props.remove(PROP_SHUTDOWN_IN_PROGRESS); } else { if (log != null) diff --git a/router/java/src/net/i2p/router/networkdb/kademlia/FloodfillMonitorJob.java b/router/java/src/net/i2p/router/networkdb/kademlia/FloodfillMonitorJob.java index 6ea216545..a8a3cbf05 100644 --- a/router/java/src/net/i2p/router/networkdb/kademlia/FloodfillMonitorJob.java +++ b/router/java/src/net/i2p/router/networkdb/kademlia/FloodfillMonitorJob.java @@ -160,7 +160,9 @@ class FloodfillMonitorJob extends JobImpl { // For reference, the avg lifetime job lag on my Pi is 6. // Should we consider avg. dropped ff jobs? RateStat lagStat = getContext().statManager().getRate("jobQueue.jobLag"); + RateStat queueStat = getContext().statManager().getRate("router.tunnelBacklog"); happy = happy && lagStat.getRate(60*60*1000L).getAvgOrLifetimeAvg() < 25; + happy = happy && getContext().tunnelManager().queueStat.getRate(60*60*1000L).getAvgOrLifetimeAvg() < 5; happy = happy && getContext().tunnelManager().getInboundBuildQueueSize() < 5; // Only if we're pretty well integrated... happy = happy && _facade.getKnownRouters() >= 400; diff --git a/router/java/src/net/i2p/router/tasks/CoalesceStatsEvent.java b/router/java/src/net/i2p/router/tasks/CoalesceStatsEvent.java index 817847835..2ac5c5e9c 100644 --- a/router/java/src/net/i2p/router/tasks/CoalesceStatsEvent.java +++ b/router/java/src/net/i2p/router/tasks/CoalesceStatsEvent.java @@ -39,6 +39,7 @@ public class CoalesceStatsEvent implements SimpleTimer.TimedEvent { ctx.statManager().createRateStat("router.activeSendPeers", "How many peers we've sent to this minute", "Throttle", new long[] { 60*1000, 5*60*1000, 60*60*1000 }); ctx.statManager().createRequiredRateStat("router.fastPeers", _x("Known fast peers"), "Throttle", new long[] { 5*60*1000, 60*60*1000 }); ctx.statManager().createRateStat("router.integratedPeers", _x("Known integrated (floodfill) peers"), "Throttle", new long[] { 60*1000, 5*60*1000, 60*60*1000 }); + ctx.statManager().createRateStat("router.tunnelBacklog", _x("Size of tunnel acceptor backlog"), "Tunnels", new long[] { 60*1000, 5*60*1000, 60*60*1000 }); _maxMemory = Runtime.getRuntime().maxMemory(); String legend = "(Bytes)"; if (_maxMemory < Long.MAX_VALUE) @@ -68,6 +69,7 @@ public class CoalesceStatsEvent implements SimpleTimer.TimedEvent { getContext().statManager().addRateData("bw.sendRate", (long)getContext().bandwidthLimiter().getSendBps()); getContext().statManager().addRateData("bw.recvRate", (long)getContext().bandwidthLimiter().getReceiveBps()); + getContext().statManager().addRateData("router.tunnelBacklog", getContext().tunnelManager().getInboundBuildQueueSize(), 60*1000); long used = Runtime.getRuntime().totalMemory() - Runtime.getRuntime().freeMemory(); getContext().statManager().addRateData("router.memoryUsed", used); if (_maxMemory - used < LOW_MEMORY_THRESHOLD) diff --git a/router/java/src/net/i2p/router/util/PriBlockingQueue.java b/router/java/src/net/i2p/router/util/PriBlockingQueue.java index ac2cf8563..7a46741c8 100644 --- a/router/java/src/net/i2p/router/util/PriBlockingQueue.java +++ b/router/java/src/net/i2p/router/util/PriBlockingQueue.java @@ -11,7 +11,7 @@ import net.i2p.util.Log; /** * Priority Blocking Queue using methods in the entries, - * as definied in PQEntry, to store priority and sequence number, + * as defined in PQEntry, to store priority and sequence number, * ensuring FIFO order within a priority. * * Input: add(), offer(), and put() are overridden to add a sequence number. diff --git a/router/java/test/junit/net/i2p/router/tunnel/BatchedFragmentTest.java b/router/java/test/junit/net/i2p/router/tunnel/BatchedFragmentTest.java index f3ac2747b..3cc09e582 100644 --- a/router/java/test/junit/net/i2p/router/tunnel/BatchedFragmentTest.java +++ b/router/java/test/junit/net/i2p/router/tunnel/BatchedFragmentTest.java @@ -131,7 +131,7 @@ public class BatchedFragmentTest extends FragmentTest { */ public void runBatches() { //success += testBatched(1, false, false, 1024, false, false); - // this takes a long fucking time + // this takes a long long time for (int i = 1; i <= 1024; i++) { testBatched(i, false, false, 1024, false, false, 1024, false, false); testBatched(i, true, false, 1024, false, false, 1024, false, false);