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

[t...@freenetproject.org]

Author: toad
Date: 2008-06-13 16:57:38 +0000 (Fri, 13 Jun 2008)
New Revision: 20311

Modified:
   branches/db4o/freenet/src/freenet/client/FECQueue.java
Log:
Build fix for FECQueue

Modified: branches/db4o/freenet/src/freenet/client/FECQueue.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/FECQueue.java      2008-06-13 
16:11:21 UTC (rev 20310)
+++ branches/db4o/freenet/src/freenet/client/FECQueue.java      2008-06-13 
16:57:38 UTC (rev 20311)
@@ -57,7 +57,7 @@
        }

        private void queueCacheFiller() {
-               databaseJobRunner.queue(cacheFillerJob, 
NativeThread.NORM_PRIORITY);
+               databaseJobRunner.queue(cacheFillerJob, 
NativeThread.NORM_PRIORITY, false);
        }

        public void addToQueue(FECJob job, FECCodec codec, ObjectContainer 
container) {
@@ -152,7 +152,7 @@
                                                } else {
                                                        
databaseJobRunner.queue(new DBJob() {

-                                                               public void 
run(ObjectContainer container) {
+                                                               public void 
run(ObjectContainer container, ClientContext context) {
                                                                        
if(job.isADecodingJob)
                                                                                
job.callback.onDecodedSegment(container, clientContext);
                                                                        else
@@ -160,7 +160,7 @@
                                                                        
container.delete(job);
                                                                }

-                                                       }, job.priority);
+                                                       }, job.priority, false);
                                                }
                                        } catch (Throwable e) {
                                                Logger.error(this, "The 
callback failed!" + e.getMessage(), e);
@@ -184,7 +184,7 @@

        private final DBJob cacheFillerJob = new DBJob() {

-               public void run(ObjectContainer container) {
+               public void run(ObjectContainer container, ClientContext 
context) {
                        // Try to avoid accessing the database while 
synchronized on the FECQueue.
                        while(true) {
                                boolean addedAny = false;