LockManager { public void blockRequest() { trace("[{}] Block all requests", gondola.getHostId()); globalLock = new CountDownLatch(1); } 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 testBlockRequest() throws Exception { lockManager.blockRequest(); assertTrue(checkBlocked(1,"c1")); }