Author: toad
Date: 2008-04-11 14:45:19 +0000 (Fri, 11 Apr 2008)
New Revision: 19181
Modified:
trunk/freenet/src/freenet/node/PacketSender.java
Log:
Revert last commit.
Modified: trunk/freenet/src/freenet/node/PacketSender.java
===================================================================
--- trunk/freenet/src/freenet/node/PacketSender.java 2008-04-11 14:43:15 UTC
(rev 19180)
+++ trunk/freenet/src/freenet/node/PacketSender.java 2008-04-11 14:45:19 UTC
(rev 19181)
@@ -209,10 +209,8 @@
lastReceivedPacketFromAnyNode =
Math.max(pn.lastReceivedPacketTime(),
lastReceivedPacketFromAnyNode);
pn.maybeOnConnect();
- boolean sendEverything = false;
if(pn.shouldDisconnectAndRemoveNow() &&
!pn.isDisconnecting()) {
node.peers.disconnect(pn, true, false);
- sendEverything = true;
}
if(pn.isConnected()) {
@@ -302,7 +300,7 @@
l =
messages[j].submitted;
sz += 2 + /* FIXME only 2? */
messages[j].getData(pn).length;
}
- if((!sendEverything) &&
node.enablePacketCoalescing && (l + MAX_COALESCING_DELAY > now) &&
+ if(node.enablePacketCoalescing && (l +
MAX_COALESCING_DELAY > now) &&
(sz < ((PacketSocketHandler)
pn.getSocketHandler()).getPacketSendThreshold())) {
// Don't send immediately
if(nextActionTime > (l +
MAX_COALESCING_DELAY))