ntex-net 3.14.1

ntexwork utils for ntex framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

use std::fmt;

use socket2::{SockAddr, Socket};
use windows_sys::Win32::System::IO::OVERLAPPED;

mod connect;
mod driver;
mod io;
mod ops;
mod stream;

pub use self::driver::{Driver, DriverApi, Handler};

/// Tcp stream wrapper for neon `TcpStream`
struct TcpStream(Socket, SockAddr, stream::StreamOps);

/// Tcp stream wrapper for neon `UnixStream`
struct UnixStream(Socket, SockAddr, stream::StreamOps);

/// The overlapped struct for IOCP ops.
#[repr(C)]
pub struct Overlapped {
    /// The base [`OVERLAPPED`].
    pub(crate) base: OVERLAPPED,
    /// User data
    pub(crate) hnd: u32,
    pub(crate) udata: u32,
}

impl Overlapped {
    pub(crate) fn new(hnd: u32, udata: u32) -> Self {
        Self {
            hnd,
            udata,
            base: unsafe { std::mem::zeroed() },
        }
    }

    pub fn as_overlapped(&self) -> *mut OVERLAPPED {
        (&raw const self.base).cast_mut()
    }

    pub fn user_data(&self) -> u32 {
        self.udata
    }
}

impl fmt::Debug for Overlapped {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.debug_struct("Overlapped")
            .field("base", &"OVERLAPPED")
            .field("hnd", &self.hnd)
            .field("udata", &self.udata)
            .finish()
    }
}