I2P_Developers/i2p.itoopie
3
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

* FloodfillMonitor:

Browse Source 
- Don't become ff if clock skew is high
       - Rebuild routerinfo immediately when ff status changes
This commit is contained in:
zzz
2008-10-19 21:48:55 +00:00
parent 06be4515e4
commit a7e876da1e
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
router/java/src/net/i2p/router/networkdb/kademlia/FloodfillMonitorJob.java
View File

@ -39,8 +39,11 @@ class FloodfillMonitorJob extends JobImpl {
public String getName() { return "Monitor the floodfill pool"; } public String getName() { return "Monitor the floodfill pool"; }
public void runJob() { public void runJob() {
boolean wasFF = _facade.floodfillEnabled();
boolean ff = shouldBeFloodfill(); boolean ff = shouldBeFloodfill();
_facade.setFloodfillEnabled(ff); _facade.setFloodfillEnabled(ff);
if (ff != wasFF)
getContext().router().rebuildRouterInfo();
if (_log.shouldLog(Log.INFO)) if (_log.shouldLog(Log.INFO))
_log.info("Should we be floodfill? " + ff); _log.info("Should we be floodfill? " + ff);
requeue((REQUEUE_DELAY / 2) + getContext().random().nextInt(REQUEUE_DELAY)); requeue((REQUEUE_DELAY / 2) + getContext().random().nextInt(REQUEUE_DELAY));
@ -115,6 +118,7 @@ class FloodfillMonitorJob extends JobImpl {
happy = happy && _facade.getKnownRouters() >= 200; happy = happy && _facade.getKnownRouters() >= 200;
happy = happy && getContext().commSystem().countActivePeers() >= 50; happy = happy && getContext().commSystem().countActivePeers() >= 50;
happy = happy && getContext().tunnelManager().getParticipatingCount() >= 100; happy = happy && getContext().tunnelManager().getParticipatingCount() >= 100;
happy = happy && Math.abs(getContext().clock().getOffset()) < 10*1000;
// We need an address and no introducers // We need an address and no introducers
if (happy) { if (happy) {
RouterAddress ra = getContext().router().getRouterInfo().getTargetAddress("SSU"); RouterAddress ra = getContext().router().getRouterInfo().getTargetAddress("SSU");