Function ConnectNamedPipe

crates/vm/src/stdlib/_winapi.rs:1046–1101

(args: ConnectNamedPipeArgs, vm: &VirtualMachine)

    #[pyfunction]
    fn ConnectNamedPipe(args: ConnectNamedPipeArgs, vm: &VirtualMachine) -> PyResult<PyObjectRef> {
        use windows_sys::Win32::Foundation::{
            ERROR_IO_PENDING, ERROR_PIPE_CONNECTED, GetLastError,
        };

        let handle = args.handle;
        let use_overlapped = args.overlapped.unwrap_or(false);

        if use_overlapped {
            // Overlapped (async) mode
            let ov = Overlapped::new_with_handle(handle.0);

            let _ret = {
                let mut inner = ov.inner.lock();
                unsafe {
                    windows_sys::Win32::System::Pipes::ConnectNamedPipe(
                        handle.0,
                        &mut *inner.overlapped,
                    )
                }
            };

            let err = unsafe { GetLastError() };
            match err {
                ERROR_IO_PENDING => {
                    let mut inner = ov.inner.lock();
                    inner.pending = true;
                }
                ERROR_PIPE_CONNECTED => {
                    let inner = ov.inner.lock();
                    unsafe {
                        windows_sys::Win32::System::Threading::SetEvent(inner.overlapped.hEvent);
                    }
                }
                _ => {
                    return Err(std::io::Error::from_raw_os_error(err as i32).to_pyexception(vm));
                }
            }

            Ok(ov.into_pyobject(vm))
        } else {
            // Synchronous mode
            let ret = unsafe {
                windows_sys::Win32::System::Pipes::ConnectNamedPipe(handle.0, null_mut())
            };

            if ret == 0 {
                let err = unsafe { GetLastError() };
                if err != ERROR_PIPE_CONNECTED {
                    return Err(std::io::Error::from_raw_os_error(err as i32).to_pyexception(vm));
                }
            }

            Ok(vm.ctx.none())
        }
    }

    /// Helper for GetShortPathName and GetLongPathName