forked from I2P_Developers/i2p.i2p
SSU: Don't call PS.expireInboundMessages() from messageReceived()
it's already called from IMF
This commit is contained in:
@@ -1671,13 +1671,14 @@ public class UDPTransport extends TransportImpl implements TimedWeightedPriority
|
||||
}
|
||||
}
|
||||
} else {
|
||||
if (_log.shouldLog(Log.DEBUG))
|
||||
_log.debug("Received another message: " + inMsg.getClass().getName());
|
||||
//if (_log.shouldLog(Log.DEBUG))
|
||||
// _log.debug("Received another message: " + inMsg.getClass().getName());
|
||||
}
|
||||
PeerState peer = getPeerState(remoteIdentHash);
|
||||
//PeerState peer = getPeerState(remoteIdentHash);
|
||||
super.messageReceived(inMsg, remoteIdent, remoteIdentHash, msToReceive, bytesReceived);
|
||||
if (peer != null)
|
||||
peer.expireInboundMessages();
|
||||
// Called in IMF, not needed here too
|
||||
//if (peer != null)
|
||||
// peer.expireInboundMessages();
|
||||
}
|
||||
|
||||
private class RemoveDropList implements SimpleTimer.TimedEvent {
|
||||
|
||||
Reference in New Issue
Block a user