forked from I2P_Developers/i2p.i2p
generics and final
This commit is contained in:
@@ -167,10 +167,10 @@ public class FloodfillNetworkDatabaseFacade extends KademliaNetworkDatabaseFacad
|
|||||||
Hash key = ds.getHash();
|
Hash key = ds.getHash();
|
||||||
Hash rkey = _context.routingKeyGenerator().getRoutingKey(key);
|
Hash rkey = _context.routingKeyGenerator().getRoutingKey(key);
|
||||||
FloodfillPeerSelector sel = (FloodfillPeerSelector)getPeerSelector();
|
FloodfillPeerSelector sel = (FloodfillPeerSelector)getPeerSelector();
|
||||||
List peers = sel.selectFloodfillParticipants(rkey, MAX_TO_FLOOD, getKBuckets());
|
List<Hash> peers = sel.selectFloodfillParticipants(rkey, MAX_TO_FLOOD, getKBuckets());
|
||||||
int flooded = 0;
|
int flooded = 0;
|
||||||
for (int i = 0; i < peers.size(); i++) {
|
for (int i = 0; i < peers.size(); i++) {
|
||||||
Hash peer = (Hash)peers.get(i);
|
Hash peer = peers.get(i);
|
||||||
RouterInfo target = lookupRouterInfoLocally(peer);
|
RouterInfo target = lookupRouterInfoLocally(peer);
|
||||||
if ( (target == null) || (_context.shitlist().isShitlisted(peer)) )
|
if ( (target == null) || (_context.shitlist().isShitlisted(peer)) )
|
||||||
continue;
|
continue;
|
||||||
|
@@ -29,11 +29,11 @@ import net.i2p.util.Log;
|
|||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
public class HandleFloodfillDatabaseStoreMessageJob extends JobImpl {
|
public class HandleFloodfillDatabaseStoreMessageJob extends JobImpl {
|
||||||
private Log _log;
|
private final Log _log;
|
||||||
private DatabaseStoreMessage _message;
|
private final DatabaseStoreMessage _message;
|
||||||
private RouterIdentity _from;
|
private final RouterIdentity _from;
|
||||||
private Hash _fromHash;
|
private Hash _fromHash;
|
||||||
private FloodfillNetworkDatabaseFacade _facade;
|
private final FloodfillNetworkDatabaseFacade _facade;
|
||||||
|
|
||||||
public HandleFloodfillDatabaseStoreMessageJob(RouterContext ctx, DatabaseStoreMessage receivedMessage, RouterIdentity from, Hash fromHash, FloodfillNetworkDatabaseFacade facade) {
|
public HandleFloodfillDatabaseStoreMessageJob(RouterContext ctx, DatabaseStoreMessage receivedMessage, RouterIdentity from, Hash fromHash, FloodfillNetworkDatabaseFacade facade) {
|
||||||
super(ctx);
|
super(ctx);
|
||||||
|
Reference in New Issue
Block a user