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

Router/Tunnel: Constrain xor message ID mask to >= 0

Browse Source
This commit is contained in:
obscuratus i2p
2023-06-11 02:05:55 +00:00
committed by idk
parent 90aacc6746
commit badcf76e2f
7 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
router/java/src/net/i2p/router/TunnelPoolSettings.java
View File

@@ -8,6 +8,7 @@ import java.util.Properties;
import net.i2p.data.Base64; import net.i2p.data.Base64;
import net.i2p.data.Hash; import net.i2p.data.Hash;
import net.i2p.data.SessionKey; import net.i2p.data.SessionKey;
import net.i2p.data.i2np.I2NPMessage;
import net.i2p.util.ConcurrentHashSet; import net.i2p.util.ConcurrentHashSet;
import net.i2p.util.NativeBigInteger; import net.i2p.util.NativeBigInteger;
import net.i2p.util.RandomSource; import net.i2p.util.RandomSource;
@@ -118,7 +119,7 @@ public class TunnelPoolSettings {
_IPRestriction = DEFAULT_IP_RESTRICTION; _IPRestriction = DEFAULT_IP_RESTRICTION;
_unknownOptions = new Properties(); _unknownOptions = new Properties();
_randomKey = generateRandomKey(); _randomKey = generateRandomKey();
_msgIDBloomXor = RandomSource.getInstance().nextLong(); _msgIDBloomXor = RandomSource.getInstance().nextLong(I2NPMessage.MAX_ID_VALUE);
if (_isExploratory && !_isInbound) if (_isExploratory && !_isInbound)
_priority = EXPLORATORY_PRIORITY; _priority = EXPLORATORY_PRIORITY;

6
router/java/src/net/i2p/router/message/GarlicMessageHandler.java
View File

@@ -34,9 +34,9 @@ public class GarlicMessageHandler implements HandlerJobBuilder {
public GarlicMessageHandler(RouterContext context) { public GarlicMessageHandler(RouterContext context) {
_context = context; _context = context;
_msgIDBloomXorLocal = RandomSource.getInstance().nextLong(); _msgIDBloomXorLocal = RandomSource.getInstance().nextLong(I2NPMessage.MAX_ID_VALUE);
_msgIDBloomXorRouter = RandomSource.getInstance().nextLong(); _msgIDBloomXorRouter = RandomSource.getInstance().nextLong(I2NPMessage.MAX_ID_VALUE);
_msgIDBloomXorTunnel = RandomSource.getInstance().nextLong(); _msgIDBloomXorTunnel = RandomSource.getInstance().nextLong(I2NPMessage.MAX_ID_VALUE);
} }
public GarlicMessageHandler(RouterContext context, long msgIDBloomXorLocal, long msgIDBloomXorRouter, long msgIDBloomXorTunnel) { public GarlicMessageHandler(RouterContext context, long msgIDBloomXorLocal, long msgIDBloomXorRouter, long msgIDBloomXorTunnel) {

2
router/java/src/net/i2p/router/networkdb/kademlia/FloodfillDatabaseLookupMessageHandler.java
View File

@@ -26,7 +26,7 @@ public class FloodfillDatabaseLookupMessageHandler implements HandlerJobBuilder
private RouterContext _context; private RouterContext _context;
private FloodfillNetworkDatabaseFacade _facade; private FloodfillNetworkDatabaseFacade _facade;
private Log _log; private Log _log;
private final long _msgIDBloomXor = RandomSource.getInstance().nextLong(); private final long _msgIDBloomXor = RandomSource.getInstance().nextLong(I2NPMessage.MAX_ID_VALUE);
public FloodfillDatabaseLookupMessageHandler(RouterContext context, FloodfillNetworkDatabaseFacade facade) { public FloodfillDatabaseLookupMessageHandler(RouterContext context, FloodfillNetworkDatabaseFacade facade) {
_context = context; _context = context;

2
router/java/src/net/i2p/router/networkdb/kademlia/FloodfillDatabaseStoreMessageHandler.java
View File

@@ -24,7 +24,7 @@ import net.i2p.util.RandomSource;
public class FloodfillDatabaseStoreMessageHandler implements HandlerJobBuilder { public class FloodfillDatabaseStoreMessageHandler implements HandlerJobBuilder {
private RouterContext _context; private RouterContext _context;
private FloodfillNetworkDatabaseFacade _facade; private FloodfillNetworkDatabaseFacade _facade;
private final long _msgIDBloomXor = RandomSource.getInstance().nextLong(); private final long _msgIDBloomXor = RandomSource.getInstance().nextLong(I2NPMessage.MAX_ID_VALUE);
public FloodfillDatabaseStoreMessageHandler(RouterContext context, FloodfillNetworkDatabaseFacade facade) { public FloodfillDatabaseStoreMessageHandler(RouterContext context, FloodfillNetworkDatabaseFacade facade) {
_context = context; _context = context;

3
router/java/src/net/i2p/router/networkdb/kademlia/StartExplorersJob.java
View File

@@ -13,6 +13,7 @@ import java.util.Set;
import net.i2p.data.Hash; import net.i2p.data.Hash;
import net.i2p.data.router.RouterInfo; import net.i2p.data.router.RouterInfo;
import net.i2p.data.i2np.I2NPMessage;
import net.i2p.router.JobImpl; import net.i2p.router.JobImpl;
import net.i2p.router.Router; import net.i2p.router.Router;
import net.i2p.router.RouterContext; import net.i2p.router.RouterContext;
@@ -59,7 +60,7 @@ class StartExplorersJob extends JobImpl {
private static final long MAX_LAG = 100; private static final long MAX_LAG = 100;
private static final long MAX_MSG_DELAY = 1500; private static final long MAX_MSG_DELAY = 1500;
private final long _msgIDBloomXor = RandomSource.getInstance().nextLong(); private final long _msgIDBloomXor = RandomSource.getInstance().nextLong(I2NPMessage.MAX_ID_VALUE);
public StartExplorersJob(RouterContext context, KademliaNetworkDatabaseFacade facade) { public StartExplorersJob(RouterContext context, KademliaNetworkDatabaseFacade facade) {
super(context); super(context);

2
router/java/src/net/i2p/router/transport/TransportManager.java
View File

@@ -136,7 +136,7 @@ public class TransportManager implements TransportEventListener {
_dhThread = (_enableUDP || enableNTCP2) ? new DHSessionKeyBuilder.PrecalcRunner(context) : null; _dhThread = (_enableUDP || enableNTCP2) ? new DHSessionKeyBuilder.PrecalcRunner(context) : null;
// always created, even if NTCP2 is not enabled, because ratchet needs it // always created, even if NTCP2 is not enabled, because ratchet needs it
_xdhThread = new X25519KeyFactory(context); _xdhThread = new X25519KeyFactory(context);
_msgIDBloomXor = _context.random().nextLong(); _msgIDBloomXor = _context.random().nextLong(I2NPMessage.MAX_ID_VALUE);
} }
/** /**

2
router/java/src/net/i2p/router/tunnel/InboundMessageDistributor.java
View File

@@ -57,7 +57,7 @@ class InboundMessageDistributor implements GarlicMessageReceiver.CloveReceiver {
_msgIDBloomXor = clienttps.getMsgIdBloomXor(); _msgIDBloomXor = clienttps.getMsgIdBloomXor();
} else { } else {
_clientNickname = "NULL/Expl"; _clientNickname = "NULL/Expl";
_msgIDBloomXor = RandomSource.getInstance().nextLong(); _msgIDBloomXor = RandomSource.getInstance().nextLong(I2NPMessage.MAX_ID_VALUE);
if (_log.shouldLog(Log.DEBUG)) if (_log.shouldLog(Log.DEBUG))
_log.debug("Initializing null or exploratory InboundMessageDistributor"); _log.debug("Initializing null or exploratory InboundMessageDistributor");
} }