| /wasmtime-44.0.1/crates/wasi-io/src/ |
| H A D | streams.rs | 83 pub type StreamResult<T> = Result<T, StreamError>;
86 pub enum StreamError { enum
92 impl StreamError { impl
93 pub fn trap(msg: &str) -> StreamError { in trap() argument
98 impl alloc::fmt::Display for StreamError { implementation
108 impl core::error::Error for StreamError { implementation
111 StreamError::Closed => None, in source()
112 StreamError::LastOperationFailed(e) | StreamError::Trap(e) => e.source(), in source()
219 Err(StreamError::Closed) => {} in blocking_write_and_flush()
224 Err(StreamError::Closed) => {} in blocking_write_and_flush()
[all …]
|
| H A D | impls.rs | 3 use crate::streams::{DynInputStream, DynOutputStream, StreamError, StreamResult};
98 fn convert_stream_error(&mut self, err: StreamError) -> Result<streams::StreamError> { in convert_stream_error() argument
100 StreamError::Closed => Ok(streams::StreamError::Closed), in convert_stream_error()
101 StreamError::LastOperationFailed(e) => { in convert_stream_error()
102 Ok(streams::StreamError::LastOperationFailed(self.push(e)?)) in convert_stream_error()
104 StreamError::Trap(e) => Err(e), in convert_stream_error()
146 return Err(StreamError::trap( in blocking_write_and_flush()
162 return Err(StreamError::trap( in blocking_write_zeroes_and_flush()
|
| H A D | bindings.rs | 24 "wasi:io/streams.stream-error" => crate::streams::StreamError,
|
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | tcp.rs | 3 SocketResult, StreamError,
63 return Err(StreamError::Closed); in read()
74 return Err(StreamError::Closed); in read()
189 WriteState::Closed => return Err(StreamError::Closed), in write()
212 return Err(StreamError::Closed); in write()
222 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
231 WriteState::Closed => Err(StreamError::Closed), in flush()
235 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() argument
248 WriteState::Closed => return Err(StreamError::Closed), in check_write()
320 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
[all …]
|
| H A D | pipe.rs | 46 return Err(StreamError::Closed); in read()
120 Err(StreamError::Closed) in check_write()
246 Err(StreamError::Closed) in read()
304 Err(StreamError::Closed) in read()
320 Err(StreamError::Closed) in write()
323 Err(StreamError::Closed) in flush()
327 Err(StreamError::Closed) in check_write()
386 Err(StreamError::Closed) => {} in empty_read_stream()
574 Err(StreamError::Closed) in backpressure_read_stream()
666 Err(StreamError::Closed) => { in closed_write_stream_()
[all …]
|
| H A D | write_stream.rs | 1 use crate::p2::{OutputStream, Pollable, StreamError};
19 fn check_error(&mut self) -> Result<(), StreamError> { in check_error() argument
21 return Err(StreamError::LastOperationFailed(e)); in check_error()
24 return Err(StreamError::Closed); in check_error()
54 fn check_write(&self) -> Result<usize, StreamError> { in check_write() argument
168 fn write(&mut self, bytes: Bytes) -> Result<(), StreamError> { in write() argument
172 return Err(StreamError::Trap(format_err!( in write()
181 None => return Err(StreamError::Trap(format_err!("write exceeded budget"))), in write()
187 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
197 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() argument
|
| H A D | filesystem.rs | 4 use crate::p2::{InputStream, OutputStream, Pollable, StreamError, StreamResult};
145 ReadState::Closed => Err(StreamError::Closed), in read()
284 fn write(&mut self, buf: Bytes) -> Result<(), StreamError> { in write() argument
287 OutputState::Closed => return Err(StreamError::Closed), in write()
290 return Err(StreamError::Trap(format_err!( in write()
310 OutputState::Closed => return Err(StreamError::Closed), in blocking_write_and_flush()
333 Err(StreamError::LastOperationFailed(e.into())) in blocking_write_and_flush()
337 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
343 OutputState::Closed => Err(StreamError::Closed), in flush()
350 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() argument
[all …]
|
| H A D | bindings.rs | 146 use wasmtime_wasi_io::streams::StreamError;
152 "wasi:io/streams.stream-error" => StreamError,
377 "wasi:io/streams.stream-error" => wasmtime_wasi_io::streams::StreamError,
|
| /wasmtime-44.0.1/crates/wasi/src/cli/ |
| H A D | locked_async.rs | 81 fn read(&mut self, size: usize) -> Result<bytes::Bytes, p2::StreamError> { in read() argument
84 Err(_) => Err(p2::StreamError::trap("concurrent reads are not supported")), in read()
87 fn skip(&mut self, size: usize) -> Result<usize, p2::StreamError> { in skip() argument
90 Err(_) => Err(p2::StreamError::trap("concurrent skips are not supported")), in skip()
179 fn check_write(&mut self) -> Result<usize, p2::StreamError> { in check_write() argument
185 fn write(&mut self, bytes: Bytes) -> Result<(), p2::StreamError> { in write() argument
191 fn flush(&mut self) -> Result<(), p2::StreamError> { in flush() argument
194 Err(_) => Err(p2::StreamError::trap( in flush()
310 Err(p2::StreamError::Closed) => Poll::Ready(None), in poll()
316 Err(p2::StreamError::LastOperationFailed(e)) => { in poll()
[all …]
|
| H A D | file.rs | 2 use crate::p2::{InputStream, OutputStream, Pollable, StreamError, StreamResult};
53 .map_err(|e| StreamError::LastOperationFailed(wasmtime::format_err!(e))) in write()
60 .map_err(|e| StreamError::LastOperationFailed(wasmtime::format_err!(e))) in flush()
131 .map_err(|e| StreamError::LastOperationFailed(wasmtime::format_err!(e)))?; in read()
133 return Err(StreamError::Closed); in read()
|
| H A D | worker_thread_stdin.rs | 38 streams::{InputStream, StreamError},
140 fn read(&mut self, size: usize) -> Result<Bytes, StreamError> { in read() argument
161 Err(StreamError::LastOperationFailed(e.into())) in read()
165 Err(StreamError::Closed) in read()
|
| H A D | stdout.rs | 81 .map_err(|e| p2::StreamError::LastOperationFailed(wasmtime::format_err!(e))) in write()
89 .map_err(|e| p2::StreamError::LastOperationFailed(wasmtime::format_err!(e))) in flush()
|
| /wasmtime-44.0.1/crates/wasi/src/p2/host/ |
| H A D | io.rs | 2 StreamError, StreamResult,
13 impl From<async_streams::StreamError> for streams::StreamError { implementation
14 fn from(other: async_streams::StreamError) -> Self { in from()
16 async_streams::StreamError::LastOperationFailed(e) => Self::LastOperationFailed(e), in from()
17 async_streams::StreamError::Closed => Self::Closed, in from()
23 fn convert_stream_error(&mut self, err: StreamError) -> wasmtime::Result<streams::StreamError> { in convert_stream_error() argument
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p2_tcp_streams.rs | 2 use test_programs::wasi::io::streams::{InputStream, OutputStream, StreamError};
22 assert!(matches!(client.input.read(10), Err(StreamError::Closed))); in test_tcp_input_stream_should_be_closed_by_remote_shutdown()
25 assert!(matches!(client.input.read(0), Err(StreamError::Closed))); in test_tcp_input_stream_should_be_closed_by_remote_shutdown()
47 assert!(matches!(client.input.read(10), Err(StreamError::Closed))); in test_tcp_input_stream_should_be_closed_by_local_shutdown()
50 assert!(matches!(client.input.read(0), Err(StreamError::Closed))); in test_tcp_input_stream_should_be_closed_by_local_shutdown()
71 Err(StreamError::Closed) in test_tcp_output_stream_should_be_closed_by_local_shutdown()
77 Err(StreamError::Closed) in test_tcp_output_stream_should_be_closed_by_local_shutdown()
79 assert!(matches!(client.output.flush(), Err(StreamError::Closed))); in test_tcp_output_stream_should_be_closed_by_local_shutdown()
|
| H A D | p2_cli_splice_stdin.rs | 2 use test_programs::wasi::io::streams::StreamError;
13 Err(StreamError::Closed) => break, in main()
14 Err(StreamError::LastOperationFailed(f)) => { in main()
|
| H A D | p2_file_read_write.rs | 36 Err(wasi::io::streams::StreamError::Closed) => break, in main()
42 Err(wasi::io::streams::StreamError::Closed) => break, in main()
|
| H A D | p2_http_outbound_request_content_length.rs | 74 test_programs::wasi::io::streams::StreamError::LastOperationFailed(e) => { in main()
77 test_programs::wasi::io::streams::StreamError::Closed => panic!("request closed"), in main()
|
| H A D | p2_api_proxy_streaming.rs | 325 io::{self, streams::StreamError},
510 Err(StreamError::Closed) => { in incoming_body()
519 Err(StreamError::LastOperationFailed(error)) => { in incoming_body()
|
| /wasmtime-44.0.1/crates/test-programs/src/ |
| H A D | tls.rs | 3 use crate::wasi::io::streams::StreamError;
43 Err(StreamError::Closed) => return Ok(()), in blocking_close_output()
44 Err(StreamError::LastOperationFailed(e)) => return Err(e), in blocking_close_output()
|
| H A D | sockets.rs | 3 use crate::wasi::io::streams::{InputStream, OutputStream, StreamError};
42 Err(StreamError::Closed) => return Ok(data), in blocking_read_to_end()
43 Err(StreamError::LastOperationFailed(e)) => return Err(e), in blocking_read_to_end()
50 pub fn blocking_write_util(&self, mut bytes: &[u8]) -> Result<(), StreamError> { in blocking_write_util() argument
|
| /wasmtime-44.0.1/crates/wasi-http/src/p2/ |
| H A D | body.rs | 15 use wasmtime_wasi::p2::{InputStream, OutputStream, Pollable, StreamError};
237 fn read(&mut self, size: usize) -> Result<Bytes, StreamError> { in read() argument
247 return Err(StreamError::LastOperationFailed(e)); in read()
257 IncomingBodyStreamState::Closed => return Err(StreamError::Closed), in read()
609 fn write(&mut self, bytes: Bytes) -> Result<(), StreamError> { in write() argument
618 return Err(StreamError::LastOperationFailed(format_err!( in write()
631 Err(StreamError::Trap(format_err!("write exceeded budget"))) in write()
639 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
643 Err(StreamError::Closed) in flush()
649 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() argument
[all …]
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p2/ |
| H A D | io.rs | 14 DynInputStream, DynOutputStream, OutputStream, Pollable, StreamError, StreamResult,
119 Err(StreamError::Closed) => { in poll_read()
171 Err(StreamError::Closed) => Poll::Ready(Ok(0)), in poll_write()
175 Err(StreamError::Closed) => { in poll_write()
223 fn try_lock(&self) -> Result<tokio::sync::MutexGuard<'_, WriteState<IO>>, StreamError> { in try_lock() argument
226 .map_err(|_| StreamError::trap("concurrent access to resource not supported")) in try_lock()
287 return Err(StreamError::Trap(wasmtime::format_err!( in write()
339 WriteState::Closed => return Err(StreamError::Closed), in flush()
351 WriteState::Closed => Err(StreamError::Closed), in check_write()
357 Err(StreamError::LastOperationFailed(e.into())) in check_write()
|
| /wasmtime-44.0.1/crates/c-api/src/ |
| H A D | wasi.rs | 15 use wasmtime_wasi_io::streams::StreamError;
200 fn write(&mut self, bytes: Bytes) -> Result<(), StreamError> { in write() argument
204 .map_err(|e| StreamError::LastOperationFailed(e.into()))?; in write()
207 return Err(StreamError::LastOperationFailed(wasmtime::format_err!( in write()
214 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
217 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() argument
|
| /wasmtime-44.0.1/crates/wasi-preview1-component-adapter/src/ |
| H A D | lib.rs | 1222 Err(streams::StreamError::Closed) => 0, in fd_pwrite()
1223 Err(streams::StreamError::LastOperationFailed(e)) => { in fd_pwrite()
1278 Err(streams::StreamError::Closed) => { in fd_read()
1282 Err(streams::StreamError::LastOperationFailed(e)) => { in fd_read()
2570 ) -> Result<Vec<u8>, streams::StreamError> { in read() argument
2603 Err(streams::StreamError::Closed) => 0, in write()
2604 Err(streams::StreamError::LastOperationFailed(e)) => { in write()
2613 Err(streams::StreamError::Closed) => return Ok(0), in write()
2614 Err(streams::StreamError::LastOperationFailed(e)) => { in write()
2621 Err(streams::StreamError::Closed) => return Ok(0), in write()
[all …]
|
| /wasmtime-44.0.1/crates/wasi/src/ |
| H A D | p1.rs | 87 streams::{StreamError, StreamResult},
287 Err(StreamError::Closed) => Ok(Vec::new()), in read()
302 .map_err(|e| StreamError::Trap(e.into()))?; in write()
678 let nwritten = nwritten.map_err(|e| StreamError::LastOperationFailed(e.into()))?; in fd_write_impl()
904 impl From<StreamError> for types::Error {
905 fn from(err: StreamError) -> Self { in from()
907 StreamError::Closed => types::Errno::Io.into(), in from()
908 StreamError::LastOperationFailed(e) => match e.downcast::<std::io::Error>() { in from()
915 StreamError::Trap(e) => types::Error::trap(e), in from()
1695 .map_err(|e| StreamError::LastOperationFailed(e.into()))?, in fd_read()
[all …]
|