Author: toad
Date: 2008-05-23 17:10:02 +0000 (Fri, 23 May 2008)
New Revision: 20077
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
Log:
indenting
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
2008-05-23 17:09:25 UTC (rev 20076)
+++ branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
2008-05-23 17:10:02 UTC (rev 20077)
@@ -243,28 +243,28 @@
public void removePendingKey(final SendableGet getter, final boolean
complain, final Key key) {
if(getter.persistent()) {
- boolean dropped = schedTransient.removePendingKey(getter,
complain, key);
- if(dropped && offeredKeys != null && !node.peersWantKey(key)) {
- for(int i=0;i<offeredKeys.length;i++)
- offeredKeys[i].remove(key);
- }
- if(transientCooldownQueue != null)
- transientCooldownQueue.removeKey(key, getter,
getter.getCooldownWakeupByKey(key), null);
+ boolean dropped =
schedTransient.removePendingKey(getter, complain, key);
+ if(dropped && offeredKeys != null &&
!node.peersWantKey(key)) {
+ for(int i=0;i<offeredKeys.length;i++)
+ offeredKeys[i].remove(key);
+ }
+ if(transientCooldownQueue != null)
+ transientCooldownQueue.removeKey(key, getter,
getter.getCooldownWakeupByKey(key), null);
} else {
- // Now the persistent clients...
-
- databaseExecutor.execute(new Runnable() {
- public void run() {
- try {
- schedCore.removePendingKey(getter,
complain, key);
- if(persistentCooldownQueue != null)
-
persistentCooldownQueue.removeKey(key, getter,
getter.getCooldownWakeupByKey(key), selectorContainer);
- } catch (Throwable t) {
- Logger.error(this, "Caught "+t, t);
+ // Now the persistent clients...
+
+ databaseExecutor.execute(new Runnable() {
+ public void run() {
+ try {
+
schedCore.removePendingKey(getter, complain, key);
+ if(persistentCooldownQueue !=
null)
+
persistentCooldownQueue.removeKey(key, getter,
getter.getCooldownWakeupByKey(key), selectorContainer);
+ } catch (Throwable t) {
+ Logger.error(this, "Caught "+t,
t);
+ }
}
- }
-
- }, "removePendingKey");
+
+ }, "removePendingKey");
}
}