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

I2CP: Prevent sending message to a local meta destination

Browse Source
This commit is contained in:
zzz
2019-06-25 13:34:59 +00:00
parent ce6551dacd
commit b52e8d6b5c
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
router/java/src/net/i2p/router/client/ClientManager.java
View File

@ -445,6 +445,15 @@ class ClientManager {
Job j = new DistributeLocal(toDest, runner, sender, fromDest, payload, msgId, messageNonce); Job j = new DistributeLocal(toDest, runner, sender, fromDest, payload, msgId, messageNonce);
//_ctx.jobQueue().addJob(j); //_ctx.jobQueue().addJob(j);
j.runJob(); j.runJob();
} else if (!_metaDests.isEmpty() && _metaDests.contains(toDest)) {
// meta dests don't have runners but are local, and you can't send to them
ClientConnectionRunner sender = getRunner(fromDest);
if (sender == null) {
// sender went away
return;
}
int rc = MessageStatusMessage.STATUS_SEND_FAILURE_BAD_LEASESET;
sender.updateMessageDeliveryStatus(fromDest, msgId, messageNonce, rc);
} else { } else {
// remote. w00t // remote. w00t
if (_log.shouldLog(Log.DEBUG)) if (_log.shouldLog(Log.DEBUG))
@ -764,7 +773,7 @@ class ClientManager {
if (_log.shouldLog(Log.WARN)) if (_log.shouldLog(Log.WARN))
_log.warn("Message received but we don't have a connection to " _log.warn("Message received but we don't have a connection to "
+ dest + "/" + _msg.getDestinationHash() + dest + "/" + _msg.getDestinationHash()
+ " currently. DROPPED"); + " currently. DROPPED", new Exception());
} }
} }
} }