mii/wasmer
1
0
Fork 0
mirror of https://github.com/mii443/wasmer.git synced 2025-12-08 05:38:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added set_blocking method to control blocking behaviour for WasiPipe

Browse Source
This commit is contained in:
Felix Schütt
2022-09-19 12:27:33 +02:00
parent 64399973e3
commit f21689d1e6
2 changed files with 51 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
lib/c-api/src/wasm_c_api/wasi/mod.rs
View File

@@ -350,9 +350,21 @@ unsafe extern "C" fn wasi_pipe_delete_memory_2(ptr: *const c_void /* = *WasiPipe
/// for backing stdin / stdout / stderr
#[no_mangle]
pub unsafe extern "C" fn wasi_pipe_new(ptr_user: &mut *mut wasi_pipe_t) -> *mut wasi_pipe_t {
wasi_pipe_new_internal_memory(ptr_user, false)
}
/// Same as `wasi_pipe_new`, but the pipe will block to wait for stdin input
#[no_mangle]
pub unsafe extern "C" fn wasi_pipe_new_blocking(ptr_user: &mut *mut wasi_pipe_t) -> *mut wasi_pipe_t {
wasi_pipe_new_internal_memory(ptr_user, true)
}
unsafe fn wasi_pipe_new_internal_memory(ptr_user: &mut *mut wasi_pipe_t, blocking: bool) -> *mut wasi_pipe_t {
use std::mem::ManuallyDrop;
let pair = WasiBidirectionalPipePair::new();
let mut pair = WasiBidirectionalPipePair::new();
pair.send.set_blocking(blocking);
pair.recv.set_blocking(blocking);
let mut data1 = ManuallyDrop::new(pair.send);
let ptr1: &mut WasiPipe = &mut data1;