Lines Matching refs:timeout
9 """QueueBarrier timeout exception."""
37 def master_barrier(self, token=None, timeout=None):
42 @param timeout: The timeout, in seconds, to wait for the slaves.
51 result.append(self.queue_master_.get(timeout=timeout))
61 def slave_barrier(self, token=None, timeout=None):
66 @param timeout: The timeout, in seconds, to wait for the slaves.
71 return self.queue_slave_.get(timeout=timeout)