Lines Matching refs:timeout
42 def _retry_on_intr(fn, timeout): argument
43 return fn(timeout)
48 def _retry_on_intr(fn, timeout): argument
49 if timeout is None:
52 deadline = monotonic() + timeout
56 return fn(timeout)
63 timeout = deadline - monotonic()
64 if timeout < 0:
65 timeout = 0
66 if timeout == float("inf"):
67 timeout = None
71 def select_wait_for_socket(sock, read=False, write=False, timeout=None): argument
86 rready, wready, xready = _retry_on_intr(fn, timeout)
90 def poll_wait_for_socket(sock, read=False, write=False, timeout=None): argument
107 return bool(_retry_on_intr(do_poll, timeout))
142 def wait_for_read(sock, timeout=None): argument
146 return wait_for_socket(sock, read=True, timeout=timeout)
149 def wait_for_write(sock, timeout=None): argument
153 return wait_for_socket(sock, write=True, timeout=timeout)