zookeeper-commits mailing list archives

Author: ivank
Date: Fri Jan 13 17:06:41 2012
New Revision: 1231187

URL: http://svn.apache.org/viewvc?rev=1231187&view=rev
Log:
BOOKKEEPER-40: BookieClientTest fails intermittantly (fpj via ivank)

Modified:
    zookeeper/bookkeeper/trunk/CHANGES.txt
    zookeeper/bookkeeper/trunk/bookkeeper-server/src/test/java/org/apache/bookkeeper/test/BookieClientTest.java

Modified: zookeeper/bookkeeper/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/zookeeper/bookkeeper/trunk/CHANGES.txt?rev=1231187&r1=1231186&r2=1231187&view=diff
==============================================================================
--- zookeeper/bookkeeper/trunk/CHANGES.txt (original)
+++ zookeeper/bookkeeper/trunk/CHANGES.txt Fri Jan 13 17:06:41 2012
@@ -16,7 +16,9 @@ Trunk (unreleased changes)
 
         BOOKKEEPER-141: Run extracting ledger id from entry log files in GC thread to speed
up bookie restart (Sijie Gou via ivank)
 
-	BOOKKEEPER-148: Jenkins build is failing (ivank via fpj)
+        BOOKKEEPER-148: Jenkins build is failing (ivank via fpj)
+
+        BOOKKEEPER-40: BookieClientTest fails intermittantly (fpj via ivank)
 
       hedwig-server/
       

Modified: zookeeper/bookkeeper/trunk/bookkeeper-server/src/test/java/org/apache/bookkeeper/test/BookieClientTest.java
URL: http://svn.apache.org/viewvc/zookeeper/bookkeeper/trunk/bookkeeper-server/src/test/java/org/apache/bookkeeper/test/BookieClientTest.java?rev=1231187&r1=1231186&r2=1231187&view=diff
==============================================================================
--- zookeeper/bookkeeper/trunk/bookkeeper-server/src/test/java/org/apache/bookkeeper/test/BookieClientTest.java
(original)
+++ zookeeper/bookkeeper/trunk/bookkeeper-server/src/test/java/org/apache/bookkeeper/test/BookieClientTest.java
Fri Jan 13 17:06:41 2012
@@ -135,8 +135,9 @@ public class BookieClientTest extends Te
         BookieClient bc = new BookieClient(new ClientConfiguration(), channelFactory, executor);
         ChannelBuffer bb;
         bb = createByteBuffer(1, 1, 1);
-        bc.addEntry(addr, 1, passwd, 1, bb, wrcb, null, BookieProtocol.FLAG_NONE);
+        bc.addEntry(addr, 1, passwd, 1, bb, wrcb, arc, BookieProtocol.FLAG_NONE);
         synchronized (arc) {
+            arc.wait(1000);
             bc.readEntry(addr, 1, 1, recb, arc, BookieProtocol.FLAG_NONE);
             arc.wait(1000);
             assertEquals(0, arc.rc);