socket_server 0.12.0

socket write event polling registration avoiding syscall
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

#![allow(incomplete_features)]
#![feature(generic_const_exprs)]

use std::time::Duration;

use qcell::{LCell, LCellOwner};
#[cfg(test)]
use socket_server::socket::{ServerSocketListener, Socket};

#[test]
fn test_mocking_system() {
    LCellOwner::scope(|mut owner| {
        #[cfg(test)]
        socket_server::mock::run_mock(
            &mut owner,
            ApplicationServer {},
            MockServer {},
            Duration::from_millis(50),
        )
    })
}

pub struct ApplicationServer {}
#[derive(Default)]
pub struct Player {}

impl<'id> ServerSocketListener<'id> for ApplicationServer {
    const MAX_CONNECTIONS: usize = 10;
    const READ_BUFFFER_LEN: usize = 100;
    const WRITE_BUFFER_LEN: usize = 100;
    type Connection = Player;

    fn tick(_server: &LCell<'id, Self>, _owner: &mut LCellOwner<'id>) {}

    fn accept(
        owner: &mut LCellOwner<'id>,
        _server: &LCell<'id, Self>,
        connection: &mut Socket<'id, '_, Self>,
        _addr: std::net::SocketAddr,
    ) {
        connection.register_close_event(owner)
    }

    fn read(
        _owner: &mut LCellOwner<'id>,
        _server: &LCell<'id, Self>,
        _connection: &mut Socket<'id, '_, Self>,
    ) {
    }

    fn flush(
        _owner: &mut LCellOwner<'id>,
        _server: &LCell<'id, Self>,
        _connection: &mut Socket<'id, '_, Self>,
    ) {
    }

    fn close(
        _owner: &mut LCellOwner<'id>,
        _server: &LCell<'id, Self>,
        _connection: &mut Socket<'id, '_, Self>,
    ) {
    }
}

pub struct MockServer {}
#[derive(Default)]
pub struct MockPlayer {}

impl<'id> ServerSocketListener<'id> for MockServer {
    const MAX_CONNECTIONS: usize = 10;
    const READ_BUFFFER_LEN: usize = 100;
    const WRITE_BUFFER_LEN: usize = 100;
    type Connection = MockPlayer;

    fn tick(_server: &LCell<'id, Self>, _owner: &mut LCellOwner<'id>) {}

    fn accept(
        _owner: &mut LCellOwner<'id>,
        _server: &LCell<'id, Self>,
        _connection: &mut Socket<'id, '_, Self>,
        _addr: std::net::SocketAddr,
    ) {
    }

    fn read(
        _owner: &mut LCellOwner<'id>,
        _server: &LCell<'id, Self>,
        _connection: &mut Socket<'id, '_, Self>,
    ) {
    }

    fn flush(
        _owner: &mut LCellOwner<'id>,
        _server: &LCell<'id, Self>,
        _connection: &mut Socket<'id, '_, Self>,
    ) {
    }

    fn close(
        _owner: &mut LCellOwner<'id>,
        _server: &LCell<'id, Self>,
        _connection: &mut Socket<'id, '_, Self>,
    ) {
        todo!()
    }
}