I2P Address: [http://git.idk.i2p]

Skip to content
Snippets Groups Projects
Commit 0e4b80b0 authored by jrandom's avatar jrandom Committed by zzz
Browse files

make sure we only try to request from people we know about (*cough*)

parent a460a0dc
No related branches found
No related tags found
No related merge requests found
...@@ -82,7 +82,6 @@ public class RequestTunnelJob extends JobImpl { ...@@ -82,7 +82,6 @@ public class RequestTunnelJob extends JobImpl {
_pool = pool; _pool = pool;
_tunnelGateway = tunnelGateway; _tunnelGateway = tunnelGateway;
_toBeRequested = new ArrayList();
_timeoutMs = timeoutMs; _timeoutMs = timeoutMs;
_expiration = -1; _expiration = -1;
_isInbound = isInbound; _isInbound = isInbound;
...@@ -112,8 +111,15 @@ public class RequestTunnelJob extends JobImpl { ...@@ -112,8 +111,15 @@ public class RequestTunnelJob extends JobImpl {
// work backwards (end point, then the router pointing at the endpoint, then the router pointing at that, etc, until the gateway // work backwards (end point, then the router pointing at the endpoint, then the router pointing at that, etc, until the gateway
_toBeRequested = new ArrayList(participants.size()); _toBeRequested = new ArrayList(participants.size());
for (int i = participants.size()-1; i >= 0; i--) for (int i = participants.size()-1; i >= 0; i--) {
_toBeRequested.add(participants.get(i)); TunnelInfo peer = (TunnelInfo)participants.get(i);
if (null != _context.netDb().lookupRouterInfoLocally(peer.getThisHop())) {
_toBeRequested.add(participants.get(i));
} else {
if (_log.shouldLog(Log.WARN))
_log.warn("ok who the fuck requested someone we don't know about? (dont answer that");
}
}
} }
public String getName() { return "Request Tunnel"; } public String getName() { return "Request Tunnel"; }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment