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

[rob...@freenetproject.org]

Author: robert
Date: 2007-12-03 23:17:43 +0000 (Mon, 03 Dec 2007)
New Revision: 16248

Modified:
   trunk/freenet/src/freenet/node/InsertHandler.java
   trunk/freenet/src/freenet/node/RequestHandler.java
   trunk/freenet/src/freenet/node/SSKInsertHandler.java
Log:
Use sendAsync for accepted (ACK) messages.


Modified: trunk/freenet/src/freenet/node/InsertHandler.java
===================================================================
--- trunk/freenet/src/freenet/node/InsertHandler.java   2007-12-03 23:13:04 UTC 
(rev 16247)
+++ trunk/freenet/src/freenet/node/InsertHandler.java   2007-12-03 23:17:43 UTC 
(rev 16248)
@@ -91,7 +91,7 @@
         // Send Accepted
         Message accepted = DMT.createFNPAccepted(uid);
         try {
-                       source.sendSync(accepted, this);
+                       source.sendAsync(accepted, null, 0, this);
                } catch (NotConnectedException e1) {
                        if(logMINOR) Logger.minor(this, "Lost connection to 
source");
                        return;

Modified: trunk/freenet/src/freenet/node/RequestHandler.java
===================================================================
--- trunk/freenet/src/freenet/node/RequestHandler.java  2007-12-03 23:13:04 UTC 
(rev 16247)
+++ trunk/freenet/src/freenet/node/RequestHandler.java  2007-12-03 23:17:43 UTC 
(rev 16248)
@@ -121,7 +121,7 @@
                htl = source.decrementHTL(htl);

         Message accepted = DMT.createFNPAccepted(uid);
-        source.sendSync(accepted, null);
+        source.sendAsync(accepted, null, 0, this);

         Object o = node.makeRequestSender(key, htl, uid, source, closestLoc, 
resetClosestLoc, false, true, false);
         if(o instanceof KeyBlock) {

Modified: trunk/freenet/src/freenet/node/SSKInsertHandler.java
===================================================================
--- trunk/freenet/src/freenet/node/SSKInsertHandler.java        2007-12-03 
23:13:04 UTC (rev 16247)
+++ trunk/freenet/src/freenet/node/SSKInsertHandler.java        2007-12-03 
23:17:43 UTC (rev 16248)
@@ -93,7 +93,7 @@
         Message accepted = DMT.createFNPSSKAccepted(uid, pubKey == null);

         try {
-                       source.sendSync(accepted, this);
+                       source.sendAsync(accepted, null, 0, this);
                } catch (NotConnectedException e1) {
                        if(logMINOR) Logger.minor(this, "Lost connection to 
source");
                        return;