Changeset fc38d54

Timestamp:

Feb 10, 2011 3:21:23 PM (9 years ago)

Author:

zzz <zzz@…>

Branches:

master

Children:

e68fbc0

Parents:

5eb511b

Message:

• 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)

File:

• core/java/src/net/i2p/internal/QueuedI2CPMessageReader.java (modified) (1 diff)

core/java/src/net/i2p/internal/QueuedI2CPMessageReader.java

@@ -43 +43 @@
                     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) {}
                 }