wasmer_wasix/syscalls/wasix/
fd_dup2.rs

1use super::*;
2use crate::syscalls::*;
3
4/// ### `fd_dup()`
5/// Duplicates the file handle
6/// Inputs:
7/// - `Fd fd`
8///   File handle to be cloned
9/// Outputs:
10/// - `Fd fd`
11///   The new file handle that is a duplicate of the original
12#[instrument(level = "trace", skip_all, fields(%fd, ret_fd = field::Empty), ret)]
13pub fn fd_dup2<M: MemorySize>(
14    mut ctx: FunctionEnvMut<'_, WasiEnv>,
15    fd: WasiFd,
16    min_result_fd: WasiFd,
17    cloexec: Bool,
18    ret_fd: WasmPtr<WasiFd, M>,
19) -> Result<Errno, WasiError> {
20    WasiEnv::do_pending_operations(&mut ctx)?;
21
22    let copied_fd = wasi_try_ok!(fd_dup_internal(
23        &mut ctx,
24        fd,
25        min_result_fd,
26        cloexec == Bool::True
27    ));
28    let env = ctx.data();
29
30    #[cfg(feature = "journal")]
31    if env.enable_journal {
32        JournalEffector::save_fd_duplicate(&mut ctx, fd, copied_fd, cloexec == Bool::True)
33            .map_err(|err| {
34                tracing::error!("failed to save file descriptor duplicate event - {}", err);
35                WasiError::Exit(ExitCode::from(Errno::Fault))
36            })?;
37    }
38
39    Span::current().record("ret_fd", copied_fd);
40    let env = ctx.data();
41    let (memory, state) = unsafe { env.get_memory_and_wasi_state(&ctx, 0) };
42    wasi_try_mem_ok!(ret_fd.write(&memory, copied_fd));
43
44    Ok(Errno::Success)
45}
46
47pub(crate) fn fd_dup_internal(
48    ctx: &mut FunctionEnvMut<'_, WasiEnv>,
49    fd: WasiFd,
50    min_result_fd: WasiFd,
51    cloexec: bool,
52) -> Result<WasiFd, Errno> {
53    let env = ctx.data();
54    let (memory, state) = unsafe { env.get_memory_and_wasi_state(&ctx, 0) };
55    let fd = state.fs.clone_fd_ext(fd, min_result_fd, Some(cloexec))?;
56    Ok(fd)
57}
wasmer_wasix/syscalls/wasix/fd_dup2.rs

wasmer_wasix/syscalls/wasix/
fd_dup2.rs
