Author: toad
Date: 2009-01-12 17:23:55 +0000 (Mon, 12 Jan 2009)
New Revision: 25024

Modified:
   trunk/freenet/src/freenet/io/xfer/BlockReceiver.java
Log:
Average it


Modified: trunk/freenet/src/freenet/io/xfer/BlockReceiver.java
===================================================================
--- trunk/freenet/src/freenet/io/xfer/BlockReceiver.java        2009-01-12 
17:21:34 UTC (rev 25023)
+++ trunk/freenet/src/freenet/io/xfer/BlockReceiver.java        2009-01-12 
17:23:55 UTC (rev 25024)
@@ -34,6 +34,7 @@
 import freenet.support.BitArray;
 import freenet.support.Buffer;
 import freenet.support.Logger;
+import freenet.support.math.TrivialRunningAverage;
 
 /**
  * @author ian
@@ -167,7 +168,12 @@
                discardFilter=relevantMessages;
                maybeResetDiscardFilter();
                long endTime = System.currentTimeMillis();
-               Logger.minor(this, "Block transfer took "+(endTime - 
startTime)+"ms");
+               long transferTime = (endTime - startTime);
+               synchronized(avgTimeTaken) {
+                       avgTimeTaken.report(transferTime);
+                       Logger.minor(this, "Block transfer took 
"+transferTime+"ms - average is "+avgTimeTaken.currentValue());
+               }
+               
                return _prb.getBlock();
                } catch(NotConnectedException e) {
                    throw new 
RetrievalException(RetrievalException.SENDER_DISCONNECTED);
@@ -186,6 +192,8 @@
                }
        }
        
+       private static TrivialRunningAverage avgTimeTaken = new 
TrivialRunningAverage();
+       
        private void maybeResetDiscardFilter() {
                long timeleft=discardEndTime-System.currentTimeMillis();
                if (timeleft>0) {

_______________________________________________
cvs mailing list
[email protected]
http://emu.freenetproject.org/cgi-bin/mailman/listinfo/cvs

Reply via email to