Author: toad
Date: 2008-02-13 00:16:09 +0000 (Wed, 13 Feb 2008)
New Revision: 17853
Modified:
trunk/freenet/src/freenet/node/LocationManager.java
Log:
Doh - actually reject!
Modified: trunk/freenet/src/freenet/node/LocationManager.java
===================================================================
--- trunk/freenet/src/freenet/node/LocationManager.java 2008-02-13 00:12:37 UTC
(rev 17852)
+++ trunk/freenet/src/freenet/node/LocationManager.java 2008-02-13 00:16:09 UTC
(rev 17853)
@@ -849,6 +849,7 @@
// receiver thread.
randomPeer.sendAsync(m, new
MyCallback(DMT.createFNPSwapRejected(oldID), pn, item), 0, null);
} catch (NotConnectedException e) {
+ if(logMINOR) Logger.minor(this, "Not connected");
// Try a different node
continue;
}
@@ -873,7 +874,7 @@
// Locked.
if(incomingMessageQueue.size() >
MAX_INCOMING_QUEUE_LENGTH) {
// Reject anyway.
- runNow = false;
+ reject = true;
swapsRejectedAlreadyLocked++;
if(logMINOR) Logger.minor(this, "Incoming queue
length too large: "+incomingMessageQueue.size()+" rejecting "+msg);
} else {
