| /wasmtime-44.0.1/crates/wasi-common/src/ |
| H A D | sched.rs | 9 MonotonicClockSubscription, RwEventFlags, RwSubscription, Subscription, SubscriptionResult,
36 subs: Vec<(Subscription<'a>, Userdata)>,
51 Subscription::MonotonicClock(MonotonicClockSubscription { in subscribe_monotonic_clock()
61 .push((Subscription::Read(RwSubscription::new(file)), ud)); in subscribe_read()
65 .push((Subscription::Write(RwSubscription::new(file)), ud)); in subscribe_write()
80 Subscription::MonotonicClock(t) => Some(t), in earliest_clock_deadline()
85 pub fn rw_subscriptions<'b>(&'b mut self) -> impl Iterator<Item = &'b mut Subscription<'a>> { in rw_subscriptions()
87 Subscription::Read { .. } | Subscription::Write { .. } => Some(s), in rw_subscriptions()
|
| /wasmtime-44.0.1/crates/wasi-common/src/sync/sched/ |
| H A D | unix.rs | 1 use crate::sched::subscription::{RwEventFlags, Subscription};
13 Subscription::Read(f) => { in poll_oneoff()
21 Subscription::Write(f) => { in poll_oneoff()
28 Subscription::MonotonicClock { .. } => unreachable!(), in poll_oneoff()
58 Subscription::Read(sub) => { in poll_oneoff()
62 Subscription::Write(sub) => (0, sub), in poll_oneoff()
|
| H A D | windows.rs | 11 use crate::sched::subscription::{RwEventFlags, Subscription};
50 Subscription::Read(r) => { in poll_oneoff_()
59 Subscription::Write(w) => { in poll_oneoff_()
66 Subscription::MonotonicClock { .. } => unreachable!(), in poll_oneoff_()
|
| /wasmtime-44.0.1/crates/wasi-common/src/sched/ |
| H A D | subscription.rs | 56 pub enum Subscription<'a> { enum
70 pub fn from_subscription(s: Subscription) -> Option<SubscriptionResult> { in from_subscription()
72 Subscription::Read(mut s) => s.result().map(SubscriptionResult::Read), in from_subscription()
73 Subscription::Write(mut s) => s.result().map(SubscriptionResult::Write), in from_subscription()
74 Subscription::MonotonicClock(s) => s.result().map(SubscriptionResult::MonotonicClock), in from_subscription()
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p1_poll_oneoff_stdio.rs | 12 r#in: &[wasip1::Subscription], in poll_oneoff_impl() argument
35 wasip1::Subscription { in test_stdin_read()
42 wasip1::Subscription { in test_stdin_read()
75 fn writable_subs(h: &HashMap<u64, wasip1::Fd>) -> Vec<wasip1::Subscription> { in writable_subs() argument
77 .map(|(ud, fd)| wasip1::Subscription { in writable_subs()
95 let clock = wasip1::Subscription { in test_stdout_stderr_write()
|
| H A D | p1_sleep_quickly_but_lots.rs | 59 fn subscribe_timeout(timeout: u64) -> wasip1::Subscription { in subscribe_timeout() argument
60 wasip1::Subscription { in subscribe_timeout()
76 fn subscribe_fd(ty: wasip1::Eventtype, file_descriptor: wasip1::Fd) -> wasip1::Subscription { in subscribe_fd() argument
77 wasip1::Subscription { in subscribe_fd()
|
| H A D | p1_poll_oneoff_files.rs | 9 r#in: &[wasip1::Subscription], in poll_oneoff_impl() argument
23 r#in: &[wasip1::Subscription], in poll_oneoff_with_retry() argument
67 let r#in = [wasip1::Subscription { in test_timeout()
105 let r#in = [wasip1::Subscription { in test_sleep()
139 wasip1::Subscription { in test_fd_readwrite()
150 wasip1::Subscription { in test_fd_readwrite()
251 wasip1::Subscription { in test_fd_readwrite_invalid_fd()
260 wasip1::Subscription { in test_fd_readwrite_invalid_fd()
|
| H A D | p1_cli_hostcall_fuel.rs | 90 fn subscribe_timeout(timeout: u64) -> wasip1::Subscription { in big_poll() argument
91 wasip1::Subscription { in big_poll()
|
| /wasmtime-44.0.1/crates/wasi-common/src/tokio/sched/ |
| H A D | unix.rs | 5 subscription::{RwEventFlags, Subscription},
57 Subscription::Read(f) => { in poll_oneoff()
73 Subscription::Write(f) => { in poll_oneoff()
83 Subscription::MonotonicClock { .. } => unreachable!(), in poll_oneoff()
|
| /wasmtime-44.0.1/crates/wiggle/tests/ |
| H A D | wasi.rs | 377 _in_: GuestPtr<types::Subscription>, in poll_oneoff() argument
|
| H A D | typenames.witx | 580 ;;; Subscription to an event.
|
| /wasmtime-44.0.1/crates/wasi/src/ |
| H A D | p0.rs | 516 subs: GuestPtr<types::Subscription>, in poll_oneoff() argument
528 snapshot1_types::Subscription { in poll_oneoff()
|
| H A D | p1.rs | 2315 subs: GuestPtr<types::Subscription>, in poll_oneoff() argument
|
| /wasmtime-44.0.1/crates/wasi-common/src/snapshots/ |
| H A D | preview_0.rs | 826 subs: GuestPtr<types::Subscription>, in poll_oneoff() argument
|
| H A D | preview_1.rs | 921 subs: GuestPtr<types::Subscription>, in poll_oneoff() argument
|
| /wasmtime-44.0.1/crates/wasi/witx/p0/ |
| H A D | typenames.witx | 580 ;;; Subscription to an event.
|
| /wasmtime-44.0.1/crates/wasi/witx/p1/ |
| H A D | typenames.witx | 583 ;;; Subscription to an event.
|
| /wasmtime-44.0.1/crates/wasi-common/witx/preview1/ |
| H A D | typenames.witx | 583 ;;; Subscription to an event.
|
| /wasmtime-44.0.1/crates/wasi-common/witx/preview0/ |
| H A D | typenames.witx | 580 ;;; Subscription to an event.
|
| /wasmtime-44.0.1/crates/wasi-preview1-component-adapter/src/ |
| H A D | lib.rs | 2093 r#in: *const Subscription, in poll_oneoff() argument
|