LockManager { public void unblockRequest() { trace("[{}] Unblock all requests", gondola.getHostId()); if (globalLock != null) { globalLock.countDown(); globalLock = null; } } LockManager(Gondola gondola); boolean filterRequest(int bucketId, String shardId); long unblockRequestOnShard(String shardId); void blockRequestOnShard(String shardId); void unblockRequest(); void blockRequest(); void unblockRequestOnBuckets(Range<Integer> splitRange); void blockRequestOnBuckets(Range<Integer> splitRange); CountDownLatch getGlobalLock(); Map<String, CountDownLatch> getShardLocks(); Map<Range<Integer>, CountDownLatch> getBucketLocks();  }
@Test public void testUnblockRequest() throws Exception { lockManager.blockRequest(); assertTrue(checkBlocked(1,"c1")); lockManager.unblockRequest(); assertFalse(checkBlocked(1,"c1")); lockManager.unblockRequest(); assertFalse(checkBlocked(1,"c1")); }