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

Router: Only flood LS2 to router that supports it

Browse Source 
Use same version check in StoreJob for flooding
This commit is contained in:
zzz
2018-12-01 18:31:58 +00:00
parent 9efa0eaa40
commit 7c928f99ea
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
router/java/src/net/i2p/router/networkdb/kademlia/FloodfillNetworkDatabaseFacade.java
View File

@ -234,6 +234,7 @@ public class FloodfillNetworkDatabaseFacade extends KademliaNetworkDatabaseFacad
_log.info("Flooding the entry for " + key + " to " + i + " more, just before midnight"); _log.info("Flooding the entry for " + key + " to " + i + " more, just before midnight");
} }
int flooded = 0; int flooded = 0;
boolean isls2 = ds.isLeaseSet() && ds.getType() != DatabaseEntry.KEY_TYPE_LEASESET;
for (int i = 0; i < peers.size(); i++) { for (int i = 0; i < peers.size(); i++) {
Hash peer = peers.get(i); Hash peer = peers.get(i);
RouterInfo target = lookupRouterInfoLocally(peer); RouterInfo target = lookupRouterInfoLocally(peer);
@ -246,6 +247,11 @@ public class FloodfillNetworkDatabaseFacade extends KademliaNetworkDatabaseFacad
continue; continue;
if (peer.equals(_context.routerHash())) if (peer.equals(_context.routerHash()))
continue; continue;
// min version checks
if (isls2 && !StoreJob.shouldStoreLS2To(target))
continue;
if (!StoreJob.shouldStoreTo(target))
continue;
DatabaseStoreMessage msg = new DatabaseStoreMessage(_context); DatabaseStoreMessage msg = new DatabaseStoreMessage(_context);
msg.setEntry(ds); msg.setEntry(ds);
OutNetMessage m = new OutNetMessage(_context, msg, _context.clock().now()+FLOOD_TIMEOUT, FLOOD_PRIORITY, target); OutNetMessage m = new OutNetMessage(_context, msg, _context.clock().now()+FLOOD_TIMEOUT, FLOOD_PRIORITY, target);