[freenet-cvs] r21457 - branches/db4o/freenet/src/freenet/client/async

[t...@freenetproject.org]

Author: toad
Date: 2008-07-28 23:18:46 +0000 (Mon, 28 Jul 2008)
New Revision: 21457

Modified:
   branches/db4o/freenet/src/freenet/client/async/InsertCompressor.java
Log:
Activation, maybe fix Cooo's second NPE

Modified: branches/db4o/freenet/src/freenet/client/async/InsertCompressor.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/async/InsertCompressor.java        
2008-07-28 23:16:46 UTC (rev 21456)
+++ branches/db4o/freenet/src/freenet/client/async/InsertCompressor.java        
2008-07-28 23:18:46 UTC (rev 21457)
@@ -128,7 +128,9 @@
                                context.jobRunner.queue(new DBJob() {

                                        public void run(ObjectContainer 
container, ClientContext context) {
+                                               container.activate(inserter, 1);
                                                inserter.onCompressed(output, 
container, context);
+                                               container.deactivate(inserter, 
1);
                                                
container.delete(InsertCompressor.this);
                                        }

@@ -153,7 +155,11 @@
                                context.jobRunner.queue(new DBJob() {

                                        public void run(ObjectContainer 
container, ClientContext context) {
+                                               container.activate(inserter, 1);
+                                               container.activate(inserter.cb, 
1);
                                                inserter.cb.onFailure(new 
InsertException(InsertException.BUCKET_ERROR, e, null), inserter, container, 
context);
+                                               
container.deactivate(inserter.cb, 1);
+                                               container.deactivate(inserter, 
1);
                                                
container.delete(InsertCompressor.this);
                                        }

@@ -167,7 +173,11 @@
                                context.jobRunner.queue(new DBJob() {

                                        public void run(ObjectContainer 
container, ClientContext context) {
+                                               container.activate(inserter, 1);
+                                               container.activate(inserter.cb, 
1);
                                                inserter.cb.onFailure(new 
InsertException(InsertException.BUCKET_ERROR, e, null), inserter, container, 
context);
+                                               
container.deactivate(inserter.cb, 1);
+                                               container.deactivate(inserter, 
1);
                                                
container.delete(InsertCompressor.this);
                                        }