[freenet-cvs] r16971 - trunk/freenet/src/freenet/node

[robert at freenetproject.org]

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