zzz/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Packages Projects Releases Wiki Activity

stat tweak

Browse Source
This commit is contained in:
zzz
2015-02-06 00:45:24 +00:00
parent 6f45242fc8
commit 1234b6b148
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
router/java/src/net/i2p/router/RouterThrottleImpl.java
View File

@@ -77,13 +77,21 @@ class RouterThrottleImpl implements RouterThrottle {
}
}
/**
* Should we accept any more data from the network for any sort of message,
* taking into account our current load, or should we simply slow down?
*
* FIXME only called by SSU Receiver, not NTCP!
* FIXME should put warning on the console
* FIXME or should we do this at all? We have Codel queues all over now...
*/
public boolean acceptNetworkMessage() {
//if (true) return true;
long lag = _context.jobQueue().getMaxLag();
if ( (lag > JOB_LAG_LIMIT) && (_context.router().getUptime() > 60*1000) ) {
if (_log.shouldLog(Log.WARN))
_log.warn("Throttling network reader, as the job lag is " + lag);
_context.statManager().addRateData("router.throttleNetworkCause", lag, lag);
_context.statManager().addRateData("router.throttleNetworkCause", lag);
return false;
} else {
return true;
@@ -96,7 +104,7 @@ class RouterThrottleImpl implements RouterThrottle {
if (lag > JOB_LAG_LIMIT) {
if (_log.shouldLog(Log.DEBUG))
_log.debug("Refusing netDb request, as the job lag is " + lag);
_context.statManager().addRateData("router.throttleNetDbCause", lag, lag);
_context.statManager().addRateData("router.throttleNetDbCause", lag);
return false;
} else {
return true;