| /wasmtime-44.0.1/crates/gdbstub-component/src/ |
| H A D | api.rs | 17 pollable: Option<AsyncPollable>, field
23 let pollable = Some(AsyncPollable::new(future.subscribe())); in continue_() localVariable
24 Resumption { future, pollable } in continue_()
29 let pollable = Some(AsyncPollable::new(future.subscribe())); in single_step() localVariable
30 Resumption { future, pollable } in single_step()
34 if let Some(pollable) = self.pollable.as_mut() { in wait()
35 pollable.wait_for().await; in wait()
41 let _ = self.pollable.take(); in result()
|
| /wasmtime-44.0.1/crates/wasi-io/src/ |
| H A D | impls.rs | 27 let pollable = self.get(p)?; in poll() localVariable
29 .entry(pollable.index) in poll()
30 .or_insert((pollable.make_future, Vec::new())); in poll()
72 let pollable = self.get(&pollable)?; in block() localVariable
73 let ready = (pollable.make_future)(self.get_any_mut(pollable.index)?); in block()
78 let pollable = self.get(&pollable)?; in ready() localVariable
79 let ready = (pollable.make_future)(self.get_any_mut(pollable.index)?); in ready()
86 fn drop(&mut self, pollable: Resource<DynPollable>) -> Result<()> { in drop()
87 let pollable = self.delete(pollable)?; in drop() localVariable
88 if let Some(delete) = pollable.remove_index_on_delete { in drop()
[all …]
|
| H A D | poll.rs | 104 let pollable = DynPollable { in subscribe() localVariable
118 Ok(table.push_child(pollable, &resource)?) in subscribe()
|
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | poll.rs | 14 fn ready(&mut self, pollable: Resource<DynPollable>) -> Result<bool> { in ready()
15 in_tokio(async { async_poll::HostPollable::ready(self, pollable).await }) in ready()
17 fn block(&mut self, pollable: Resource<DynPollable>) -> Result<()> { in block()
18 in_tokio(async { async_poll::HostPollable::block(self, pollable).await }) in block()
20 fn drop(&mut self, pollable: Resource<DynPollable>) -> Result<()> { in drop()
21 async_poll::HostPollable::drop(self, pollable) in drop()
|
| /wasmtime-44.0.1/crates/test-programs/src/ |
| H A D | tls.rs | 12 let pollable = future.subscribe(); in blocking_finish() localVariable
16 None => pollable.block_until(&timeout).expect("timed out"), in blocking_finish()
33 let pollable = output.subscribe(); in blocking_close_output() localVariable
39 Ok(0) => pollable.block_until(&timeout).expect("timed out"), in blocking_close_output()
|
| H A D | http.rs | 96 let pollable = request_body.subscribe(); in request() localVariable
98 pollable.block(); in request()
120 pollable.block(); in request()
132 let pollable = future_response.subscribe(); in request() localVariable
133 pollable.block(); in request()
|
| H A D | sockets.rs | 52 let pollable = self.subscribe(); in blocking_write_util() localVariable
55 pollable.block_until(&timeout).expect("write timed out"); in blocking_write_util()
81 let pollable = stream.subscribe(); in blocking_resolve_addresses() localVariable
95 pollable.block_until(&timeout)?; in blocking_resolve_addresses()
252 let pollable = self.subscribe(); in blocking_receive() localVariable
263 pollable.block_until(&timeout)?; in blocking_receive()
|
| /wasmtime-44.0.1/crates/debugger/wit/deps/ |
| H A D | io.wit | 42 resource pollable {
52 /// containing only this pollable.
90 use poll.{pollable};
167 subscribe: func() -> pollable;
218 /// let pollable = this.subscribe();
221 /// pollable.block();
230 /// pollable.block();
263 subscribe: func() -> pollable;
281 /// let pollable = this.subscribe();
284 /// pollable.block();
[all …]
|
| H A D | clocks.wit | 14 use wasi:io/[email protected].{pollable};
38 /// Create a `pollable` which will resolve once the specified instant
41 subscribe-instant: func(when: instant) -> pollable;
43 /// Create a `pollable` that will resolve after the specified duration has
46 subscribe-duration: func(when: duration) -> pollable;
|
| H A D | sockets.wit | 163 use wasi:io/[email protected].{pollable};
189 subscribe: func() -> pollable;
221 use wasi:io/[email protected].{pollable};
539 /// Create a `pollable` which can be used to poll for, or block on,
543 /// return `error(would-block)`, this pollable can be used to wait for
557 subscribe: func() -> pollable;
620 use wasi:io/[email protected].{pollable};
797 subscribe: func() -> pollable;
832 subscribe: func() -> pollable;
843 /// When this function returns ok(0), the `subscribe` pollable will
[all …]
|
| /wasmtime-44.0.1/crates/wasi/src/p2/wit/deps/ |
| H A D | io.wit | 42 resource pollable {
52 /// containing only this pollable.
90 use poll.{pollable};
167 subscribe: func() -> pollable;
218 /// let pollable = this.subscribe();
221 /// pollable.block();
230 /// pollable.block();
263 subscribe: func() -> pollable;
281 /// let pollable = this.subscribe();
284 /// pollable.block();
[all …]
|
| H A D | clocks.wit | 14 use wasi:io/[email protected].{pollable};
38 /// Create a `pollable` which will resolve once the specified instant
41 subscribe-instant: func(when: instant) -> pollable;
43 /// Create a `pollable` that will resolve after the specified duration has
46 subscribe-duration: func(when: duration) -> pollable;
|
| H A D | sockets.wit | 163 use wasi:io/[email protected].{pollable};
189 subscribe: func() -> pollable;
221 use wasi:io/[email protected].{pollable};
539 /// Create a `pollable` which can be used to poll for, or block on,
543 /// return `error(would-block)`, this pollable can be used to wait for
557 subscribe: func() -> pollable;
620 use wasi:io/[email protected].{pollable};
797 subscribe: func() -> pollable;
832 subscribe: func() -> pollable;
843 /// When this function returns ok(0), the `subscribe` pollable will
[all …]
|
| /wasmtime-44.0.1/crates/wasi-http/wit/deps/ |
| H A D | io.wit | 42 resource pollable {
52 /// containing only this pollable.
90 use poll.{pollable};
167 subscribe: func() -> pollable;
218 /// let pollable = this.subscribe();
221 /// pollable.block();
230 /// pollable.block();
263 subscribe: func() -> pollable;
281 /// let pollable = this.subscribe();
284 /// pollable.block();
[all …]
|
| H A D | clocks.wit | 14 use wasi:io/[email protected].{pollable};
38 /// Create a `pollable` which will resolve once the specified instant
41 subscribe-instant: func(when: instant) -> pollable;
43 /// Create a `pollable` that will resolve after the specified duration has
46 subscribe-duration: func(when: duration) -> pollable;
|
| /wasmtime-44.0.1/crates/wasi-tls/wit/deps/ |
| H A D | io.wit | 42 resource pollable {
52 /// containing only this pollable.
90 use poll.{pollable};
167 subscribe: func() -> pollable;
218 /// let pollable = this.subscribe();
221 /// pollable.block();
230 /// pollable.block();
263 subscribe: func() -> pollable;
281 /// let pollable = this.subscribe();
284 /// pollable.block();
[all …]
|
| /wasmtime-44.0.1/crates/wasi-io/wit/deps/ |
| H A D | io.wit | 42 resource pollable {
52 /// containing only this pollable.
90 use poll.{pollable};
167 subscribe: func() -> pollable;
218 /// let pollable = this.subscribe();
221 /// pollable.block();
230 /// pollable.block();
263 subscribe: func() -> pollable;
281 /// let pollable = this.subscribe();
284 /// pollable.block();
[all …]
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p2_api_reactor.rs | 37 let pollable = o.subscribe(); in write_strings_to() localVariable
41 pollable.block(); in write_strings_to()
59 pollable.block(); in write_strings_to()
|
| H A D | p2_api_proxy_streaming.rs | 354 .map(|(pollable, _)| pollable) in run()
363 for (ready, (pollable, waker)) in ready.into_iter().zip(wakers) { in run()
367 new_wakers.push((pollable, waker)); in run()
|
| /wasmtime-44.0.1/crates/wasi-common/src/sync/ |
| H A D | stdio.rs | 31 fn pollable(&self) -> Option<rustix::fd::BorrowedFd<'_>> { in pollable() method
36 fn pollable(&self) -> Option<io_extras::os::windows::RawHandleOrSocket> { in pollable() method
111 fn pollable(&self) -> Option<rustix::fd::BorrowedFd<'_>> {
115 fn pollable(&self) -> Option<io_extras::os::windows::RawHandleOrSocket> {
|
| H A D | net.rs | 85 fn pollable(&self) -> Option<rustix::fd::BorrowedFd<'_>> {
89 fn pollable(&self) -> Option<io_extras::os::windows::RawHandleOrSocket> {
178 fn pollable(&self) -> Option<rustix::fd::BorrowedFd<'_>> {
182 fn pollable(&self) -> Option<io_extras::os::windows::RawHandleOrSocket> {
|
| /wasmtime-44.0.1/crates/wasi-tls/wit/deps/tls/ |
| H A D | types.wit | 6 use wasi:io/[email protected].{pollable};
28 subscribe: func() -> pollable;
|
| /wasmtime-44.0.1/crates/wasi-common/src/sync/sched/ |
| H A D | unix.rs | 16 .pollable() in poll_oneoff()
24 .pollable() in poll_oneoff()
|
| H A D | windows.rs | 53 } else if r.file.pollable().is_some() { in poll_oneoff_()
60 if w.file.pollable().is_some() { in poll_oneoff_()
|
| /wasmtime-44.0.1/crates/wasi-common/src/ |
| H A D | file.rs | 12 fn pollable(&self) -> Option<rustix::fd::BorrowedFd<'_>> { in pollable() method
17 fn pollable(&self) -> Option<io_extras::os::windows::RawHandleOrSocket> { in pollable() method
|