socket9 0.1.0-alpha.1

Extended untilities for the networking/unix sockets and raw network sockets
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
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
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130

/*-
 * socket9 - A RAW networking sockets manipulation and configration basing on 
 * strong types.
 * 
 * Copyright (C) 2021 Aleksandr Morozov, Lucia Hoffmann
 * Copyright (C) 2025 Aleksandr Morozov
 * 
 * The syslog-rs crate can be redistributed and/or modified
 * under the terms of either of the following licenses:
 *
 *   1. EUROPEAN UNION PUBLIC LICENCE v. 1.2 EUPL © the European Union 2007, 2016 OR
 *
 *   2. the Mozilla Public License Version 2.0 (the “MPL”) OR
 *                     
 *   3. The MIT License (MIT)
 */

 
use std::{cmp::min, ffi::c_int, time::Duration};

use crate::{IPPROTO_TCP, OptRMarker, OptWMarker, SockOptMarker};

#[cfg(not(any(
        target_os = "tvos",
        target_os = "ios",
        target_os = "macos",
        target_os = "openbsd",
    )))]
use crate::TCP_KEEPIDLE;

#[cfg(any(
        target_os = "ios",
        target_os = "macos",
        target_os = "tvos",
    ))]
use crate::TCP_KEEPALIVE;

#[repr(transparent)]
#[derive(Debug, Clone, Copy)]
pub struct IpProtoKeepIdleAliveR(c_int);

impl SockOptMarker for IpProtoKeepIdleAliveR 
{
    const SO_LEVEL: c_int = IPPROTO_TCP;  

    #[cfg(any(
        target_os = "ios",
        target_os = "macos",
        target_os = "tvos",
    ))]
    const SO_OPTNAME: c_int = TCP_KEEPALIVE;

    #[cfg(not(any(
        target_os = "tvos",
        target_os = "ios",
        target_os = "macos",
        target_os = "openbsd",
    )))]
    const SO_OPTNAME: c_int = TCP_KEEPIDLE;

    type DataType = Duration;
    type InputType = c_int;

    #[inline]
    fn from(value: Self::InputType) -> Self 
    {
        return Self(value);
    }

    #[inline]
    fn get(self) -> Self::DataType
    {
        return Duration::from_secs(self.0 as u64);
    }

    #[inline]
    fn from_user(_sz: Self::DataType) -> Self where Self: Sized
    {
        panic!("IpProtoKeepIdleAliveR cannot write!");
    }
}

impl OptRMarker for IpProtoKeepIdleAliveR {}

#[repr(transparent)]
#[derive(Debug, Clone, Copy)]
pub struct IpProtoKeepIdleAliveW(c_int);

impl SockOptMarker for IpProtoKeepIdleAliveW 
{
    const SO_LEVEL: c_int = IPPROTO_TCP;  

    #[cfg(any(
        target_os = "ios",
        target_os = "macos",
        target_os = "tvos",
    ))]
    const SO_OPTNAME: c_int = TCP_KEEPALIVE;

    #[cfg(not(any(
        target_os = "tvos",
        target_os = "ios",
        target_os = "macos",
        target_os = "openbsd",
    )))]
    const SO_OPTNAME: c_int = TCP_KEEPIDLE;

    type DataType = Duration;
    type InputType = c_int;

    #[inline]
    fn from(_value: Self::InputType) -> Self 
    {
        panic!("IpProtoKeepIdleAliveR cannot read!");
    }

    #[inline]
    fn get(self) -> Self::DataType
    {
        panic!("IpProtoKeepIdleAliveR cannot read!");
    }

    #[inline]
    fn from_user(sz: Self::DataType) -> Self where Self: Sized
    {
        return Self(min(sz.as_secs(), c_int::MAX as u64) as Self::InputType);
    }
}

impl OptWMarker for IpProtoKeepIdleAliveW {}