more work on the roundrobin tests

This commit is contained in:
Peter Veentjer 2011-06-30 21:32:32 +03:00
parent f18958422e
commit a4102d516b

View file

@ -65,6 +65,14 @@ class ZooKeeperBarrier(zkClient: ZkClient, name: String, node: String, count: In
leave()
}
/**
* An await does a enter/leave making this barrier a 'single' barrier instead of a double barrier.
*/
def await() {
enter
leave()
}
def enter = {
zkClient.createEphemeral(entry)
if (zkClient.countChildren(barrier) >= count)