Author: nextgens
Date: 2008-10-23 09:42:45 +0000 (Thu, 23 Oct 2008)
New Revision: 23043
Modified:
trunk/freenet/src/freenet/client/async/SingleFileInserter.java
Log:
Make OffThreadCompressor run at low-priority
Modified: trunk/freenet/src/freenet/client/async/SingleFileInserter.java
===================================================================
--- trunk/freenet/src/freenet/client/async/SingleFileInserter.java
2008-10-22 22:42:36 UTC (rev 23042)
+++ trunk/freenet/src/freenet/client/async/SingleFileInserter.java
2008-10-23 09:42:45 UTC (rev 23043)
@@ -16,6 +16,7 @@
import freenet.keys.CHKBlock;
import freenet.keys.FreenetURI;
import freenet.keys.SSKBlock;
+import freenet.node.PrioRunnable;
import freenet.support.Logger;
import freenet.support.OOMHandler;
import freenet.support.SimpleFieldSet;
@@ -24,6 +25,7 @@
import freenet.support.compress.Compressor.COMPRESSOR_TYPE;
import freenet.support.io.BucketChainBucketFactory;
import freenet.support.io.BucketTools;
+import freenet.support.io.NativeThread;
/**
* Attempt to insert a file. May include metadata.
@@ -111,7 +113,7 @@
// Of course it doesn't make any sense on multi-core systems.
private static final Object compressorSync = new Object();
- private class OffThreadCompressor implements Runnable {
+ private class OffThreadCompressor implements PrioRunnable {
public void run() {
freenet.support.Logger.OSThread.logPID(this);
try {
@@ -131,6 +133,10 @@
cb.onFailure(new
InsertException(InsertException.INTERNAL_ERROR, t, null),
SingleFileInserter.this);
}
}
+
+ public int getPriority() {
+ return NativeThread.LOW_PRIORITY;
+ }
}
private void tryCompress() throws InsertException {
