sark-h2 0.13.0

HTTP/2 protocol primitives + client/server bootstrap for sark stack
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

use dope::driver::token::Token;
use dope_fiber::slab::{ErasedTaskId, TaskId};
use o3::collections::FixedHashTable;

use crate::stream::StreamId;

#[derive(Clone, Copy)]
pub(crate) struct TaskTarget(Option<ErasedTaskId>);

impl TaskTarget {
    pub(crate) const fn task(key: ErasedTaskId) -> Self {
        Self(Some(key))
    }

    pub(crate) const fn key(self) -> Option<ErasedTaskId> {
        self.0
    }
}

pub(crate) struct RunningTask {
    pub(crate) connection_id: Token,
    pub(crate) stream_id: StreamId,
    pub(crate) task: TaskId,
    pub(crate) key: ErasedTaskId,
    pub(crate) previous: Option<u32>,
    pub(crate) next: Option<u32>,
    pub(crate) ready: bool,
    pub(crate) ready_previous: Option<u32>,
    pub(crate) ready_next: Option<u32>,
}

#[derive(Clone, Copy)]
struct TaskMapEntry {
    connection_id: Token,
    stream_id: StreamId,
    index: u32,
}

pub(crate) struct TaskMap {
    entries: FixedHashTable<TaskMapEntry>,
}

impl TaskMap {
    pub(crate) fn with_capacity(capacity: usize) -> Self {
        Self {
            entries: FixedHashTable::with_capacity(capacity),
        }
    }

    fn hash(connection_id: Token, stream_id: StreamId) -> u64 {
        let value = connection_id.raw() ^ u64::from(stream_id.as_u32()).wrapping_mul(0x9E37_79B9);
        value.wrapping_mul(0x9E37_79B9_7F4A_7C15)
    }

    pub(crate) fn insert(
        &mut self,
        connection_id: Token,
        stream_id: StreamId,
        index: usize,
    ) -> bool {
        self.entries
            .try_insert(
                Self::hash(connection_id, stream_id),
                TaskMapEntry {
                    connection_id,
                    stream_id,
                    index: index as u32,
                },
                |entry| entry.connection_id == connection_id && entry.stream_id == stream_id,
            )
            .is_ok()
    }

    pub(crate) fn remove(&mut self, connection_id: Token, stream_id: StreamId) -> Option<usize> {
        self.entries
            .remove(Self::hash(connection_id, stream_id), |entry| {
                entry.connection_id == connection_id && entry.stream_id == stream_id
            })
            .map(|entry| entry.index as usize)
    }

    pub(crate) fn get(&self, connection_id: Token, stream_id: StreamId) -> Option<usize> {
        self.entries
            .get(Self::hash(connection_id, stream_id), |entry| {
                entry.connection_id == connection_id && entry.stream_id == stream_id
            })
            .map(|entry| entry.index as usize)
    }

    pub(crate) fn is_empty(&self) -> bool {
        self.entries.is_empty()
    }
}