forked from I2P_Developers/i2p.i2p
be more accepting in what router references we receive (let them be up to 6h old before throwing a hissy fit)
This commit is contained in:
@@ -171,6 +171,12 @@ public class KademliaNetworkDatabaseFacade extends NetworkDatabaseFacade {
|
|||||||
/** if we have less than 5 routers left, don't drop any more, even if they're failing or doing bad shit */
|
/** if we have less than 5 routers left, don't drop any more, even if they're failing or doing bad shit */
|
||||||
private final static int MIN_REMAINING_ROUTERS = 5;
|
private final static int MIN_REMAINING_ROUTERS = 5;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* dont accept any dbDtore of a router over 6 hours old (unless we dont
|
||||||
|
* know anyone or just started up)
|
||||||
|
*/
|
||||||
|
private final static long ROUTER_INFO_EXPIRATION = 6*60*60*1000l;
|
||||||
|
|
||||||
public KademliaNetworkDatabaseFacade(RouterContext context) {
|
public KademliaNetworkDatabaseFacade(RouterContext context) {
|
||||||
_context = context;
|
_context = context;
|
||||||
_log = _context.logManager().getLog(KademliaNetworkDatabaseFacade.class);
|
_log = _context.logManager().getLog(KademliaNetworkDatabaseFacade.class);
|
||||||
@@ -609,7 +615,7 @@ public class KademliaNetworkDatabaseFacade extends NetworkDatabaseFacade {
|
|||||||
if (_log.shouldLog(Log.WARN))
|
if (_log.shouldLog(Log.WARN))
|
||||||
_log.warn("Invalid routerInfo signature! forged router structure! router = " + routerInfo);
|
_log.warn("Invalid routerInfo signature! forged router structure! router = " + routerInfo);
|
||||||
return "Invalid routerInfo signature on " + key.toBase64();
|
return "Invalid routerInfo signature on " + key.toBase64();
|
||||||
} else if (!routerInfo.isCurrent(Router.CLOCK_FUDGE_FACTOR + ExpireRoutersJob.EXPIRE_DELAY)) {
|
} else if (!routerInfo.isCurrent(ROUTER_INFO_EXPIRATION)) {
|
||||||
long age = _context.clock().now() - routerInfo.getPublished();
|
long age = _context.clock().now() - routerInfo.getPublished();
|
||||||
int existing = _kb.size();
|
int existing = _kb.size();
|
||||||
if (existing >= MIN_REMAINING_ROUTERS) {
|
if (existing >= MIN_REMAINING_ROUTERS) {
|
||||||
|
Reference in New Issue
Block a user