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

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

flag as closed /after/ we send the disconnect message *cough*

parent 0324bac0
No related branches found
No related tags found
No related merge requests found
...@@ -447,7 +447,6 @@ abstract class I2PSessionImpl implements I2PSession, I2CPMessageReader.I2CPMessa ...@@ -447,7 +447,6 @@ abstract class I2PSessionImpl implements I2PSession, I2CPMessageReader.I2CPMessa
if (_closed) return; if (_closed) return;
if (_log.shouldLog(Log.DEBUG)) _log.debug("Destroy the session", new Exception("DestroySession()")); if (_log.shouldLog(Log.DEBUG)) _log.debug("Destroy the session", new Exception("DestroySession()"));
_closed = true;
if (sendDisconnect) { if (sendDisconnect) {
try { try {
_producer.disconnect(this); _producer.disconnect(this);
...@@ -455,6 +454,7 @@ abstract class I2PSessionImpl implements I2PSession, I2CPMessageReader.I2CPMessa ...@@ -455,6 +454,7 @@ abstract class I2PSessionImpl implements I2PSession, I2CPMessageReader.I2CPMessa
propogateError("Error destroying the session", ipe); propogateError("Error destroying the session", ipe);
} }
} }
_closed = true;
closeSocket(); closeSocket();
if (_sessionListener != null) _sessionListener.disconnected(this); if (_sessionListener != null) _sessionListener.disconnected(this);
} }
......
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