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

[rob...@freenetproject.org]

Author: robert
Date: 2007-12-07 01:41:35 +0000 (Fri, 07 Dec 2007)
New Revision: 16387

Modified:
   trunk/freenet/src/freenet/node/SSKInsertHandler.java
Log:
count messages back to sender as part of liability


Modified: trunk/freenet/src/freenet/node/SSKInsertHandler.java
===================================================================
--- trunk/freenet/src/freenet/node/SSKInsertHandler.java        2007-12-07 
01:36:12 UTC (rev 16386)
+++ trunk/freenet/src/freenet/node/SSKInsertHandler.java        2007-12-07 
01:41:35 UTC (rev 16387)
@@ -256,7 +256,7 @@
             if((status == SSKInsertSender.ROUTE_NOT_FOUND) || (status == 
SSKInsertSender.ROUTE_REALLY_NOT_FOUND)) {
                 Message msg = DMT.createFNPRouteNotFound(uid, sender.getHTL());
                 try {
-                                       source.sendSync(msg, null);
+                                       source.sendSync(msg, this);
                                } catch (NotConnectedException e) {
                                        if(logMINOR) Logger.minor(this, "Lost 
connection to source");
                                        return;
@@ -269,7 +269,7 @@
             if(status == SSKInsertSender.SUCCESS) {
                Message msg = DMT.createFNPInsertReply(uid);
                try {
-                                       source.sendSync(msg, null);
+                                       source.sendSync(msg, this);
                                } catch (NotConnectedException e) {
                                        if(logMINOR) Logger.minor(this, "Lost 
connection to source");
                                        return;
@@ -283,7 +283,7 @@
             Logger.error(this, "Unknown status code: 
"+sender.getStatusString());
             Message msg = DMT.createFNPRejectedOverload(uid, true);
             try {
-                               source.sendSync(msg, null);
+                               source.sendSync(msg, this);
                        } catch (NotConnectedException e) {
                                // Ignore
                        }