Author: nextgens
Date: 2007-11-29 12:23:10 +0000 (Thu, 29 Nov 2007)
New Revision: 16063

Modified:
   trunk/freenet/src/freenet/client/FECCodec.java
Log:
FECCodec: doh... if something was thrown we weren't releasing the FDs

Modified: trunk/freenet/src/freenet/client/FECCodec.java
===================================================================
--- trunk/freenet/src/freenet/client/FECCodec.java      2007-11-29 12:21:38 UTC 
(rev 16062)
+++ trunk/freenet/src/freenet/client/FECCodec.java      2007-11-29 12:23:10 UTC 
(rev 16063)
@@ -16,6 +16,7 @@
 import freenet.support.api.Bucket;
 import freenet.support.api.BucketFactory;
 import freenet.support.io.BucketTools;
+import freenet.support.io.Closer;

 /**
  * FEC (forward error correction) handler.
@@ -175,11 +176,11 @@

                        for (int i = 0; i < k; i++) {
                                if (writers[i] != null)
-                                       writers[i].close();
+                                       Closer.close(writers[i]);
                        }
                        for (int i = 0; i < n; i++) {
                                if (readers[i] != null)
-                                       readers[i].close();
+                                       Closer.close(readers[i]);
                        }

                }
@@ -313,10 +314,10 @@

                        for (int i = 0; i < k; i++)
                                if (readers[i] != null)
-                                       readers[i].close();
+                                       Closer.close(readers[i]);
                        for (int i = 0; i < n - k; i++)
                                if (writers[i] != null)
-                                       writers[i].close();
+                                       Closer.close(writers[i]);

                }
                // Set new buckets only after have a successful decode.


Reply via email to