tiny_http_fork 0.12.10

Low level HTTP server library FORK
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

extern crate tiny_http_fork;

use std::io::Write;
use divan::Bencher;
use tiny_http_fork::{Header, Method, config::ServerConfig};



fn main() 
{
    // Run registered benchmarks.
    divan::main();
}

#[cfg(feature = "allow_utf8_headers")]
#[divan::bench]
fn header_parsing_with_utf8(bencher: Bencher) 
{
    bencher
        .bench_local(
            move || 
            {
                Header::from_bytes("Auth-Custom-Type", "佳波").unwrap();
                Header::from_bytes("Auth-Custom-Type", "Kanami").unwrap();
                Header::from_bytes("Other-Header", "指ずク熱体ばぴつこ真下せ長芸ゆぐも称断イへ超市へん覧追テ境査ぶる出研シヘメ野朝").unwrap();
            }
        );
}

#[cfg(not(feature = "allow_utf8_headers"))]
#[divan::bench]
fn header_parsing_with_ascii(bencher: Bencher) 
{
    bencher
        .bench_local(
            move || 
            {
                Header::from_bytes("Auth-Custom-Type", "Kanami").unwrap();
                Header::from_bytes("Other-Header", "very long text for the header data").unwrap();
            }
        );
}

#[divan::bench]
fn sequential_requests(bencher: Bencher) 
{
    let cfg = 
        ServerConfig::new_http("127.0.0.1:0")
            .unwrap()
            .set_min_threads(4)
            .set_max_threads(64);

    let server = tiny_http_fork::Server::new(cfg).unwrap();
    let port = server.server_addr().to_ip().unwrap().port();

   
    let mut stream = std::net::TcpStream::connect(("127.0.0.1", port)).unwrap();

    bencher
        .bench_local(
            move || 
            {
                write!(stream, "GET / HTTP/1.1\r\nHost: localhost\r\n\r\n").unwrap();

                let request = server.recv().unwrap();

                assert_eq!(request.method(), &Method::Get);

                request.respond(tiny_http_fork::Response::new_empty(tiny_http_fork::StatusCode(204))).unwrap();    
            }
        );
}

#[divan::bench]
fn parallel_requests(bencher: Bencher) 
{
    fdlimit::raise_fd_limit().unwrap();

    let cfg = 
        ServerConfig::new_http("127.0.0.1:0")
            .unwrap()
            .set_min_threads(4)
            .set_max_threads(64);

    let server = tiny_http_fork::Server::new(cfg).unwrap();
    let port = server.server_addr().to_ip().unwrap().port();

    bencher
        .bench_local(
            move || 
            {
                let mut streams = Vec::new();

                for _ in 0..1000usize {
                    let mut stream = std::net::TcpStream::connect(("127.0.0.1", port)).unwrap();
                    (write!(
                        stream,
                        "GET / HTTP/1.1\r\nHost: localhost\r\nConnection: close\r\n\r\n"
                    ))
                    .unwrap();
                    streams.push(stream);
                }

                loop {
                    let request = match server.try_recv().unwrap() {
                        None => break,
                        Some(rq) => rq,
                    };

                    assert_eq!(request.method(), &Method::Get);

                    request.respond(tiny_http_fork::Response::new_empty(tiny_http_fork::StatusCode(204))).unwrap();
                }
            }
        );
}