Author: toad
Date: 2008-01-25 17:12:32 +0000 (Fri, 25 Jan 2008)
New Revision: 17279
Modified:
trunk/freenet/src/freenet/io/comm/MessageCore.java
Log:
Clear matched before start waiting.
Modified: trunk/freenet/src/freenet/io/comm/MessageCore.java
===================================================================
--- trunk/freenet/src/freenet/io/comm/MessageCore.java 2008-01-25 17:11:58 UTC
(rev 17278)
+++ trunk/freenet/src/freenet/io/comm/MessageCore.java 2008-01-25 17:12:32 UTC
(rev 17279)
@@ -288,6 +288,7 @@
public void addAsyncFilter(MessageFilter filter,
AsyncMessageFilterCallback callback) throws DisconnectedException {
filter.setAsyncCallback(callback);
+ filter.clearMatched();
filter.onStartWaiting();
if(logMINOR) Logger.minor(this, "Adding async filter "+filter+"
for "+callback);
Message ret = null;
@@ -364,6 +365,7 @@
boolean logDEBUG = Logger.shouldLog(Logger.DEBUG, this);
if(logDEBUG) Logger.debug(this, "Waiting for "+filter);
long startTime = System.currentTimeMillis();
+ filter.clearMatched();
filter.onStartWaiting();
Message ret = null;
if(filter.anyConnectionsDropped())
