aboutsummaryrefslogtreecommitdiff
path: root/src/tunnel.rs
blob: 0de6f51c3c14e88c06df465d84021aedf3466109 (plain) (blame)
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
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
use std::ffi::CString;
use std::io;
use std::net::{Ipv4Addr, Ipv6Addr};

use crate::{internal, Error, Result};

/// A handle to a 6in4 tunnel. The interface is automatically deleted on drop.
#[derive(Debug)]
pub struct Sit {
    name: String,
}

impl Drop for Sit {
    fn drop(&mut self) {
        let _ = self.do_delete();
    }
}

impl Sit {
    pub fn new(name: &str, master: &str, laddr: Ipv4Addr, raddr: Ipv4Addr) -> Result<Self> {
        let tnlname = CString::new(name)?.into_raw();
        let ifmaster = CString::new(master)?.into_raw();

        let err = unsafe {
            internal::netlinkd_create_6in4(
                tnlname,
                ifmaster,
                u32::from(laddr).to_be(),
                u32::from(raddr).to_be(),
            )
        };

        let _ = unsafe { CString::from_raw(tnlname) };
        let _ = unsafe { CString::from_raw(ifmaster) };

        if err < 0 {
            Err(Error::Io(io::Error::last_os_error()))
        } else {
            Ok(Self {
                name: name.to_owned(),
            })
        }
    }

    fn do_delete(&self) -> Result<()> {
        let tnlname = CString::new(self.name.as_str())?.into_raw();
        let err = unsafe { internal::netlinkd_delete_tunnel(tnlname) };
        let _ = unsafe { CString::from_raw(tnlname) };

        if err < 0 {
            Err(Error::Io(io::Error::last_os_error()))
        } else {
            Ok(())
        }
    }
}

/// A handle to a 4in6 tunnel. The interface is automatically deleted on drop.
#[derive(Debug)]
pub struct IpIp6 {
    name: String,
}

impl Drop for IpIp6 {
    fn drop(&mut self) {
        let _ = self.do_delete();
    }
}

impl IpIp6 {
    pub fn new(name: &str, master: &str, laddr: Ipv6Addr, raddr: Ipv6Addr) -> Result<Self> {
        let tnlname = CString::new(name)?.into_raw();
        let ifmaster = CString::new(master)?.into_raw();

        let err = unsafe {
            internal::netlinkd_create_4in6(
                tnlname,
                ifmaster,
                &laddr.octets() as *const u8,
                &raddr.octets() as *const u8,
            )
        };

        let _ = unsafe { CString::from_raw(tnlname) };
        let _ = unsafe { CString::from_raw(ifmaster) };

        if err < 0 {
            Err(Error::Io(io::Error::last_os_error()))
        } else {
            Ok(Self {
                name: name.to_owned(),
            })
        }
    }

    fn do_delete(&self) -> Result<()> {
        let tnlname = CString::new(self.name.as_str())?.into_raw();
        let err = unsafe { internal::netlinkd_delete_tunnel(tnlname) };
        let _ = unsafe { CString::from_raw(tnlname) };

        if err < 0 {
            Err(Error::Io(io::Error::last_os_error()))
        } else {
            Ok(())
        }
    }
}