I2P_Developers/i2p.itoopie
3
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

if we reach this point, bump up the expiration if necessary (otherwise the fast expire will occur with small clock skews)

Browse Source
This commit is contained in:
jrandom
2004-08-12 03:24:44 +00:00
committed by zzz
parent ebdc7d70a1
commit f1ce1b5361
1 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
router/java/src/net/i2p/router/message/SendMessageDirectJob.java
View File

@ -73,12 +73,6 @@ public class SendMessageDirectJob extends JobImpl {
public void runJob() { public void runJob() {
long now = getContext().clock().now(); long now = getContext().clock().now();
if (_expiration - 30*1000 < now) {
if (_log.shouldLog(Log.INFO))
_log.info("Soon to expire sendDirect of " + _message.getClass().getName()
+ " [expiring in " + (_expiration-now) + "]", getAddedBy());
}
if (_expiration < now - Router.CLOCK_FUDGE_FACTOR) { if (_expiration < now - Router.CLOCK_FUDGE_FACTOR) {
if (_log.shouldLog(Log.ERROR)) if (_log.shouldLog(Log.ERROR))
_log.error("Timed out sending message " + _message + " directly (expiration = " _log.error("Timed out sending message " + _message + " directly (expiration = "
@ -87,6 +81,17 @@ public class SendMessageDirectJob extends JobImpl {
getContext().jobQueue().addJob(_onFail); getContext().jobQueue().addJob(_onFail);
return; return;
} }
if (_expiration - 30*1000 < now) {
if (_log.shouldLog(Log.INFO))
_log.info("Soon to expire sendDirect of " + _message.getClass().getName()
+ " [expiring in " + (_expiration-now) + "]", getAddedBy());
// if its made it this far, we want to honor it, so make sure we give it
// enough time to be sent out
_expiration += 30*1000;
}
if (_router != null) { if (_router != null) {
if (_log.shouldLog(Log.DEBUG)) if (_log.shouldLog(Log.DEBUG))
_log.debug("Router specified, sending"); _log.debug("Router specified, sending");