Update of /cvsroot/freenet/freenet/src/freenet/message
In directory sc8-pr-cvs1:/tmp/cvs-serv13542/src/freenet/message
Modified Files:
DataRequest.java
Log Message:
6179:
Fix zab's deadlocks.
Add setTrailerStream to MessageSendCallback. Now we can theoretically send any message
fully async (we don't yet use it except in the below).
Add some new files, PeerHandler, PeerPacket, PeerPacketMessage, which will be used for
a major refactoring of ConnectionHandler and separation of the message queue into a
per-peer thing, rather than a per-connection thing. Not integrated yet, so should be
harmless.
toString(), logging. Add log messages for long messageInitialStateTime's.
Add getCipher() to CipherOutputStream, for future use in refactoring and possibly
elsewhere, and Link.encryptBytes(byte[]) for similar use.
Index: DataRequest.java
===================================================================
RCS file: /cvsroot/freenet/freenet/src/freenet/message/DataRequest.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- DataRequest.java 4 Jul 2003 06:33:00 -0000 1.3
+++ DataRequest.java 8 Sep 2003 17:03:04 -0000 1.4
@@ -50,12 +50,15 @@
public State getInitialState() {
stateTime = System.currentTimeMillis();
if(receivedTime > 1000*1000*1000) {
+ long t = stateTime - receivedTime;
Core.diagnostics.occurrenceContinuous("messageInitialStateTime",
- stateTime - receivedTime);
+ t);
+ if(t > 1000)
+ Core.logger.log(this, "Long messageInitialStateTime "+t+" : "+
+ this, Logger.NORMAL);
}
return new NewDataRequest(id);
}
-
}
_______________________________________________
cvs mailing list
[EMAIL PROTECTED]
http://dodo.freenetproject.org/cgi-bin/mailman/listinfo/cvs
