forked from I2P_Developers/i2p.i2p
*cough* (oops)
This commit is contained in:
@@ -50,7 +50,7 @@ public class SendMessageDirectJob extends JobImpl {
|
|||||||
_message = message;
|
_message = message;
|
||||||
_targetHash = toPeer;
|
_targetHash = toPeer;
|
||||||
_router = null;
|
_router = null;
|
||||||
if (timeoutMs <= 30) {
|
if (timeoutMs <= 30*1000) {
|
||||||
_expiration = ctx.clock().now() + 30*1000;
|
_expiration = ctx.clock().now() + 30*1000;
|
||||||
} else {
|
} else {
|
||||||
_expiration = timeoutMs + ctx.clock().now();
|
_expiration = timeoutMs + ctx.clock().now();
|
||||||
|
@@ -85,7 +85,7 @@ public class SendTunnelMessageJob extends JobImpl {
|
|||||||
new Exception("SendTunnel from"));
|
new Exception("SendTunnel from"));
|
||||||
}
|
}
|
||||||
//_log.info("Send tunnel message " + msg.getClass().getName() + " to " + _destRouter + " over " + _tunnelId + " targetting tunnel " + _targetTunnelId, new Exception("SendTunnel from"));
|
//_log.info("Send tunnel message " + msg.getClass().getName() + " to " + _destRouter + " over " + _tunnelId + " targetting tunnel " + _targetTunnelId, new Exception("SendTunnel from"));
|
||||||
if (timeoutMs < 30) {
|
if (timeoutMs < 30*1000) {
|
||||||
_expiration = getContext().clock().now() + 30*1000;
|
_expiration = getContext().clock().now() + 30*1000;
|
||||||
} else {
|
} else {
|
||||||
_expiration = getContext().clock().now() + timeoutMs;
|
_expiration = getContext().clock().now() + timeoutMs;
|
||||||
|
Reference in New Issue
Block a user