oops, we need to mark the peer we don't send to as failed (otherwise we wont send any more requests out, since there will be 'too many pending')

This commit is contained in:
jrandom
2004-08-18 20:44:57 +00:00
committed by zzz
parent 0ffc0a1959
commit 4636f7be7b

View File

@@ -195,6 +195,7 @@ class SearchJob extends JobImpl {
if (_log.shouldLog(Log.WARN))
_log.warn(getJobId() + ": Error selecting closest hash that wasnt a router! "
+ peer + " : " + (ds == null ? "null" : ds.getClass().getName()));
_state.replyTimeout(peer);
} else {
sendSearch((RouterInfo)ds);
sent++;