Update of /cvsroot/freenet/freenet/src/freenet
In directory sc8-pr-cvs1:/tmp/cvs-serv2155/src/freenet
Modified Files:
PeerHandler.java
Log Message:
implement a few missing diagnostic variables
Index: PeerHandler.java
===================================================================
RCS file: /cvsroot/freenet/freenet/src/freenet/PeerHandler.java,v
retrieving revision 1.47
retrieving revision 1.48
diff -u -w -r1.47 -r1.48
--- PeerHandler.java 24 Nov 2003 19:31:00 -0000 1.47
+++ PeerHandler.java 24 Nov 2003 22:27:08 -0000 1.48
@@ -5,6 +5,7 @@
import java.util.Hashtable;
import java.util.Iterator;
import java.util.LinkedList;
+import freenet.message.QueryRejected;
import freenet.node.Node;
import freenet.node.NodeReference;
import freenet.session.Link;
@@ -221,6 +222,8 @@
volatile boolean removedFromOCM = true;
Object removedFromOCMLock = new Object();
+ long lastMessageQueuedTime = -1;
+ long lastMessageQueuedTimeNoQR = -1;
long lastMessageSentTime = -1;
Object rejectOldVersionLock = new Object();
final long initialRejectOldVersionTime = 250;
@@ -713,6 +716,13 @@
Core.logger.log(this, "Discarding low priority message " + pm
+ " on " + this, Logger.MINOR);
pm.notifyFailure(null);
return;
+ }
+
+ if (lastMessageQueuedTime==-1)
lastMessageQueuedTime=System.currentTimeMillis();
+
Core.diagnostics.occurrenceContinuous("messageSendInterarrivalTime",System.currentTimeMillis()-lastMessageQueuedTime);
+ if (!(pm.msg instanceof QueryRejected)) {
+ if (lastMessageQueuedTimeNoQR==-1)
lastMessageQueuedTimeNoQR=System.currentTimeMillis();
+
Core.diagnostics.occurrenceContinuous("messageSendInterarrivalTimeNoQR",System.currentTimeMillis()-lastMessageQueuedTimeNoQR);
}
if(pm.hasTrailer()) {
_______________________________________________
cvs mailing list
[EMAIL PROTECTED]
http://dodo.freenetproject.org/cgi-bin/mailman/listinfo/cvs
