Author: toad
Date: 2008-09-25 22:19:46 +0000 (Thu, 25 Sep 2008)
New Revision: 22839
Modified:
trunk/freenet/src/freenet/node/Node.java
Log:
Feed incoming keys to the client layer even if we can't store them for some
reason.
Modified: trunk/freenet/src/freenet/node/Node.java
===================================================================
--- trunk/freenet/src/freenet/node/Node.java 2008-09-25 22:03:53 UTC (rev
22838)
+++ trunk/freenet/src/freenet/node/Node.java 2008-09-25 22:19:46 UTC (rev
22839)
@@ -2489,8 +2489,6 @@
}
chkDatacache.put(block);
nodeStats.avgCacheLocation.report(loc);
- if(clientCore != null && clientCore.requestStarters !=
null)
-
clientCore.requestStarters.chkFetchScheduler.tripPendingKey(block);
failureTable.onFound(block);
} catch (IOException e) {
Logger.error(this, "Cannot store data: "+e, e);
@@ -2501,6 +2499,8 @@
t.printStackTrace();
Logger.error(this, "Caught "+t+" storing data", t);
}
+ if(clientCore != null && clientCore.requestStarters != null)
+
clientCore.requestStarters.chkFetchScheduler.tripPendingKey(block);
}
/** Store the block if this is a sink. Call for inserts. */
@@ -2523,8 +2523,6 @@
sskDatastore.put(block, false);
}
sskDatacache.put(block, false);
- if(clientCore != null && clientCore.requestStarters !=
null)
-
clientCore.requestStarters.sskFetchScheduler.tripPendingKey(block);
failureTable.onFound(block);
} catch (IOException e) {
Logger.error(this, "Cannot store data: "+e, e);
@@ -2537,6 +2535,8 @@
t.printStackTrace();
Logger.error(this, "Caught "+t+" storing data", t);
}
+ if(clientCore != null && clientCore.requestStarters != null)
+
clientCore.requestStarters.sskFetchScheduler.tripPendingKey(block);
}
/**
