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

[nextg...@freenetproject.org]

Author: nextgens
Date: 2006-07-12 14:41:05 +0000 (Wed, 12 Jul 2006)
New Revision: 9575

Modified:
   trunk/freenet/src/freenet/node/FNPPacketMangler.java
   trunk/freenet/src/freenet/node/LocationManager.java
Log:
doh

Modified: trunk/freenet/src/freenet/node/FNPPacketMangler.java
===================================================================
--- trunk/freenet/src/freenet/node/FNPPacketMangler.java        2006-07-12 
14:37:15 UTC (rev 9574)
+++ trunk/freenet/src/freenet/node/FNPPacketMangler.java        2006-07-12 
14:41:05 UTC (rev 9575)
@@ -952,7 +952,7 @@
                         } catch (NotConnectedException e) {
                             Logger.normal(this, "Caught "+e+" while sending 
messages, requeueing remaining messages");
                             // Requeue
-                            if(pn.isReallyConnected() && !dontRequeue)
+                            if(!dontRequeue)
                                pn.requeueMessageItems(messages, lastIndex, 
messages.length - lastIndex, false, "NotConnectedException(3)");
                             return;
                         } catch (WouldBlockException e) {

Modified: trunk/freenet/src/freenet/node/LocationManager.java
===================================================================
--- trunk/freenet/src/freenet/node/LocationManager.java 2006-07-12 14:37:15 UTC 
(rev 9574)
+++ trunk/freenet/src/freenet/node/LocationManager.java 2006-07-12 14:41:05 UTC 
(rev 9575)
@@ -923,7 +923,6 @@
      * We lost the connection to a node, or it was restarted.
      */
     public void lostOrRestartedNode(PeerNode pn) {
-       if(!pn.isReallyConnected()) return;
         Vector v = new Vector();
         synchronized(recentlyForwardedIDs) {
             Enumeration e = recentlyForwardedIDs.keys();