Author: toad
Date: 2008-02-18 13:51:01 +0000 (Mon, 18 Feb 2008)
New Revision: 18039

Modified:
   trunk/freenet/src/freenet/node/ResettingHTLProbeRequestHandler.java
   trunk/freenet/src/freenet/node/ResettingHTLProbeRequestSender.java
Log:
Send the probe trace *after* updating nearest and best.

Modified: trunk/freenet/src/freenet/node/ResettingHTLProbeRequestHandler.java
===================================================================
--- trunk/freenet/src/freenet/node/ResettingHTLProbeRequestHandler.java 
2008-02-18 13:44:15 UTC (rev 18038)
+++ trunk/freenet/src/freenet/node/ResettingHTLProbeRequestHandler.java 
2008-02-18 13:51:01 UTC (rev 18039)
@@ -46,16 +46,16 @@
                ResettingHTLProbeRequestHandler handler = 
                        new ResettingHTLProbeRequestHandler(source, uid, 
sender);
                sender.addListener(handler);
-               sender.start();
                PeerNode[] peers = n.peers.connectedPeers;
                Message accepted = DMT.createFNPAccepted(uid);
-               Message trace = DMT.createFNPRHProbeTrace(uid, nearestLoc, 
best, htl, (short)1, (short)1, n.getLocation(), n.swapIdentifier, 
LocationManager.extractLocs(peers, true), LocationManager.extractUIDs(peers), 
(short)0, (short)1, "", source.swapIdentifier);
+               Message trace = DMT.createFNPRHProbeTrace(uid, 
sender.getNearestLoc(), sender.getBest(), htl, (short)1, (short)1, 
n.getLocation(), n.swapIdentifier, LocationManager.extractLocs(peers, true), 
LocationManager.extractUIDs(peers), (short)0, (short)1, "", 
source.swapIdentifier);
                try {
                        source.sendAsync(accepted, null, 0, sender);
                        source.sendAsync(trace, null, 0, sender);
                } catch (NotConnectedException e) {
                        // Ignore, sender will pick up
                }
+               sender.start();
        }

        public void onCompletion(double nearest, double best, short counter, 
short uniqueCounter, short linearCounter) throws NotConnectedException {

Modified: trunk/freenet/src/freenet/node/ResettingHTLProbeRequestSender.java
===================================================================
--- trunk/freenet/src/freenet/node/ResettingHTLProbeRequestSender.java  
2008-02-18 13:44:15 UTC (rev 18038)
+++ trunk/freenet/src/freenet/node/ResettingHTLProbeRequestSender.java  
2008-02-18 13:51:01 UTC (rev 18039)
@@ -540,4 +540,12 @@
                return NativeThread.HIGH_PRIORITY;
        }

+       double getBest() {
+               return best;
+       }
+
+       public double getNearestLoc() {
+               return nearestLoc;
+       }
+
 }


Reply via email to