Home
last modified time | relevance | path

Searched refs:reader (Results 1 – 25 of 42) sorted by relevance

12

/wasmtime-44.0.1/crates/wasi/src/p2/
H A Dpipe.rs163 let mut reader = pin!(reader); in new() localVariable
384 match reader.read(10) { in empty_read_stream()
423 let bs = reader.read(0).unwrap(); in infinite_read_stream()
450 match reader.read(0) { in finite_read_stream()
476 let bs = reader.read(1).unwrap(); in multiple_chunks_read_stream()
488 let bs = reader.read(1).unwrap(); in multiple_chunks_read_stream()
495 let bs = reader.read(1).unwrap(); in multiple_chunks_read_stream()
506 let bs = reader.read(1).unwrap(); in multiple_chunks_read_stream()
510 let bs = reader.read(1).unwrap(); in multiple_chunks_read_stream()
517 let bs = reader.read(1).unwrap(); in multiple_chunks_read_stream()
[all …]
H A Dtcp.rs18 let reader = Arc::new(Mutex::new(TcpReader::new(self.take_receive_stream()?))); in p2_streams() localVariable
21 reader: reader.clone(), in p2_streams()
24 let input: DynInputStream = Box::new(TcpReadStream(reader)); in p2_streams()
31 reader: Arc<Mutex<TcpReader>>, field
38 try_lock_for_socket(&self.reader)?.shutdown(); in shutdown()
/wasmtime-44.0.1/crates/cranelift/src/translate/
H A Dfunc_translator.rs62 reader.bytes_remaining(), in translate_body()
143 reader: &mut BinaryReader, in parse_local_decls()
150 let local_count = reader.read_var_u32()?; in parse_local_decls()
154 let pos = reader.original_position(); in parse_local_decls()
155 let count = reader.read_var_u32()?; in parse_local_decls()
156 let ty = reader.read()?; in parse_local_decls()
239 reader: BinaryReader, in parse_function_body()
252 let mut reader = OperatorsReader::new(reader); in parse_function_body() localVariable
255 while !reader.eof() { in parse_function_body()
259 let op = reader.read()?; in parse_function_body()
[all …]
/wasmtime-44.0.1/crates/wizer/src/component/
H A Dparse.rs84 Payload::InstanceSection(reader) => { in parse_into()
86 for instance in reader { in parse_into()
104 for _ in reader { in parse_into()
110 Payload::ComponentAliasSection(reader) => { in parse_into()
111 for alias in reader { in parse_into()
143 for function in reader { in parse_into()
159 Payload::ComponentImportSection(reader) => { in parse_into()
160 for import in reader { in parse_into()
170 for export in reader { in parse_into()
179 Payload::ComponentTypeSection(reader) => { in parse_into()
[all …]
/wasmtime-44.0.1/crates/wasi-common/src/
H A Dpipe.rs34 reader: Arc<RwLock<R>>, field
40 reader: self.reader.clone(), in clone()
56 pub fn from_shared(reader: Arc<RwLock<R>>) -> Self { in from_shared()
57 Self { reader } in from_shared()
64 match Arc::try_unwrap(self.reader) { in try_into_inner()
66 Err(reader) => { in try_into_inner()
67 self.reader = reader; in try_into_inner()
73 RwLock::write(&self.reader).unwrap() in borrow()
/wasmtime-44.0.1/crates/cranelift/src/debug/transform/
H A Dmod.rs53 translation.debuginfo.dwarf.debug_abbrev.reader().slice() in load_dwp()
56 translation.debuginfo.dwarf.debug_info.reader().slice() in load_dwp()
59 translation.debuginfo.dwarf.debug_line.reader().slice() in load_dwp()
62 translation.debuginfo.dwarf.debug_str.reader().slice() in load_dwp()
68 .reader() in load_dwp()
70 gimli::SectionId::DebugLoc => translation.debuginfo.debug_loc.reader().slice(), in load_dwp()
72 translation.debuginfo.debug_loclists.reader().slice() in load_dwp()
75 translation.debuginfo.debug_rnglists.reader().slice() in load_dwp()
78 translation.debuginfo.dwarf.debug_types.reader().slice() in load_dwp()
81 translation.debuginfo.debug_cu_index.reader().slice() in load_dwp()
[all …]
/wasmtime-44.0.1/crates/test-programs/src/bin/
H A Dfuzz_async.rs340 let prev = s.future_readers.insert(id, reader); in run()
345 let reader = i::future_take(id); in run() localVariable
347 let prev = s.future_readers.insert(id, reader); in run()
353 i::future_receive(id, reader); in run()
437 read: reader.into_future(), in run()
447 Err(reader) => { in run()
549 let (writer, reader) = wit_stream::new(); in run()
553 let prev = s.stream_readers.insert(id, reader); in run()
558 let reader = i::stream_take(id); in run() localVariable
560 let prev = s.stream_readers.insert(id, reader); in run()
[all …]
H A Dasync_intertask_communication.rs61 fn future_read(reader: u32) -> u32 { in future_read()
73 unsafe { future_read(reader, 0) } in future_read()
76 fn future_drop_readable(reader: u32) { in future_drop_readable()
88 unsafe { future_drop_readable(reader) } in future_drop_readable()
/wasmtime-44.0.1/cranelift/reader/
H A DCargo.toml3 name = "cranelift-reader"
5 description = "Cranelift textual IR reader"
7 documentation = "https://docs.rs/cranelift-reader"
/wasmtime-44.0.1/tests/misc_testsuite/component-model/async/
H A Dstream-cancel-finished-op.wast92 (local $reader i32)
98 (local.set $reader (i32.wrap_i64 (local.get $ret64)))
110 local.get $reader
122 (local $reader i32)
128 (local.set $reader (i32.wrap_i64 (local.get $ret64)))
131 ;; Write some data (will block since no reader is ready)
137 (call $stream.drop-readable (local.get $reader))
152 (local $reader i32)
158 (local.set $reader (i32.wrap_i64 (local.get $ret64)))
161 ;; Write some data (will block since no reader is ready)
[all …]
H A Dtrap-if-done.wast207 (func $trap-after-future-reader-dropped (export "trap-after-future-reader-dropped")
288 … (func $trap-after-stream-reader-eager-dropped (export "trap-after-stream-reader-eager-dropped")
304 … (func $trap-after-stream-reader-async-dropped (export "trap-after-stream-reader-async-dropped")
427 …(func (export "trap-after-future-reader-dropped") (canon lift (core func $core "trap-after-future-…
430 …(func (export "trap-after-stream-reader-eager-dropped") (canon lift (core func $core "trap-after-s…
431 …(func (export "trap-after-stream-reader-async-dropped") async (canon lift (core func $core "trap-a…
439 …(func (export "trap-after-future-reader-dropped") (alias export $d "trap-after-future-reader-dropp…
442 …(func (export "trap-after-stream-reader-eager-dropped") (alias export $d "trap-after-stream-reader…
443 …(func (export "trap-after-stream-reader-async-dropped") (alias export $d "trap-after-stream-reader…
453 (assert_trap (invoke "trap-after-future-reader-dropped") "cannot write to future after previous wri…
[all …]
H A Dtask-builtins.wast470 ;; Component that will drive the reader forward and write to the future/stream
475 (import "reader" (instance $reader
482 …(core func $run-reader-future (canon lower (func $reader "run-future") (memory $libc "memory") asy…
483 …(core func $run-reader-stream (canon lower (func $reader "run-stream") (memory $libc "memory") asy…
492 (import "" "run-reader-future" (func $run-reader-future (param i32 i32) (result i32)))
493 (import "" "run-reader-stream" (func $run-reader-stream (param i32 i32) (result i32)))
593 (export "run-reader-future" (func $run-reader-future))
594 (export "run-reader-stream" (func $run-reader-stream))
603 (component $reader
713 (instance $Reader (instantiate $reader))
[all …]
/wasmtime-44.0.1/winch/codegen/src/frame/
H A Dmod.rs49 reader: &mut BinaryReader<'_>, in new()
54 let local_count = reader.read_var_u32()?; in new()
58 let position = reader.original_position(); in new()
59 let count = reader.read_var_u32()?; in new()
60 let ty = reader.read()?; in new()
/wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/
H A Dfuture_stream_any.rs90 reader: FutureReader<T>, in try_from_future_reader()
96 let ty = match store.0.transmit_origin(reader.id())? { in try_from_future_reader()
102 id: reader.id(), in try_from_future_reader()
262 reader: StreamReader<T>, in try_from_stream_reader()
268 let ty = match store.0.transmit_origin(reader.id())? { in try_from_stream_reader()
274 id: reader.id(), in try_from_stream_reader()
H A Dfutures_and_streams.rs1522 reader: Option<FutureReader<T>>, field
1544 reader: Some(reader), in new()
1570 if let Some(reader) = &mut self.reader { in drop()
1922 reader: Some(reader), in new()
1948 if let Some(reader) = &mut self.reader { in drop()
4085 reader: u32, in guest_cancel_read()
4125 reader: u32, in guest_drop_readable()
4232 reader: u32, in future_cancel_read()
4256 reader: u32, in stream_cancel_read()
4279 reader: u32, in future_drop_readable()
[all …]
/wasmtime-44.0.1/tests/all/component_model/
H A Dasync.rs737 let reader = FutureReader::new(&mut store, MyFutureReader)?; in cancel_host_future() localVariable
738 func.call_async(&mut store, (reader,)).await?; in cancel_host_future()
1152 let reader = StreamReader::new(&mut store, NeverWriteStreamProducer)?; in stream_cancel_read_async_does_not_corrupt_state() localVariable
1153 func.call_async(&mut store, (reader,)).await?; in stream_cancel_read_async_does_not_corrupt_state()
1312 let reader = StreamReader::new(&mut store, bytes::Bytes::from_static(b"hello"))?; in bytes_stream_producer() localVariable
1314 func.call_async(&mut store, (reader, 1)).await?, in bytes_stream_producer()
1319 let reader = StreamReader::new(&mut store, bytes::Bytes::from_static(b"hello"))?; in bytes_stream_producer() localVariable
1321 func.call_async(&mut store, (reader, 100)).await?, in bytes_stream_producer()
/wasmtime-44.0.1/tests/all/guest_debug/
H A Dmod.rs78 let mut reader = BufReader::new(stderr); in spawn() localVariable
87 reader.read_line(&mut line)?; in spawn()
92 stderr_reader: reader, in spawn()
/wasmtime-44.0.1/cranelift/docs/
H A Dindex.md36 - [cranelift-reader](https://docs.rs/cranelift-reader)
/wasmtime-44.0.1/examples/
H A Dmpk.rs235 let reader = BufReader::new(file); in num_bytes_mapped() localVariable
237 for line in reader.lines() { in num_bytes_mapped()
/wasmtime-44.0.1/crates/wasi-tls/src/p2/
H A Dhost.rs34 let reader = WasiStreamReader::new(input); in new() localVariable
36 let transport = tokio::io::join(reader, writer); in new()
/wasmtime-44.0.1/crates/environ/src/
H A Dcomponent.rs153 … future_cancel_read(vmctx: vmctx, caller_instance: u32, ty: u32, async_: u8, reader: u32) -> u64;
157 future_drop_readable(vmctx: vmctx, caller_instance: u32, ty: u32, reader: u32) -> bool;
167 … stream_cancel_read(vmctx: vmctx, caller_instance: u32, ty: u32, async_: u8, reader: u32) -> u64;
171 stream_drop_readable(vmctx: vmctx, caller_instance: u32, ty: u32, reader: u32) -> bool;
/wasmtime-44.0.1/cranelift/serde/
H A DCargo.toml24 cranelift-reader = { workspace = true }
/wasmtime-44.0.1/cranelift/interpreter/
H A DCargo.toml29 cranelift-reader = { workspace = true }
/wasmtime-44.0.1/crates/wizer/src/
H A Drewrite.rs219 let mut reader = wasmparser::BinaryReader::new(s.data, 0); in is_name_section() localVariable
220 matches!(reader.read_string(), Ok("name")) in is_name_section()
/wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/component/
H A Dlibcalls.rs1059 reader: u32, in future_cancel_read()
1065 reader, in future_cancel_read()
1090 reader: u32, in future_drop_readable()
1092 instance.future_drop_readable(store, TypeFutureTableIndex::from_u32(ty), reader) in future_drop_readable()
1173 reader: u32, in stream_cancel_read()
1179 reader, in stream_cancel_read()
1204 reader: u32, in stream_drop_readable()
1206 instance.stream_drop_readable(store, TypeStreamTableIndex::from_u32(ty), reader) in stream_drop_readable()

12