[freenet-cvs] r23004 - branches/db4o/freenet/src/freenet/node

[t...@freenetproject.org]

Author: toad
Date: 2008-10-18 22:12:50 +0000 (Sat, 18 Oct 2008)
New Revision: 23004

Modified:
   branches/db4o/freenet/src/freenet/node/NodeRestartJobsQueue.java
Log:
Synchronization


Modified: branches/db4o/freenet/src/freenet/node/NodeRestartJobsQueue.java
===================================================================
--- branches/db4o/freenet/src/freenet/node/NodeRestartJobsQueue.java    
2008-10-18 22:08:48 UTC (rev 23003)
+++ branches/db4o/freenet/src/freenet/node/NodeRestartJobsQueue.java    
2008-10-18 22:12:50 UTC (rev 23004)
@@ -50,7 +50,7 @@

        private final Set<DBJob>[] dbJobs;

-       public void queueRestartJob(DBJob job, int priority, ObjectContainer 
container) {
+       public synchronized void queueRestartJob(DBJob job, int priority, 
ObjectContainer container) {
                container.activate(dbJobs[priority], 1);
                if(dbJobs[priority].add(job)) {
                        /*
@@ -66,7 +66,7 @@
                container.deactivate(dbJobs[priority], 1);
        }

-       public void removeRestartJob(DBJob job, int priority, ObjectContainer 
container) {
+       public synchronized void removeRestartJob(DBJob job, int priority, 
ObjectContainer container) {
                boolean jobWasActive = container.ext().isActive(job);
                if(!jobWasActive) container.activate(job, 1);
                container.activate(dbJobs[priority], 1);
@@ -107,7 +107,7 @@
                if(!jobWasActive) container.deactivate(job, 1);
        }

-       DBJob[] getRestartDatabaseJobs(ObjectContainer container) {
+       synchronized DBJob[] getRestartDatabaseJobs(ObjectContainer container) {
                ArrayList<DBJob> list = new ArrayList<DBJob>();
                for(int i=dbJobs.length-1;i>=0;i--) {
                        container.activate(dbJobs[i], 1);