[freenet-cvs] r17927 - trunk/freenet/src/freenet/node

[nextg...@freenetproject.org]

Author: nextgens
Date: 2008-02-15 08:13:37 +0000 (Fri, 15 Feb 2008)
New Revision: 17927

Modified:
   trunk/freenet/src/freenet/node/PacketSender.java
Log:
PacketSender has MAX_PRIORITY

Modified: trunk/freenet/src/freenet/node/PacketSender.java
===================================================================
--- trunk/freenet/src/freenet/node/PacketSender.java    2008-02-15 08:12:01 UTC 
(rev 17926)
+++ trunk/freenet/src/freenet/node/PacketSender.java    2008-02-15 08:13:37 UTC 
(rev 17927)
@@ -17,6 +17,7 @@
 import freenet.support.Logger;
 import freenet.support.OOMHandler;
 import freenet.support.WouldBlockException;
+import freenet.support.io.NativeThread;

 /**
  * @author amphibian
@@ -44,7 +45,7 @@
        final LinkedList resendPackets;
        /** ~= Ticker :) */
        private final TreeMap timedJobsByTime;
-       final Thread myThread;
+       final NativeThread myThread;
        final Node node;
        NodeStats stats;
        long lastClearedOldSwapChains;
@@ -60,9 +61,8 @@
                resendPackets = new LinkedList();
                timedJobsByTime = new TreeMap();
                this.node = node;
-               myThread = new Thread(this, "PacketSender thread for " + 
node.getDarknetPortNumber());
+               myThread = new NativeThread(this, "PacketSender thread for " + 
node.getDarknetPortNumber(), Thread.MAX_PRIORITY);
                myThread.setDaemon(true);
-               myThread.setPriority(Thread.MAX_PRIORITY);
                logMINOR = Logger.shouldLog(Logger.MINOR, this);
                logDEBUG = Logger.shouldLog(Logger.DEBUG, this);
                rpiTemp = new Vector();