* I2CP: Correctly close internal connections on the router side

when closed by the client, was causing massive memory leak
            for internal clients using lots of sessions (thanks sponge)
This commit is contained in:
zzz
2011-02-10 15:21:23 +00:00
parent 5eb511b0bf
commit fc38d54bcb

View File

@ -42,10 +42,12 @@ public class QueuedI2CPMessageReader extends I2CPMessageReader {
I2CPMessage msg = null;
try {
msg = in.take();
if (msg.getType() == PoisonI2CPMessage.MESSAGE_TYPE)
if (msg.getType() == PoisonI2CPMessage.MESSAGE_TYPE) {
_listener.disconnected(QueuedI2CPMessageReader.this);
cancelRunner();
else
} else {
_listener.messageReceived(QueuedI2CPMessageReader.this, msg);
}
} catch (InterruptedException ie) {}
}
// ??? unused