zzz/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Streaming: Don't queue a message for an unknown connection on the SYN queue

Browse Source 
if it has a send ID set, it must be for a recently closed connection
This commit is contained in:
zzz
2013-09-27 01:50:38 +00:00
parent 9a00621fa4
commit 30a666c833
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
apps/streaming/java/src/net/i2p/client/streaming/PacketHandler.java
View File

@@ -105,8 +105,8 @@ class PacketHandler {
displayPacket(packet, "RECV", "wsize " + con.getOptions().getWindowSize() + " rto " + con.getOptions().getRTO()); displayPacket(packet, "RECV", "wsize " + con.getOptions().getWindowSize() + " rto " + con.getOptions().getRTO());
receiveKnownCon(con, packet); receiveKnownCon(con, packet);
} else { } else {
receiveUnknownCon(packet, sendId, queueIfNoConn);
displayPacket(packet, "UNKN", null); displayPacket(packet, "UNKN", null);
receiveUnknownCon(packet, sendId, queueIfNoConn);
} }
// Don't log here, wait until we have the conn to make the dumps easier to follow // Don't log here, wait until we have the conn to make the dumps easier to follow
//((PacketLocal)packet).logTCPDump(true); //((PacketLocal)packet).logTCPDump(true);
@@ -285,6 +285,13 @@ class PacketHandler {
return; return;
} }
} }
} else {
// if it has a send ID, it's almost certainly for a recently removed connection.
if (_log.shouldLog(Log.WARN))
_log.warn("Dropping pkt w/ send ID but no con found, recently disconnected? " + packet);
// don't bother sending reset
packet.releasePayload();
return;
} }
if (packet.isFlagSet(Packet.FLAG_SYNCHRONIZE)) { if (packet.isFlagSet(Packet.FLAG_SYNCHRONIZE)) {