|
@@ -377,9 +377,11 @@ public class CommitProcessorMetricsTest extends ZKTestCase {
|
|
|
|
|
|
//three read requests will be processed in parallel
|
|
|
commitSeen = new CountDownLatch(1);
|
|
|
+ requestScheduled = new CountDownLatch(3);
|
|
|
commitProcessor.processRequest(createReadRequest(1l, 2));
|
|
|
commitProcessor.processRequest(createReadRequest(1l, 3));
|
|
|
commitProcessor.processRequest(createReadRequest(1l, 4));
|
|
|
+ requestScheduled.await(5, TimeUnit.SECONDS);
|
|
|
|
|
|
//add a commit request to trigger waitForEmptyPool, which will record number of requests being proccessed
|
|
|
poolEmpytied = new CountDownLatch(1);
|