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

[t...@freenetproject.org]

Author: toad
Date: 2008-02-18 14:40:34 +0000 (Mon, 18 Feb 2008)
New Revision: 18043

Modified:
   trunk/freenet/src/freenet/node/CHKInsertSender.java
   trunk/freenet/src/freenet/node/SSKInsertSender.java
Log:
CHK- and SSK- InsertSender too.

Modified: trunk/freenet/src/freenet/node/CHKInsertSender.java
===================================================================
--- trunk/freenet/src/freenet/node/CHKInsertSender.java 2008-02-18 14:38:02 UTC 
(rev 18042)
+++ trunk/freenet/src/freenet/node/CHKInsertSender.java 2008-02-18 14:40:34 UTC 
(rev 18043)
@@ -22,10 +22,11 @@
 import freenet.keys.NodeCHK;
 import freenet.support.Logger;
 import freenet.support.OOMHandler;
+import freenet.support.io.NativeThread;

-public final class CHKInsertSender implements Runnable, AnyInsertSender, 
ByteCounter {
+public final class CHKInsertSender implements PrioRunnable, AnyInsertSender, 
ByteCounter {

-       private class BackgroundTransfer implements Runnable, 
AsyncMessageFilterCallback {
+       private class BackgroundTransfer implements PrioRunnable, 
AsyncMessageFilterCallback {
                /** Node we are waiting for response from */
                final PeerNode pn;
                /** We may be sending data to that node */
@@ -156,6 +157,10 @@
                        Logger.error(this, "Restarted "+ctx+" for "+this);
                        receivedNotice(true);
                }
+
+               public int getPriority() {
+                       return NativeThread.HIGH_PRIORITY;
+               }
        }

        CHKInsertSender(NodeCHK myKey, long uid, byte[] headers, short htl, 
@@ -856,4 +861,8 @@
        public synchronized boolean startedSendingData() {
                return !backgroundTransfers.isEmpty();
        }
+
+       public int getPriority() {
+               return NativeThread.HIGH_PRIORITY;
+       }
 }

Modified: trunk/freenet/src/freenet/node/SSKInsertSender.java
===================================================================
--- trunk/freenet/src/freenet/node/SSKInsertSender.java 2008-02-18 14:38:02 UTC 
(rev 18042)
+++ trunk/freenet/src/freenet/node/SSKInsertSender.java 2008-02-18 14:40:34 UTC 
(rev 18043)
@@ -20,6 +20,7 @@
 import freenet.support.Logger;
 import freenet.support.OOMHandler;
 import freenet.support.ShortBuffer;
+import freenet.support.io.NativeThread;

 /**
  * SSKs require separate logic for inserts and requests, for various reasons:
@@ -28,7 +29,7 @@
  *   wait for a long data-transfer timeout.
  * - SSKs have pubkeys, which don't always need to be sent.
  */
-public class SSKInsertSender implements Runnable, AnyInsertSender, ByteCounter 
{
+public class SSKInsertSender implements PrioRunnable, AnyInsertSender, 
ByteCounter {

     // Constants
     static final int ACCEPTED_TIMEOUT = 10000;
@@ -556,4 +557,8 @@
                node.sentPayload(x);
        }

+       public int getPriority() {
+               return NativeThread.HIGH_PRIORITY;
+       }
+
 }