Searched refs:with_timeout (Results 1 – 4 of 4) sorted by relevance
22 explicit HangingReceiveThread(SyncSocket* socket, bool with_timeout) in HangingReceiveThread() argument25 with_timeout_(with_timeout), in HangingReceiveThread()
321 fn with_timeout(timeout: Duration, f: impl FnOnce() + Send + 'static) { in with_timeout() function363 with_timeout(Duration::from_secs(60), || { in drop_cancels_remote_tasks()385 with_timeout(Duration::from_secs(60), || { in local_tasks_wake_join_all()
710 def check_sendall_interrupted(self, with_timeout): argument724 if with_timeout:730 if with_timeout:
1591 def check_sendall_interrupted(self, with_timeout): argument1605 if with_timeout:1611 if with_timeout: