Searched refs:master_barrier (Results 1 – 2 of 2) sorted by relevance
80 barrier.master_barrier(timeout=P2P_INITIALIZE_TIMEOUT_SECS)123 client_sha1s = barrier.master_barrier(
37 def master_barrier(self, token=None, timeout=None): member in QueueBarrier