I2P Address: [http://git.idk.i2p]

Skip to content
Snippets Groups Projects
Commit 25314fd9 authored by jrandom's avatar jrandom Committed by zzz
Browse files

make sure we mark the send as *failed* if we need to reconnect

parent 9a06a575
No related branches found
No related tags found
No related merge requests found
...@@ -65,6 +65,7 @@ class I2PSessionImpl2 extends I2PSessionImpl { ...@@ -65,6 +65,7 @@ class I2PSessionImpl2 extends I2PSessionImpl {
} }
public boolean sendMessage(Destination dest, byte[] payload) throws I2PSessionException { public boolean sendMessage(Destination dest, byte[] payload) throws I2PSessionException {
return sendMessage(dest, payload, new SessionKey(), new HashSet(64)); return sendMessage(dest, payload, new SessionKey(), new HashSet(64));
} }
...@@ -225,12 +226,12 @@ class I2PSessionImpl2 extends I2PSessionImpl { ...@@ -225,12 +226,12 @@ class I2PSessionImpl2 extends I2PSessionImpl {
_log.error("State with nonce " + state.getNonce() _log.error("State with nonce " + state.getNonce()
+ " was not accepted? (no messageId!! found=" + found + " was not accepted? (no messageId!! found=" + found
+ " msgId=" + state.getMessageId() + ")", + " msgId=" + state.getMessageId() + ")",
new Exception("Race on accept/success status messages?")); new Exception("Race on accept/success status messages, or reconnected?"));
nackTags(state); nackTags(state);
//if (_log.shouldLog(Log.CRIT)) //if (_log.shouldLog(Log.CRIT))
// _log.log(Log.CRIT, "Disconnecting/reconnecting because we never were accepted!"); // _log.log(Log.CRIT, "Disconnecting/reconnecting because we never were accepted!");
//disconnect(); //disconnect();
//return false; return false;
} }
if (_log.shouldLog(Log.DEBUG)) if (_log.shouldLog(Log.DEBUG))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment