dandri/i2p.i2p
1
0
Fork 0
mirror of https://github.com/i2p/i2p.i2p.git synced 2026-06-05 08:31:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

NetDB: refactor determination of router connection establishment

Browse Source
This commit is contained in:
eyedeekay
2024-03-26 12:40:45 -04:00
parent cdddc62fdd
commit 9e20ba7090
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
router/java/src/net/i2p/router/networkdb/kademlia/HandleFloodfillDatabaseStoreMessageJob.java
+7 -2
View File
@@ -481,7 +481,6 @@ class HandleFloodfillDatabaseStoreMessageJob extends JobImpl {
msg.setMessageId(_message.getReplyToken());
// Randomize for a little protection against clock-skew fingerprinting.
// But the "arrival" isn't used for anything, right?
// TODO just set to 0?
// TODO we have no session to garlic wrap this with, needs new message
msg.setArrival(getContext().clock().now() - getContext().random().nextInt(3*1000));
// may be null
@@ -536,7 +535,12 @@ class HandleFloodfillDatabaseStoreMessageJob extends JobImpl {
}
return;
}
boolean isEstab = getContext().commSystem().isEstablished(toPeer);
DatabaseEntry entry = _message.getEntry();
int type = entry.getType();
// only send direct for RI replies or non-tunnel
boolean isEstab = (type == DatabaseEntry.KEY_TYPE_ROUTERINFO || replyTunnel == null) &&
getContext().commSystem().isEstablished(toPeer);
/*
if (!isEstab && replyTunnel != null) {
DatabaseEntry entry = _message.getEntry();
int type = entry.getType();
@@ -589,6 +593,7 @@ class HandleFloodfillDatabaseStoreMessageJob extends JobImpl {
}
}
}
*/
if (isEstab && !_facade.isClientDb()) {
I2NPMessage out1 = msg;
I2NPMessage out2 = msg2;