Author: robert
Date: 2008-01-08 21:32:36 +0000 (Tue, 08 Jan 2008)
New Revision: 16971
Modified:
trunk/freenet/src/freenet/node/FNPPacketMangler.java
Log:
fixme
Modified: trunk/freenet/src/freenet/node/FNPPacketMangler.java
===================================================================
--- trunk/freenet/src/freenet/node/FNPPacketMangler.java 2008-01-08
19:25:23 UTC (rev 16970)
+++ trunk/freenet/src/freenet/node/FNPPacketMangler.java 2008-01-08
21:32:36 UTC (rev 16971)
@@ -1983,6 +1983,7 @@
}
int packetNumber =
kt.allocateOutgoingPacketNumberNeverBlock();
this.processOutgoingPreformatted(buf,
0, buf.length, kt, packetNumber, mi.cb, mi.alreadyReportedBytes);
+ //MARK: onSent()
mi.onSent(buf.length +
fullHeadersLengthOneMessage);
} catch (NotConnectedException e) {
Logger.normal(this, "Caught "+e+" while
sending messages ("+mi_name+") to "+pn.getPeer()+requeueLogString);
@@ -2062,6 +2063,7 @@
for(int i=0;i<messageData.length;i++) {
MessageItem mi = newMsgs[i];
mi_name = (mi.msg == null ? "(not a
Message)" : mi.msg.getSpec().getName());
+ //FIXME: This onSent() is called before
the (MARK:'d) onSent above for the same message item. Shouldn't they be
mutually exclusive?
mi.onSent(messageData[i].length + 2 +
(fullHeadersLengthMinimum / messageData.length));
}
} catch (NotConnectedException e) {
