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

[robert at 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;