| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/ |
| H A D | mod.rs | 107 pub(crate) mod concurrent; module
121 pub use self::concurrent::{
764 pub(crate) use concurrent_disabled as concurrent;
|
| H A D | store.rs | 4 use crate::runtime::component::concurrent::ConcurrentState;
144 crate::component::concurrent::tls::set(store, move || drop(futures)); in drop_fibers_and_futures()
|
| H A D | func.rs | 20 use crate::component::concurrent::{self, AsAccessor, PreparedCall};
412 concurrent::queue_call(store.as_context_mut(), prepared) in call_concurrent_dynamic()
433 concurrent::prepare_call( in prepare_call_dynamic()
|
| H A D | linker.rs | 2 use crate::component::concurrent::Accessor;
796 crate::component::concurrent::tls::set(store.0, || future.as_mut().poll(cx)) in resource_concurrent()
|
| H A D | values.rs | 3 use crate::component::concurrent::{self, ErrorContext, FutureAny, StreamAny};
504 concurrent::lower_error_context_to_index(*rep, cx, ty)?.linear_lower_to_flat( in lower()
667 concurrent::lower_error_context_to_index(*rep, cx, ty)?.linear_lower_to_memory( in store()
|
| /wasmtime-44.0.1/tests/all/component_model/ |
| H A D | import.rs | 502 async fn test_stack_and_heap_args_and_rets(concurrent: bool) -> Result<()> { in test_stack_and_heap_args_and_rets()
503 let (body, async_lower_opts, async_lift_opts, async_type) = if concurrent { in test_stack_and_heap_args_and_rets()
739 if concurrent { in test_stack_and_heap_args_and_rets()
844 if concurrent { in test_stack_and_heap_args_and_rets()
857 if concurrent { in test_stack_and_heap_args_and_rets()
968 if concurrent { in test_stack_and_heap_args_and_rets()
|
| H A D | func.rs | 1168 async fn test_many_parameters(dynamic: bool, concurrent: bool) -> Result<()> { in test_many_parameters()
1169 let (body, async_opts) = if concurrent { in test_many_parameters()
1327 if concurrent { in test_many_parameters()
1372 if concurrent { in test_many_parameters()
1453 async fn test_many_results(dynamic: bool, concurrent: bool) -> Result<()> { in test_many_results()
1454 let (ret, async_opts) = if concurrent { in test_many_results()
1760 if concurrent { in test_many_results()
1850 if concurrent { in test_many_results()
|
| /wasmtime-44.0.1/crates/wasi-keyvalue/wit/deps/keyvalue/ |
| H A D | batch.wit | 29 /// MAY show an out-of-date value if there are concurrent writes to the store.
46 /// Other concurrent operations may also be able to see the partial results.
61 /// Other concurrent operations may also be able to see the partial results.
|
| H A D | store.wit | 117 /// MAY show an out-of-date list of keys if there are concurrent writes to the store.
|
| /wasmtime-44.0.1/cranelift/filetests/src/ |
| H A D | lib.rs | 13 mod concurrent; module
|
| H A D | runner.rs | 6 use crate::concurrent::{ConcurrentRunner, Reply};
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/ |
| H A D | future_stream_any.rs | 3 use crate::component::concurrent::futures_and_streams::{self, TransmitOrigin};
4 use crate::component::concurrent::{TableId, TransmitHandle};
|
| /wasmtime-44.0.1/crates/wasmtime/ |
| H A D | README.md | 22 wasm, and scalability of concurrent instances.
38 servers with many concurrent instances.
|
| /wasmtime-44.0.1/tests/misc_testsuite/component-model/async/ |
| H A D | streams.wast | 186 (assert_trap (invoke "read-twice") "cannot have concurrent operations active on a future/stream")
188 (assert_trap (invoke "write-twice") "cannot have concurrent operations active on a future/stream")
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/func/ |
| H A D | host.rs | 4 use crate::component::concurrent;
6 use crate::component::concurrent::{Accessor, Status};
431 HostResult::Future(future) => concurrent::poll_and_block(store.0, future)?, in call_sync_lower()
|
| H A D | options.rs | 3 use crate::component::concurrent::ConcurrentState;
|
| H A D | typed.rs | 21 use crate::component::concurrent::{self, AsAccessor, PreparedCall};
171 use crate::component::concurrent::TaskId; in call_async()
218 let result = concurrent::queue_call(wrapper.store.as_context_mut(), prepared)?; in call_async()
313 concurrent::queue_call(store, prepared) in call_concurrent()
372 concurrent::prepare_call( in prepare_call()
|
| /wasmtime-44.0.1/ |
| H A D | README.md | 94 calls between the embedder and wasm, and scalability of concurrent instances.
111 on massive servers with many concurrent instances, we've got you covered.
|
| /wasmtime-44.0.1/docs/ |
| H A D | examples-fast-instantiation.md | 13 run the configured maximum number of concurrent instances. Creating a new
|
| /wasmtime-44.0.1/crates/component-macro/tests/ |
| H A D | codegen.rs | 16 mod concurrent {
|
| /wasmtime-44.0.1/crates/wasi/src/p3/wit/deps/ |
| H A D | cli.wit | 79 /// Multiple streams may be active at the same time. The behavior of concurrent
|
| /wasmtime-44.0.1/crates/wasi-http/src/p3/wit/deps/ |
| H A D | cli.wit | 79 /// Multiple streams may be active at the same time. The behavior of concurrent
|
| H A D | filesystem.wit | 32 /// concurrent writers.
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/component/ |
| H A D | libcalls.rs | 5 use crate::component::concurrent::WaitResult;
9 use crate::runtime::component::concurrent::{ResourcePair, SuspensionTarget};
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/ |
| H A D | component.rs | 13 use crate::runtime::component::concurrent::ConcurrentInstanceState;
|