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

Transports: Cache the last reachable peer

Browse Source 
Adapted from i2speed / jogger
ref: http://zzz.i2p/topics/2894 item 5
This commit is contained in:
zzz
2020-06-01 13:08:03 +00:00
parent 957767c985
commit ec231ecd78
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
router/java/src/net/i2p/router/transport/TransportImpl.java
View File

@ -61,6 +61,8 @@ public abstract class TransportImpl implements Transport {
/** map from routerIdentHash to timestamp (Long) that the peer was last unreachable */
private final Map<Hash, Long> _unreachableEntries;
private final Map<Hash, Long> _wasUnreachableEntries;
// one-entry cache for reachable check
private volatile Hash _lastReachablePeer;
private final Set<InetAddress> _localAddresses;
/** global router ident -> IP */
private static final Map<Hash, byte[]> _IPMap;
@ -851,14 +853,18 @@ public abstract class TransportImpl implements Transport {
public void mayDisconnect(Hash peer) {}
public boolean isUnreachable(Hash peer) {
if (peer == _lastReachablePeer) return false;
boolean rv;
Long when = _unreachableEntries.get(peer);
if ((rv = when != null)) {
long now = _context.clock().now();
rv = when.longValue() + UNREACHABLE_PERIOD >= now;
if (!rv) {
_lastReachablePeer = peer;
_unreachableEntries.remove(peer);
}
} else {
_lastReachablePeer = peer;
}
return rv;
}
@ -872,6 +878,8 @@ public abstract class TransportImpl implements Transport {
Long now = Long.valueOf(_context.clock().now());
// This isn't very useful since it is cleared when they contact us
_unreachableEntries.put(peer, now);
if (peer == _lastReachablePeer)
_lastReachablePeer = null;
// This is not cleared when they contact us
markWasUnreachable(peer, true);
}