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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

//! Listeners accept connections from dialers.

use super::*;
use runng_derive::{NngGetOpts, NngSetOpts};
use runng_sys::*;

/// Wraps `nng_listener`.  See [nng_listener](https://nng.nanomsg.org/man/v1.2.2/nng_listener.5).
#[derive(Debug, NngGetOpts, NngSetOpts)]
#[prefix = "nng_listener_"]
pub struct NngListener {
    listener: nng_listener,
    socket: NngSocket,
}

impl NngListener {
    /// See [nng_listener_create](https://nng.nanomsg.org/man/v1.2.2/nng_listener_create.3).
    pub(crate) fn new(socket: NngSocket, url: &str) -> Result<Self> {
        unsafe {
            let mut listener = nng_listener::default();
            let (_cstring, url) = to_cstr(url)?;
            let res = nng_listener_create(&mut listener, socket.nng_socket(), url);
            Error::zero_map(res, || NngListener { listener, socket })
        }
    }

    /// See [nng_listener_start](https://nng.nanomsg.org/man/v1.2.2/nng_listener_start.3).
    pub fn start(&self) -> Result<()> {
        // TODO: Use different type for started vs non-started dialer?  According to nng docs options can generally only
        // be set before the dialer is started.
        unsafe { nng_int_to_result(nng_listener_start(self.listener, 0)) }
    }

    #[cfg(feature = "unstable")]
    pub fn getopt_sockaddr(&self, option: NngOption) -> Result<nng_sockaddr> {
        unsafe {
            let mut sockaddr = nng_sockaddr::default();
            Error::zero_map(
                nng_listener_getopt_sockaddr(self.listener, option.as_cptr(), &mut sockaddr),
                || sockaddr,
            )
        }
    }
}

impl NngWrapper for NngListener {
    type NngType = nng_listener;
    unsafe fn get_nng_type(&self) -> Self::NngType {
        self.listener
    }
}

impl GetSocket for NngListener {
    fn socket(&self) -> &NngSocket {
        &self.socket
    }
    fn socket_mut(&mut self) -> &mut NngSocket {
        &mut self.socket
    }
}

/// "Unsafe" version of `NngListener`.  Merely wraps `nng_listener` and makes no attempt to manage the underlying resources.
/// May be invalid, close unexpectedly, etc.
#[derive(Debug)]
pub struct UnsafeListener {
    listener: nng_listener,
}

impl UnsafeListener {
    pub(crate) fn new(listener: nng_listener) -> Self {
        Self { listener }
    }

    /// See [nng_listener_id](https://nng.nanomsg.org/man/v1.2.2/nng_listener_id.3).
    pub fn id(&self) -> i32 {
        unsafe { nng_listener_id(self.listener) }
    }
}