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

[t...@freenetproject.org]

Author: toad
Date: 2008-06-25 22:48:29 +0000 (Wed, 25 Jun 2008)
New Revision: 20721

Modified:
   branches/db4o/freenet/src/freenet/client/async/InsertCompressor.java
Log:
Boost priority slightly so that insert compressed doesn't have to wait for all 
the blocks to be registered from other inserts running at the same time.

Modified: branches/db4o/freenet/src/freenet/client/async/InsertCompressor.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/async/InsertCompressor.java        
2008-06-25 21:19:44 UTC (rev 20720)
+++ branches/db4o/freenet/src/freenet/client/async/InsertCompressor.java        
2008-06-25 22:48:29 UTC (rev 20721)
@@ -95,7 +95,7 @@
                                                        
inserter.onStartCompression(phase, container, context);
                                                }

-                                       }, NativeThread.NORM_PRIORITY, false);
+                                       }, NativeThread.NORM_PRIORITY+1, false);
                                }

                                Compressor comp = 
Compressor.getCompressionAlgorithmByDifficulty(i);
@@ -131,7 +131,7 @@
                                                
container.delete(InsertCompressor.this);
                                        }

-                               }, NativeThread.NORM_PRIORITY, false);
+                               }, NativeThread.NORM_PRIORITY+1, false);
                        } else {
                                inserter.onCompressed(output, null, context);
                        }
@@ -145,7 +145,7 @@
                                                
container.delete(InsertCompressor.this);
                                        }

-                               }, NativeThread.NORM_PRIORITY, false);
+                               }, NativeThread.NORM_PRIORITY+1, false);
                        } else {
                                inserter.cb.onFailure(new 
InsertException(InsertException.BUCKET_ERROR, e, null), inserter, null, 
context);
                        }
@@ -159,7 +159,7 @@
                                                
container.delete(InsertCompressor.this);
                                        }

-                               }, NativeThread.NORM_PRIORITY, false);
+                               }, NativeThread.NORM_PRIORITY+1, false);
                        } else {
                                inserter.cb.onFailure(new 
InsertException(InsertException.BUCKET_ERROR, e, null), inserter, null, 
context);
                        }