| /wasmtime-44.0.1/crates/test-programs/src/ |
| H A D | sockets.rs | 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
142 let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS); in blocking_listen() localVariable
160 let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS); in blocking_connect() localVariable
223 Ok(0) => sub.block_until(timeout)?, in blocking_check_send()
233 let permit = self.blocking_check_send(&timeout)?; in blocking_send()
[all …]
|
| H A D | tls.rs | 11 let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS * 200); in blocking_finish() localVariable
16 None => pollable.block_until(&timeout).expect("timed out"), in blocking_finish()
32 let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS); in blocking_close_output() localVariable
39 Ok(0) => pollable.block_until(&timeout).expect("timed out"), in blocking_close_output()
|
| /wasmtime-44.0.1/fuzz/fuzz_targets/ |
| H A D | instantiate.rs | 13 timeout: Timeout, field
23 let timeout = if u.arbitrary()? { in arbitrary() localVariable
29 Ok(InstantiateInput { config, timeout }) in arbitrary()
39 let timeout = match input.timeout { in execute() localVariable
46 instantiate(module, known_valid, &input.config, timeout); in execute()
65 input.timeout = Timeout::None; in gen_module()
67 } else if let Timeout::None = input.timeout { in gen_module()
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p1_poll_oneoff_files.rs | 60 let timeout = 5_000_000u64; // 5 milliseconds in test_timeout() localVariable
63 timeout, in test_timeout()
90 after - before >= timeout, in test_timeout()
98 let timeout = 5_000_000u64; // 5 milliseconds in test_sleep() localVariable
101 timeout, in test_sleep()
128 after - before >= timeout, in test_sleep()
|
| H A D | p2_http_outbound_request_timeout.rs | 9 let timeout = Duration::from_millis(200); in main() localVariable
10 let connect_timeout: Option<u64> = Some(timeout.as_nanos() as u64); in main()
|
| H A D | p3_http_outbound_request_timeout.rs | 14 let timeout = Duration::from_millis(200); in run() localVariable
15 let connect_timeout: Option<u64> = Some(timeout.as_nanos() as u64); in run()
|
| H A D | p1_sleep_quickly_but_lots.rs | 59 fn subscribe_timeout(timeout: u64) -> wasip1::Subscription { in subscribe_timeout()
67 timeout, in subscribe_timeout()
|
| H A D | p1_cli_hostcall_fuel.rs | 90 fn subscribe_timeout(timeout: u64) -> wasip1::Subscription { in big_poll()
98 timeout, in big_poll()
|
| H A D | p1_poll_oneoff_stdio.rs | 26 timeout: TIMEOUT, in test_stdin_read()
102 timeout: TIMEOUT, in test_stdout_stderr_write()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/memory/ |
| H A D | shared_memory.rs | 130 timeout: Option<Duration>, in atomic_wait32()
141 let deadline = timeout.map(|d| Instant::now() + d); in atomic_wait32()
154 timeout: Option<Duration>, in atomic_wait64()
165 let deadline = timeout.map(|d| Instant::now() + d); in atomic_wait64()
|
| /wasmtime-44.0.1/crates/wasi-http/src/p2/ |
| H A D | mod.rs | 583 use tokio::time::timeout;
595 let tcp_stream = timeout(connect_timeout, TcpStream::connect(&authority))
639 let (sender, conn) = timeout(
659 let (sender, conn) = timeout(
693 let resp = timeout(first_byte_timeout, sender.send_request(request))
|
| H A D | body.rs | 93 timeout: Pin<Box<tokio::time::Sleep>>, field
108 timeout: Box::pin(wasmtime_wasi::runtime::with_ambient_tokio_runtime(|| { in new()
129 me.timeout in poll_frame()
137 if let Poll::Ready(()) = me.timeout.as_mut().poll(cx) { in poll_frame()
|
| /wasmtime-44.0.1/docs/ |
| H A D | examples-profiling-guest.md | 13 When used with `-W timeout=N`, the timeout will be rounded up to the nearest
|
| H A D | cli-cache.md | 99 Setting `optimizing-compression-task-timeout`
107 [`optimizing-compression-task-timeout`] interval.
112 [`optimizing-compression-task-timeout`]: #setting-optimizing-compression-task-timeout
244 [`optimizing-compression-task-timeout`] interval.
|
| /wasmtime-44.0.1/crates/wasi-http/src/p3/ |
| H A D | request.rs | 330 let stream = match tokio::time::timeout(connect_timeout, TcpStream::connect(&authority)).await { in default_send_request()
375 let (mut sender, conn) = tokio::time::timeout( in default_send_request()
404 timeout: tokio::time::Interval, in default_send_request() field
420 self.timeout.reset(); in default_send_request()
424 ready!(self.timeout.poll_tick(cx)); in default_send_request()
437 let res = tokio::time::timeout(first_byte_timeout, sender.send_request(req)) in default_send_request()
441 let mut timeout = tokio::time::interval(between_bytes_timeout); in default_send_request() localVariable
442 timeout.reset(); in default_send_request()
443 Ok(res.map(|incoming| IncomingResponseBody { incoming, timeout })) in default_send_request()
|
| /wasmtime-44.0.1/crates/wasi-http/src/p3/wit/deps/ |
| H A D | http.wit | 57 DNS-timeout,
65 connection-timeout,
66 connection-read-timeout,
67 connection-write-timeout,
90 HTTP-response-timeout,
347 /// currently an optional timeout applicable to the transport layer of the
356 /// The timeout for the initial connect to the HTTP Server.
357 get-connect-timeout: func() -> option<duration>;
362 /// The timeout for receiving the first byte of the Response body.
363 get-first-byte-timeout: func() -> option<duration>;
[all …]
|
| /wasmtime-44.0.1/tests/all/guest_debug/ |
| H A D | mod.rs | 65 timeout: Duration, in spawn()
79 let deadline = std::time::Instant::now() + timeout; in spawn()
104 fn wait_for_stderr(&mut self, marker: &str, timeout: Duration) -> Result<String> { in wait_for_stderr()
105 let deadline = std::time::Instant::now() + timeout; in wait_for_stderr()
|
| /wasmtime-44.0.1/crates/wasi-http/wit/deps/ |
| H A D | http.wit | 65 DNS-timeout,
73 connection-timeout,
74 connection-read-timeout,
75 connection-write-timeout,
98 HTTP-response-timeout,
360 /// The timeout for the initial connect to the HTTP Server.
362 connect-timeout: func() -> option<duration>;
364 /// return value indicates that this timeout is not supported.
366 set-connect-timeout: func(duration: option<duration>) -> result;
369 first-byte-timeout: func() -> option<duration>;
[all …]
|
| /wasmtime-44.0.1/src/commands/ |
| H A D | run.rs | 328 if self.run.common.wasm.timeout.is_some() { in new_engine()
423 .timeout in instantiate_and_run()
425 let result = tokio::time::timeout(dur, async { in instantiate_and_run()
555 if self.run.common.wasm.timeout.is_some() { in setup_epoch_handler()
576 if let Some(timeout) = self.run.common.wasm.timeout { in setup_epoch_handler()
580 thread::sleep(timeout); in setup_epoch_handler()
634 if let Some(timeout) = self.run.common.wasm.timeout { in setup_guest_profiler()
635 let mut timeout = (timeout.as_secs_f64() / interval.as_secs_f64()).ceil() as u64; in setup_guest_profiler() localVariable
636 assert!(timeout > 0); in setup_guest_profiler()
641 timeout -= 1; in setup_guest_profiler()
[all …]
|
| /wasmtime-44.0.1/tests/misc_testsuite/threads/ |
| H A D | atomics_wait_address.wast | 101 ;; timeout
124 ;; timeout on 0ns
|
| /wasmtime-44.0.1/cranelift/ |
| H A D | run-souper.sh | 46 $(which timeout) --foreground --kill-after=1s $TIMEOUT bash -c "$cmd"
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/ |
| H A D | memory.rs | 994 timeout: Option<Duration>, in atomic_wait32()
996 self.vm.atomic_wait32(addr, expected, timeout) in atomic_wait32()
1012 timeout: Option<Duration>, in atomic_wait64()
1014 self.vm.atomic_wait64(addr, expected, timeout) in atomic_wait64()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/ |
| H A D | memory.rs | 516 timeout: Option<core::time::Duration>, in atomic_wait32()
519 Some(m) => m.atomic_wait32(addr, expected, timeout), in atomic_wait32()
533 timeout: Option<core::time::Duration>, in atomic_wait64()
536 Some(m) => m.atomic_wait64(addr, expected, timeout), in atomic_wait64()
|
| H A D | parking_spot.rs | 157 let timeout = match deadline { in wait() localVariable
170 thread::park_timeout(timeout); in wait()
609 let timeout = Instant::now() + Duration::from_millis(1); in wait_with_timeout() localVariable
610 parking_spot.wait64(&atomic, cur, Some(timeout), &mut waiter); in wait_with_timeout()
|
| /wasmtime-44.0.1/crates/wasi-common/src/sync/sched/ |
| H A D | windows.rs | 180 WaitMode::Timeout(timeout) => match self.notify_rx.recv_timeout(timeout) { in poll()
|