svn commit: r1420028 - in /zookeeper/trunk: CHANGES.txt src/java/test/org/apache/zookeeper/server/quorum/Zab1_0Test.java

[phunt]

Author: phunt
Date: Tue Dec 11 08:18:08 2012
New Revision: 1420028

URL: http://svn.apache.org/viewvc?rev=1420028&view=rev
Log:
ZOOKEEPER-1596. Zab1_0Test should ensure that the file is closed (Enis Soztutar 
via phunt)

Modified:
    zookeeper/trunk/CHANGES.txt
    
zookeeper/trunk/src/java/test/org/apache/zookeeper/server/quorum/Zab1_0Test.java

Modified: zookeeper/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/zookeeper/trunk/CHANGES.txt?rev=1420028&r1=1420027&r2=1420028&view=diff
==============================================================================
--- zookeeper/trunk/CHANGES.txt (original)
+++ zookeeper/trunk/CHANGES.txt Tue Dec 11 08:18:08 2012
@@ -273,6 +273,9 @@ BUGFIXES:
   ZOOKEEPER-1591. Windows build is broken because inttypes.h doesn't exist
   (Marshall McMullen via michim)
 
+  ZOOKEEPER-1596. Zab1_0Test should ensure that the file is closed
+  (Enis Soztutar via phunt)
+
 IMPROVEMENTS:
 
   ZOOKEEPER-1170. Fix compiler (eclipse) warnings: unused imports,

Modified: 
zookeeper/trunk/src/java/test/org/apache/zookeeper/server/quorum/Zab1_0Test.java
URL: 
http://svn.apache.org/viewvc/zookeeper/trunk/src/java/test/org/apache/zookeeper/server/quorum/Zab1_0Test.java?rev=1420028&r1=1420027&r2=1420028&view=diff
==============================================================================
--- 
zookeeper/trunk/src/java/test/org/apache/zookeeper/server/quorum/Zab1_0Test.java
 (original)
+++ 
zookeeper/trunk/src/java/test/org/apache/zookeeper/server/quorum/Zab1_0Test.java
 Tue Dec 11 08:18:08 2012
@@ -1000,8 +1000,13 @@ public class Zab1_0Test {
         peer.setCnxnFactory(new NullServerCnxnFactory());
         File version2 = new File(tmpDir, "version-2");
         version2.mkdir();
-        new FileOutputStream(new File(version2, 
"currentEpoch")).write("0\n".getBytes());
-        new FileOutputStream(new File(version2, 
"acceptedEpoch")).write("0\n".getBytes());
+        FileOutputStream fos;
+        fos = new FileOutputStream(new File(version2, "currentEpoch"));
+        fos.write("0\n".getBytes());
+        fos.close();
+        fos = new FileOutputStream(new File(version2, "acceptedEpoch"));
+        fos.write("0\n".getBytes());
+        fos.close();
         return peer;
     }
 }