fail("Should have thrown a TimeoutException");
} catch (TimeoutException e) {
}
// Let the get complete finally
checkPoint.triggerForever("pre_acquire_shared_topology_lock_released");
Assert.assertEquals(firstValue, getFuture.get(10, TimeUnit.SECONDS));
Assert.assertEquals(firstValue, putFuture.get(10, TimeUnit.SECONDS));