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

[t...@freenetproject.org]

Author: toad
Date: 2008-02-16 18:26:36 +0000 (Sat, 16 Feb 2008)
New Revision: 18005

Modified:
   trunk/freenet/src/freenet/node/NodeDispatcher.java
   trunk/freenet/src/freenet/node/ResettingHTLProbeRequestSender.java
Log:
Run RequestSender etc at HIGH_PRIORITY.

Modified: trunk/freenet/src/freenet/node/NodeDispatcher.java
===================================================================
--- trunk/freenet/src/freenet/node/NodeDispatcher.java  2008-02-16 18:24:23 UTC 
(rev 18004)
+++ trunk/freenet/src/freenet/node/NodeDispatcher.java  2008-02-16 18:26:36 UTC 
(rev 18005)
@@ -19,6 +19,7 @@
 import freenet.support.Fields;
 import freenet.support.Logger;
 import freenet.support.ShortBuffer;
+import freenet.support.io.NativeThread;

 /**
  * @author amphibian
@@ -323,7 +324,7 @@
                }
                //if(!node.lockUID(id)) return false;
                RequestHandler rh = new RequestHandler(m, source, id, node, 
htl, key);
-               node.executor.execute(rh, "RequestHandler for UID "+id+" on 
"+node.getDarknetPortNumber());
+               node.executor.execute(rh, "RequestHandler for UID "+id+" on 
"+node.getDarknetPortNumber(), NativeThread.HIGH_PRIORITY);
                return true;
        }

@@ -364,10 +365,10 @@
                long now = System.currentTimeMillis();
                if(m.getSpec().equals(DMT.FNPSSKInsertRequest)) {
                        SSKInsertHandler rh = new SSKInsertHandler(m, source, 
id, node, now);
-                       node.executor.execute(rh, "SSKInsertHandler for "+id+" 
on "+node.getDarknetPortNumber());
+                       node.executor.execute(rh, "SSKInsertHandler for "+id+" 
on "+node.getDarknetPortNumber(), NativeThread.HIGH_PRIORITY);
                } else {
                        CHKInsertHandler rh = new CHKInsertHandler(m, source, 
id, node, now);
-                       node.executor.execute(rh, "CHKInsertHandler for "+id+" 
on "+node.getDarknetPortNumber());
+                       node.executor.execute(rh, "CHKInsertHandler for "+id+" 
on "+node.getDarknetPortNumber(), NativeThread.HIGH_PRIORITY);
                }
                if(logMINOR) Logger.minor(this, "Started InsertHandler for 
"+id);
                return true;
@@ -448,7 +449,7 @@
                                return true;
                        }
                        AnnounceSender sender = new AnnounceSender(m, uid, 
source, om, node);
-                       node.executor.execute(sender, "Announcement sender for 
"+uid);
+                       node.executor.execute(sender, "Announcement sender for 
"+uid, NativeThread.HIGH_PRIORITY);
                        success = true;
                        return true;
                } finally {

Modified: trunk/freenet/src/freenet/node/ResettingHTLProbeRequestSender.java
===================================================================
--- trunk/freenet/src/freenet/node/ResettingHTLProbeRequestSender.java  
2008-02-16 18:24:23 UTC (rev 18004)
+++ trunk/freenet/src/freenet/node/ResettingHTLProbeRequestSender.java  
2008-02-16 18:26:36 UTC (rev 18005)
@@ -15,6 +15,7 @@
 import freenet.io.comm.NotConnectedException;
 import freenet.support.Logger;
 import freenet.support.ShortBuffer;
+import freenet.support.io.NativeThread;

 /**
  * Probe request sender.
@@ -76,7 +77,7 @@
     }

     public void start() {
-       node.executor.execute(this, "ResettingHTLProbeRequestSender for UID 
"+uid);
+       node.executor.execute(this, "ResettingHTLProbeRequestSender for UID 
"+uid, NativeThread.HIGH_PRIORITY);
     }

     public void run() {