Author: xor
Date: 2008-11-15 17:34:09 +0000 (Sat, 15 Nov 2008)
New Revision: 23599

Modified:
   trunk/plugins/WoT/introduction/IntroductionClient.java
Log:
Bugfix: Also terminate inserts at shutdown.

Modified: trunk/plugins/WoT/introduction/IntroductionClient.java
===================================================================
--- trunk/plugins/WoT/introduction/IntroductionClient.java      2008-11-15 
17:29:32 UTC (rev 23598)
+++ trunk/plugins/WoT/introduction/IntroductionClient.java      2008-11-15 
17:34:09 UTC (rev 23599)
@@ -214,11 +214,15 @@
        }
        
        private synchronized void cancelRequests() {
-               Iterator<ClientGetter> i = mRequests.iterator();
-               int counter = 0;
-               Logger.debug(this, "Trying to stop all requests"); 
-               while (i.hasNext()) { i.next().cancel(); ++counter; }
-               Logger.debug(this, "Stopped " + counter + " current requests");
+               Iterator<ClientGetter> r = mRequests.iterator();
+               Iterator<ClientPutter> i = mInserts.iterator();
+               int rcounter = 0;
+               int icounter = 0;
+               Logger.debug(this, "Trying to stop all requests & inserts"); 
+               while (r.hasNext()) { r.next().cancel(); ++rcounter; }
+               while (i.hasNext()) { i.next().cancel(); ++icounter; }
+               Logger.debug(this, "Stopped " + rcounter + " current requests");
+               Logger.debug(this, "Stopped " + icounter + " current inserts");
        }
        
        private synchronized void downloadPuzzles() {

_______________________________________________
cvs mailing list
[email protected]
http://emu.freenetproject.org/cgi-bin/mailman/listinfo/cvs

Reply via email to