Home
last modified time | relevance | path

Searched refs:task (Results 1 – 25 of 122) sorted by relevance

12345

/wasmtime-44.0.1/crates/wasmtime/src/runtime/component/
H A Dconcurrent.rs1526 let task = state.get_mut(thread.task)?; in exit_guest_sync_call() localVariable
1534 let task = state.get_mut(thread.task)?; in exit_guest_sync_call() localVariable
1685 let task = state.current_guest_thread()?.task; in check_blocking() localVariable
2649 let task = state.get_mut(guest_thread.task)?; in start_call() localVariable
2769 let task = state.get_mut(guest_thread.task)?; in start_call() localVariable
2972 let task = state.get_mut(guest_thread.task)?; in task_cancel() localVariable
3479 let task = state.get_mut(guest_thread.task)?; in waitable_check() localVariable
5144 let task = self.get_mut(task)?; in may_block() localVariable
5154 let (task, is_host) = (task >> 1, task & 1 == 1); in call_context()
5302 task: self.thread.task, in task_id()
[all …]
/wasmtime-44.0.1/crates/wasi/src/
H A Druntime.rs25 use std::task::{Context, Poll, Waker};
41 pub struct AbortOnDropJoinHandle<T>(tokio::task::JoinHandle<T>);
61 type Target = tokio::task::JoinHandle<T>;
67 fn deref_mut(&mut self) -> &mut tokio::task::JoinHandle<T> { in deref_mut()
71 impl<T> From<tokio::task::JoinHandle<T>> for AbortOnDropJoinHandle<T> {
72 fn from(jh: tokio::task::JoinHandle<T>) -> Self { in from()
91 let j = with_ambient_tokio_runtime(|| tokio::task::spawn(f)); in spawn()
100 let j = with_ambient_tokio_runtime(|| tokio::task::spawn_blocking(f)); in spawn_blocking()
150 tokio::task::yield_now().await; in in_tokio()
184 let mut task = Context::from_waker(Waker::noop()); in poll_noop() localVariable
[all …]
/wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/
H A Dabort.rs4 use std::task::{Context, Poll, Waker};
65 if let Some(task) = waiting_for_abort_signal.take() { in abort()
66 task.wake(); in abort()
182 let task = match prev { in drop() localVariable
192 if let Some(task) = task { in drop()
193 task.wake(); in drop()
202 use std::task::{Context, Poll, Waker};
267 let task = tokio::task::spawn(future); in await_completion() localVariable
269 task.await.unwrap(); in await_completion()
278 let task = tokio::task::spawn(future); in await_abort() localVariable
[all …]
/wasmtime-44.0.1/crates/wasi-tls/src/providers/
H A Dopenssl.rs47 cx: &mut std::task::Context<'_>, in poll_read()
49 ) -> std::task::Poll<io::Result<()>> { in poll_read()
57 cx: &mut std::task::Context<'_>, in poll_write()
59 ) -> std::task::Poll<io::Result<usize>> { in poll_write()
65 cx: &mut std::task::Context<'_>, in poll_flush()
66 ) -> std::task::Poll<Result<(), io::Error>> { in poll_flush()
72 cx: &mut std::task::Context<'_>, in poll_shutdown()
73 ) -> std::task::Poll<Result<(), io::Error>> { in poll_shutdown()
H A Dnativetls.rs6 use std::task::Poll;
38 cx: &mut std::task::Context<'_>, in poll_read()
48 cx: &mut std::task::Context<'_>, in poll_write()
56 cx: &mut std::task::Context<'_>, in poll_flush()
63 cx: &mut std::task::Context<'_>, in poll_shutdown()
/wasmtime-44.0.1/crates/wasi-tls/src/p2/
H A Dio.rs7 use std::task::{Poll, ready};
68 FutureState::Pending(task) => self.0 = FutureState::Ready(task.as_mut().await), in ready()
82 cx: &mut std::task::Context<'_>, in poll_read()
141 cx: &mut std::task::Context<'_>, in poll_write()
189 cx: &mut std::task::Context<'_>, in poll_flush()
196 cx: &mut std::task::Context<'_>, in poll_shutdown()
388 WriteState::Writing(task) | WriteState::Flushing(task) => _ = task.cancel().await, in cancel()
389 WriteState::Closing(task) => _ = task.cancel().await, in cancel()
396 WriteState::Writing(task) | WriteState::Flushing(task) => { in ready()
397 *self = match task.await { in ready()
[all …]
/wasmtime-44.0.1/tests/misc_testsuite/component-model/async/
H A Dstackful.wast23 (import "" "task.return" (func $task-return (param i32)))
24 (func (export "foo") (param i32) (call $task-return (local.get 0)))
26 (core func $task-return (canon task.return (result u32)))
28 (with "" (instance (export "task.return" (func $task-return))))
71 (import "" "task.return" (func $task-return (param i32)))
72 (func (export "foo") (param i32) (call $task-return (local.get 0)))
74 (core func $task-return (canon task.return (result u32)))
76 (with "" (instance (export "task.return" (func $task-return))))
H A Dfused.wast11 (import "" "task.return" (func $task-return (param i32)))
14 (call $task-return (local.get 0))
18 (core func $task-return (canon task.return (result u32)))
20 (with "" (instance (export "task.return" (func $task-return))))
108 (import "" "task.return" (func $task-return (param i32)))
111 (call $task-return (local.get 0))
115 (core func $task-return (canon task.return (result u32)))
117 (with "" (instance (export "task.return" (func $task-return))))
H A Dyield-when-cancelled.wast4 ;; This test checks that an `EVENT_CANCELLED` can be delivered to a task that's
9 (import "" "task.cancel" (func $task-cancel))
31 call $task-cancel
41 (core func $task-cancel (canon task.cancel))
46 (export "task.cancel" (func $task-cancel))
H A Dstreams-massive-send.wast25 (import "" "task.return future" (func $task.return-future (param i32)))
26 (import "" "task.return stream" (func $task.return-stream (param i32)))
36 (call $task.return-stream (local.get $r))
54 (call $task.return-future (local.get $r))
144 (core func $task.return-future (canon task.return (result $f)))
145 (core func $task.return-stream (canon task.return (result $s)))
153 (export "task.return future" (func $task.return-future))
154 (export "task.return stream" (func $task.return-stream))
H A Dsync-streams.wast20 (import "" "task.return0" (func $task.return0))
21 (import "" "task.return1" (func $task.return1 (param i32)))
39 (call $task.return1 (local.get $rx))
61 (call $task.return0)
81 (canon task.return (memory $memory "mem") (core func $task.return0))
82 (canon task.return (result $ST) (memory $memory "mem") (core func $task.return1))
90 (export "task.return0" (func $task.return0))
91 (export "task.return1" (func $task.return1))
H A Dtask-builtins.wast23 ;; task.return
26 (import "" "task.return" (func $task-return (param i32)))
28 (core func $task-return (canon task.return (result u32)))
209 (core func $task.return (canon task.return (result string) (memory $libc "memory")))
212 (import "" "task.return" (func $task.return (param i32 i32)))
228 call $task.return
237 (export "task.return" (func $task.return))
491 (import "" "task.return" (func $task.return (param i32)))
592 (export "task.return" (func $task.return))
662 (import "" "task.return" (func $task.return (param i32)))
[all …]
/wasmtime-44.0.1/crates/wasi-http/src/
H A Dhandler.rs18 use std::task::Poll;
261 if let Err(error) = self.run_(task, req_id).await { in run()
268 task: Option<TaskFn<S::StoreData>>, in run_()
323 let accept_task = |task: TaskFn<S::StoreData>, in run_()
344 (task)(accessor, proxy).await; in run_()
349 if let Some(task) = task { in run_()
350 accept_task(task, &mut futures, &mut reuse_count); in run_()
441 Some(Ok(task)) => { in run_()
583 self.start_worker(Some(task), req_id); in spawn()
585 self.0.task_queue.push(task); in spawn()
[all …]
/wasmtime-44.0.1/crates/wasi/src/p2/
H A Dtcp.rs237 WriteState::Writing(task) => { in check_write()
238 self.state = WriteState::Writing(task); in check_write()
241 WriteState::Closing(task) => { in check_write()
242 self.state = WriteState::Closing(task); in check_write()
284 WriteState::Writing(task) | WriteState::Closing(task) => _ = task.cancel().await, in cancel()
291 WriteState::Writing(task) => { in ready()
292 self.state = match task.await { in ready()
297 WriteState::Closing(task) => { in ready()
298 self.state = match task.await { in ready()
H A Dfilesystem.rs108 ReadState::Waiting(task) => { in wait_ready()
109 self.state = task.await; in wait_ready()
166 ReadState::Waiting(task) => { in cancel()
177 task.cancel().await; in cancel()
363 OutputState::Waiting(task) => { in cancel()
374 task.cancel().await; in cancel()
384 if let OutputState::Waiting(task) = &mut self.state { in ready()
385 self.state = match task.await { in ready()
H A Dwrite_stream.rs5 use std::task::{Context, Poll, Waker};
203 Some(task) => _ = task.cancel().await, in cancel()
/wasmtime-44.0.1/docs/
H A Dcli-cache.md99 Setting `optimizing-compression-task-timeout`
106 no other worker has started the task for this file within the last
107 [`optimizing-compression-task-timeout`] interval.
108 If some worker has started working on it, other workers are skipping this task.
112 [`optimizing-compression-task-timeout`]: #setting-optimizing-compression-task-timeout
121 When the [cache worker] attempts acquiring a lock for some task,
123 To be fault tolerant and eventually execute every task,
178 then the worker will delete some cache files, so after the task,
194 then the worker will delete some cache files, so after the task,
244 [`optimizing-compression-task-timeout`] interval.
[all …]
/wasmtime-44.0.1/crates/wasi/src/p3/filesystem/
H A Dhost.rs12 use core::task::{Context, Poll, ready};
18 use tokio::task::{JoinHandle, spawn_blocking};
176 assert!(self.task.is_none()); in poll_produce()
200 let task = me.task.get_or_insert_with(|| { in poll_produce() localVariable
217 self.task = None; in poll_produce()
300 self.task.abort(); in close()
382 task: None, in new_at()
392 task: None, in new_append()
457 let task = me.task.get_or_insert_with(|| { in poll_consume() localVariable
466 self.task = None; in poll_consume()
[all …]
/wasmtime-44.0.1/crates/test-programs/src/bin/
H A Dasync_poll_synchronous.rs62 let (event, task, code) = waitable_set_poll(set); in run()
64 assert_eq!(call, task); in run()
67 subtask_drop(task); in run()
/wasmtime-44.0.1/crates/wasi/tests/
H A Dprocess_stdin.rs33 'task: loop { in main()
69 break 'task; in main()
73 break 'task; in main()
77 continue 'task; in main()
/wasmtime-44.0.1/examples/tokio/
H A Dmain.rs21 let join1 = tokio::task::spawn(async move { run_wasm(inputs1).await }); in main()
22 let join2 = tokio::task::spawn(async move { in main()
26 let join3 = tokio::task::spawn(async move { in main()
/wasmtime-44.0.1/crates/test-programs/src/
H A Dasync_.rs66 pub fn subtask_drop(task: u32); in subtask_drop()
77 pub fn subtask_cancel(task: u32) -> u32; in subtask_cancel()
88 pub fn subtask_cancel_async(task: u32) -> u32; in subtask_cancel_async()
/wasmtime-44.0.1/crates/wasi-http/src/p3/host/
H A Dhandler.rs6 use core::task::{Context, Poll, Waker};
10 use tokio::task::{self, JoinHandle};
88 let io = task::spawn(async move { in send()
/wasmtime-44.0.1/tests/all/component_model/
H A Dcall_hook.rs7 use std::task::{self, Poll};
510 tokio::task::yield_now().await; in drop_suspended_async_hook()
557 tokio::task::yield_now().await; in drop_suspended_async_hook()
600 fn poll(mut self: Pin<&mut Self>, task: &mut task::Context<'_>) -> Poll<()> { in drop_suspended_async_hook()
602 match Pin::new(&mut self.future).poll(task) { in drop_suspended_async_hook()
/wasmtime-44.0.1/tests/all/
H A Dasync_functions.rs6 use std::task::{Context, Poll, Waker};
80 tokio::task::yield_now().await; in smoke_with_suspension()
89 tokio::task::yield_now().await; in smoke_with_suspension()
108 tokio::task::yield_now().await; in smoke_host_func_with_suspension()
116 tokio::task::yield_now().await; in smoke_host_func_with_suspension()
147 tokio::task::yield_now().await; in recursive_call()
220 tokio::task::yield_now().await; in suspend_while_suspending()
264 tokio::task::yield_now().await; in cancel_during_run()
516 tokio::task::yield_now().await; in resume_separate_thread()
549 tokio::task::yield_now().await; in resume_separate_thread2()
[all …]

12345