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

2008-03-22 Thread [email protected] 
Author: toad
Date: 2008-03-22 17:32:26 + (Sat, 22 Mar 2008)
New Revision: 18724

Modified:
   trunk/freenet/src/freenet/node/PeerNode.java
Log:
Also in disconnect().

Modified: trunk/freenet/src/freenet/node/PeerNode.java
===
--- trunk/freenet/src/freenet/node/PeerNode.java2008-03-22 17:29:50 UTC 
(rev 18723)
+++ trunk/freenet/src/freenet/node/PeerNode.java2008-03-22 17:32:26 UTC 
(rev 18724)
@@ -1138,6 +1138,7 @@
node.peers.disconnected(this);
boolean ret;
KeyTracker cur, prev, unv;
+   MessageItem[] messagesTellDisconnected = null;
synchronized(this) {
ret = isConnected;
// Force renegotiation.
@@ -1161,10 +1162,16 @@
}
if(dumpMessageQueue) {
synchronized(messagesToSendNow) {
+   messagesTellDisconnected = 
(MessageItem[]) messagesToSendNow.toArray(new 
MessageItem[messagesToSendNow.size()]);
messagesToSendNow.clear();
}
}
}
+   if(messagesTellDisconnected != null) {
+   for(int i=0;i

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

2008-03-22 Thread toad 
Author: toad
Date: 2008-03-22 17:32:26 + (Sat, 22 Mar 2008)
New Revision: 18724

Modified:
   trunk/freenet/src/freenet/node/PeerNode.java
Log:
Also in disconnect().

Modified: trunk/freenet/src/freenet/node/PeerNode.java
===
--- trunk/freenet/src/freenet/node/PeerNode.java2008-03-22 17:29:50 UTC 
(rev 18723)
+++ trunk/freenet/src/freenet/node/PeerNode.java2008-03-22 17:32:26 UTC 
(rev 18724)
@@ -1138,6 +1138,7 @@
node.peers.disconnected(this);
boolean ret;
KeyTracker cur, prev, unv;
+   MessageItem[] messagesTellDisconnected = null;
synchronized(this) {
ret = isConnected;
// Force renegotiation.
@@ -1161,10 +1162,16 @@
}
if(dumpMessageQueue) {
synchronized(messagesToSendNow) {
+   messagesTellDisconnected = 
(MessageItem[]) messagesToSendNow.toArray(new 
MessageItem[messagesToSendNow.size()]);
messagesToSendNow.clear();
}
}
}
+   if(messagesTellDisconnected != null) {
+   for(int i=0;ihttp://emu.freenetproject.org/cgi-bin/mailman/listinfo/cvs