Lines Matching refs:timeout

25     pub fn block_until(&self, timeout: &Pollable) -> Result<(), ErrorCode> {  in block_until()
26 let ready = poll::poll(&[self, timeout]); in block_until()
51 let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS); in blocking_write_util() localVariable
55 pollable.block_until(&timeout).expect("write timed out"); in blocking_write_util()
80 let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS); in blocking_resolve_addresses() localVariable
95 pollable.block_until(&timeout)?; in blocking_resolve_addresses()
128 let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS); in blocking_bind() localVariable
135 Err(ErrorCode::WouldBlock) => sub.block_until(&timeout)?, in blocking_bind()
142 let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS); in blocking_listen() localVariable
149 Err(ErrorCode::WouldBlock) => sub.block_until(&timeout)?, in blocking_listen()
160 let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS); in blocking_connect() localVariable
167 Err(ErrorCode::WouldBlock) => sub.block_until(&timeout)?, in blocking_connect()
174 let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS); in blocking_accept() localVariable
179 Err(ErrorCode::WouldBlock) => sub.block_until(&timeout)?, in blocking_accept()
196 let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS); in blocking_bind() localVariable
203 Err(ErrorCode::WouldBlock) => sub.block_until(&timeout)?, in blocking_bind()
218 fn blocking_check_send(&self, timeout: &Pollable) -> Result<u64, ErrorCode> { in blocking_check_send()
223 Ok(0) => sub.block_until(timeout)?, in blocking_check_send()
230 let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS); in blocking_send() localVariable
233 let permit = self.blocking_check_send(&timeout)?; in blocking_send()
251 let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS); in blocking_receive() localVariable
263 pollable.block_until(&timeout)?; in blocking_receive()