| /wasmtime-44.0.1/crates/wasi-io/src/ |
| H A D | streams.rs | 178 fn check_write(&mut self) -> StreamResult<usize>; in check_write() method
236 let n = self.check_write()?; in write_zeroes()
256 let n = self.check_write()?; in write_ready()
|
| H A D | impls.rs | 126 fn check_write(&mut self, stream: Resource<DynOutputStream>) -> StreamResult<u64> { in check_write() method
127 let bytes = self.get_mut(&stream)?.check_write()?; in check_write()
200 output.check_write()? in splice()
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p2_api_reactor.rs | 42 let n = match o.check_write() { in write_strings_to()
60 match o.check_write() { in write_strings_to()
|
| H A D | p2_tcp_streams.rs | 63 assert!(client.output.check_write().unwrap() as usize >= message.len()); in test_tcp_output_stream_should_be_closed_by_local_shutdown()
76 client.output.check_write(), in test_tcp_output_stream_should_be_closed_by_local_shutdown()
93 .check_write() in test_tcp_shutdown_should_not_lose_data()
|
| H A D | p2_stream_pollable_correct.rs | 20 let n = stdout.check_write().unwrap() as usize; in main()
|
| H A D | piped_simple.rs | 18 let n = out.check_write().unwrap() as usize; in producer()
|
| H A D | piped_multiple.rs | 18 let n = out.check_write().unwrap() as usize; in producer()
|
| H A D | piped_polling.rs | 21 let available = out.check_write().unwrap() as usize; in producer()
|
| H A D | p2_api_proxy_streaming.rs | 405 match stream.check_write() { in outgoing_body()
|
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | write_stream.rs | 54 fn check_write(&self) -> Result<usize, StreamError> { in check_write() method
197 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() method
198 self.worker.check_write() in check_write()
|
| H A D | tcp.rs | 235 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() method
324 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() method
325 try_lock_for_stream(&self.0)?.check_write() in check_write()
|
| H A D | pipe.rs | 114 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() method
286 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() method
326 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() method
|
| H A D | filesystem.rs | 350 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() method
|
| /wasmtime-44.0.1/crates/wasi/src/p2/host/ |
| H A D | io.rs | 33 fn check_write(&mut self, stream: Resource<OutputStream>) -> StreamResult<u64> { in check_write() method
34 Ok(AsyncHostOutputStream::check_write(self, stream)?) in check_write()
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p2/ |
| H A D | io.rs | 152 match output.check_write() { in poll_write()
248 fn check_write(&mut self) -> StreamResult<usize> { in check_write() function
249 self.try_lock()?.check_write() in check_write()
345 fn check_write(&mut self) -> StreamResult<usize> { in check_write() function
|
| /wasmtime-44.0.1/crates/test-programs/src/ |
| H A D | http.rs | 100 let permit = match request_body.check_write() { in request()
122 match request_body.check_write() { in request()
|
| H A D | tls.rs | 38 match output.check_write() { in blocking_close_output()
|
| H A D | sockets.rs | 57 let permit = self.check_write()?; in blocking_write_util()
|
| /wasmtime-44.0.1/crates/wasi/src/cli/ |
| H A D | locked_async.rs | 179 fn check_write(&mut self) -> Result<usize, p2::StreamError> { in check_write() method
181 Ok(mut stream) => stream.check_write(), in check_write()
|
| H A D | stdout.rs | 92 fn check_write(&mut self) -> p2::StreamResult<usize> { in check_write() method
|
| H A D | file.rs | 63 fn check_write(&mut self) -> StreamResult<usize> { in check_write() method
|
| /wasmtime-44.0.1/crates/c-api/src/ |
| H A D | wasi.rs | 217 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() method
|
| /wasmtime-44.0.1/crates/wasi-http/src/p2/ |
| H A D | body.rs | 649 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() method
|
| /wasmtime-44.0.1/examples/min-platform/embedding/src/ |
| H A D | wasi.rs | 323 fn check_write(&mut self) -> wasmtime_wasi_io::streams::StreamResult<usize> { in check_write() method
|
| /wasmtime-44.0.1/src/commands/ |
| H A D | serve.rs | 1385 fn check_write(&mut self) -> StreamResult<usize> { in check_write() method
|