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 an uncaught OCMOSJ exception from killing the session

Browse Source
This commit is contained in:
zzz
2019-11-20 14:54:46 +00:00
parent 398b4ceade
commit 5e67f4232a
1 changed files with 21 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
router/java/src/net/i2p/router/client/ClientMessageEventListener.java
View File

@ -454,7 +454,27 @@ class ClientMessageEventListener implements I2CPMessageReader.I2CPMessageEventLi
if (_log.shouldLog(Log.DEBUG)) if (_log.shouldLog(Log.DEBUG))
_log.debug("handleSendMessage called"); _log.debug("handleSendMessage called");
long beforeDistribute = _context.clock().now(); long beforeDistribute = _context.clock().now();
MessageId id = _runner.distributeMessage(message); MessageId id;
try {
// ClientMessagePool runs OCMOSJ inline
// don't let bugs there kill the whole session
id = _runner.distributeMessage(message);
} catch (Exception e) {
_log.error("Error sending message", e);
MessageStatusMessage status = new MessageStatusMessage();
status.setMessageId(_runner.getNextMessageId());
status.setSessionId(sid.getSessionId());
status.setSize(0);
status.setNonce(message.getNonce());
status.setStatus(MessageStatusMessage.STATUS_SEND_FAILURE_ROUTER);
try {
_runner.doSend(status);
} catch (I2CPMessageException ime) {
if (_log.shouldLog(Log.WARN))
_log.warn("Error writing out the message status message", ime);
}
return;
}
long timeToDistribute = _context.clock().now() - beforeDistribute; long timeToDistribute = _context.clock().now() - beforeDistribute;
// TODO validate session id // TODO validate session id
_runner.ackSendMessage(sid, id, message.getNonce()); _runner.ackSendMessage(sid, id, message.getNonce());