forked from I2P_Developers/i2p.i2p
Discard at IBGW based on router clock not system clock
This commit is contained in:
@@ -386,7 +386,7 @@ public class TunnelDispatcher implements Service {
|
|||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
public void dispatch(TunnelGatewayMessage msg) {
|
public void dispatch(TunnelGatewayMessage msg) {
|
||||||
long before = System.currentTimeMillis();
|
long before = _context.clock().now();
|
||||||
TunnelGateway gw = _inboundGateways.get(msg.getTunnelId());
|
TunnelGateway gw = _inboundGateways.get(msg.getTunnelId());
|
||||||
if (gw != null) {
|
if (gw != null) {
|
||||||
if (_log.shouldLog(Log.DEBUG))
|
if (_log.shouldLog(Log.DEBUG))
|
||||||
@@ -423,7 +423,7 @@ public class TunnelDispatcher implements Service {
|
|||||||
+ " existing = " + _inboundGateways.size(), new Exception("source"));
|
+ " existing = " + _inboundGateways.size(), new Exception("source"));
|
||||||
}
|
}
|
||||||
|
|
||||||
long dispatchTime = System.currentTimeMillis() - before;
|
long dispatchTime = _context.clock().now() - before;
|
||||||
|
|
||||||
if (_log.shouldLog(Log.DEBUG))
|
if (_log.shouldLog(Log.DEBUG))
|
||||||
_log.debug("Dispatch in gw time: " + dispatchTime + " gateway? " + gw);
|
_log.debug("Dispatch in gw time: " + dispatchTime + " gateway? " + gw);
|
||||||
|
Reference in New Issue
Block a user