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

[t...@freenetproject.org]

Author: toad
Date: 2008-01-29 20:05:54 +0000 (Tue, 29 Jan 2008)
New Revision: 17400

Modified:
   trunk/freenet/src/freenet/node/SSKInsertSender.java
Log:
LocalSskInsertBytesReceivedAverage was always 0 because we called waitFor() 
with ,null instead of ,this.

Modified: trunk/freenet/src/freenet/node/SSKInsertSender.java
===================================================================
--- trunk/freenet/src/freenet/node/SSKInsertSender.java 2008-01-29 18:55:17 UTC 
(rev 17399)
+++ trunk/freenet/src/freenet/node/SSKInsertSender.java 2008-01-29 20:05:54 UTC 
(rev 17400)
@@ -191,7 +191,7 @@
             while (true) {

                                try {
-                                       msg = node.usm.waitFor(mf, null);
+                                       msg = node.usm.waitFor(mf, this);
                                } catch (DisconnectedException e) {
                                        Logger.normal(this, "Disconnected from 
" + next
                                                        + " while waiting for 
Accepted");
@@ -257,7 +257,7 @@

                Message newAck;
                                try {
-                                       newAck = node.usm.waitFor(mf1, null);
+                                       newAck = node.usm.waitFor(mf1, this);
                                } catch (DisconnectedException e) {
                                        if(logMINOR) Logger.minor(this, 
"Disconnected from "+next);
                                        htl--;
@@ -299,7 +299,7 @@

             while (true) {
                                try {
-                                       msg = node.usm.waitFor(mf, null);
+                                       msg = node.usm.waitFor(mf, this);
                                } catch (DisconnectedException e) {
                                        Logger.normal(this, "Disconnected from 
" + next
                                                        + " while waiting for 
InsertReply on " + this);