[freenet-cvs] r21414 - branches/db4o/freenet/src/freenet/client

[t...@freenetproject.org]

Author: toad
Date: 2008-07-25 23:22:25 +0000 (Fri, 25 Jul 2008)
New Revision: 21414

Modified:
   branches/db4o/freenet/src/freenet/client/FECQueue.java
Log:
Hmmm...

Modified: branches/db4o/freenet/src/freenet/client/FECQueue.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/FECQueue.java      2008-07-25 
23:20:58 UTC (rev 21413)
+++ branches/db4o/freenet/src/freenet/client/FECQueue.java      2008-07-25 
23:22:25 UTC (rev 21414)
@@ -43,6 +43,7 @@
        private transient ClientContext clientContext;
        private transient int runningFECThreads;
        private transient int fecPoolCounter;
+       private transient PrioRunnable runner;
        private final long nodeDBHandle;

        public static FECQueue create(final long nodeDBHandle, ObjectContainer 
container) {
@@ -82,6 +83,7 @@
                        persistentQueueCache[i] = new LinkedList();
                }
                OOMHandler.addOOMHook(this);
+               initRunner();
                queueCacheFiller();
        }

@@ -138,11 +140,12 @@
                }
        }

-       /**
-        * Runs on each thread.
-        * @author nextgens
-        */
-       private final PrioRunnable runner = new PrioRunnable() {
+       private void initRunner() {
+               runner = new PrioRunnable() {
+               /**
+                * Runs on each thread.
+                * @author nextgens
+                */
                public void run() {
                        freenet.support.Logger.OSThread.logPID(this);
                        try {
@@ -225,6 +228,7 @@
                }

        };
+       }

        private final DBJob cacheFillerJob = new DBJob() {