Author: toad
Date: 2007-04-13 21:18:27 +0000 (Fri, 13 Apr 2007)
New Revision: 12667
Modified:
trunk/freenet/src/freenet/io/comm/Message.java
trunk/freenet/src/freenet/node/InsertHandler.java
trunk/freenet/src/freenet/node/SSKInsertHandler.java
Log:
Include bytes from message that establishes the handler
Modified: trunk/freenet/src/freenet/io/comm/Message.java
===================================================================
--- trunk/freenet/src/freenet/io/comm/Message.java 2007-04-13 21:01:32 UTC
(rev 12666)
+++ trunk/freenet/src/freenet/io/comm/Message.java 2007-04-13 21:18:27 UTC
(rev 12667)
@@ -234,4 +234,8 @@
set(DMT.TARGET_LOCATION, targetLocation);
set(DMT.HTL, htl);
}
+
+ public int receivedByteCount() {
+ return _receivedByteCount;
+ }
}
\ No newline at end of file
Modified: trunk/freenet/src/freenet/node/InsertHandler.java
===================================================================
--- trunk/freenet/src/freenet/node/InsertHandler.java 2007-04-13 21:01:32 UTC
(rev 12666)
+++ trunk/freenet/src/freenet/node/InsertHandler.java 2007-04-13 21:18:27 UTC
(rev 12667)
@@ -62,6 +62,7 @@
htl = node.maxHTL();
}
logMINOR = Logger.shouldLog(Logger.MINOR, this);
+ receivedBytes(req.receivedByteCount());
}
public String toString() {
Modified: trunk/freenet/src/freenet/node/SSKInsertHandler.java
===================================================================
--- trunk/freenet/src/freenet/node/SSKInsertHandler.java 2007-04-13
21:01:32 UTC (rev 12666)
+++ trunk/freenet/src/freenet/node/SSKInsertHandler.java 2007-04-13
21:18:27 UTC (rev 12667)
@@ -43,6 +43,7 @@
private byte[] data;
private byte[] headers;
private boolean canCommit;
+
SSKInsertHandler(Message req, long id, Node node, long startTime) {
this.req = req;
this.node = node;
@@ -65,6 +66,7 @@
headers = ((ShortBuffer) req.getObject(DMT.BLOCK_HEADERS)).getData();
canCommit = false;
logMINOR = Logger.shouldLog(Logger.MINOR, this);
+ receivedBytes(req.receivedByteCount());
}
public String toString() {
