[freenet-cvs] r18056 - trunk/freenet/src/freenet/io/xfer

[t...@freenetproject.org]

Author: toad
Date: 2008-02-18 22:52:00 +0000 (Mon, 18 Feb 2008)
New Revision: 18056

Modified:
   trunk/freenet/src/freenet/io/xfer/BlockTransmitter.java
Log:
Run block transmission at priority HIGH.

Modified: trunk/freenet/src/freenet/io/xfer/BlockTransmitter.java
===================================================================
--- trunk/freenet/src/freenet/io/xfer/BlockTransmitter.java     2008-02-18 
22:38:12 UTC (rev 18055)
+++ trunk/freenet/src/freenet/io/xfer/BlockTransmitter.java     2008-02-18 
22:52:00 UTC (rev 18056)
@@ -31,11 +31,13 @@
 import freenet.io.comm.PeerContext;
 import freenet.io.comm.RetrievalException;
 import freenet.node.PeerNode;
+import freenet.node.PrioRunnable;
 import freenet.support.BitArray;
 import freenet.support.DoubleTokenBucket;
 import freenet.support.Executor;
 import freenet.support.Logger;
 import freenet.support.TimeUtil;
+import freenet.support.io.NativeThread;
 import freenet.support.transport.ip.IPUtil;

 /**
@@ -81,7 +83,7 @@
                        // Will throw on running
                }
                throttle = _destination.getThrottle();
-               _senderThread = new Runnable() {
+               _senderThread = new PrioRunnable() {

                        public void run() {
                                while (!_sendComplete) {
@@ -167,6 +169,10 @@
                                        now = System.currentTimeMillis();
                                }
                        }
+
+                       public int getPriority() {
+                               return NativeThread.HIGH_PRIORITY;
+                       }
                };
        }

@@ -306,7 +312,7 @@
         * Send the data, off-thread.
         */
        public void sendAsync(final Executor executor) {
-               executor.execute(new Runnable() {
+               executor.execute(new PrioRunnable() {
                        public void run() {
                                                 try {
                                                    
asyncExitStatus=send(executor);
@@ -316,7 +322,11 @@
                                                       
BlockTransmitter.this.notifyAll();
                                                    }
                                                 }
-                                       } },
+                                       }
+
+                       public int getPriority() {
+                               return NativeThread.HIGH_PRIORITY;
+                       } },
                        "BlockTransmitter:sendAsync() for "+this);
        }