s2n-quic-dc 0.44.0

Internal crate used by s2n-quic
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

// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0

use crate::{credentials, packet::stream};
use core::time::Duration;
use s2n_quic_core::{packet::number::PacketNumber, probe, varint::VarInt};

probe::define!(
    extern "probe" {
        /// Called when a control packet is received
        #[link_name = s2n_quic_dc__stream__send__control_packet]
        pub fn on_control_packet(
            credential_id: credentials::Id,
            stream_id: stream::Id,
            packet_number: VarInt,
            control_data_len: usize,
        );

        /// Called when a control packet is decrypted
        #[link_name = s2n_quic_dc__stream__send__control_packet_decrypted]
        pub fn on_control_packet_decrypted(
            credential_id: credentials::Id,
            stream_id: stream::Id,
            packet_number: VarInt,
            control_data_len: usize,
            valid: bool,
        );

        /// Called when a control packet was dropped due to being a duplicate
        #[link_name = s2n_quic_dc__stream__send__control_packet_decrypted]
        pub fn on_control_packet_duplicate(
            credential_id: credentials::Id,
            stream_id: stream::Id,
            packet_number: VarInt,
            control_data_len: usize,
        );

        /// Called when a packet was ACK'd
        #[link_name = s2n_quic_dc__stream__send__packet_ack]
        pub fn on_packet_ack(
            credential_id: credentials::Id,
            stream_id: stream::Id,
            packet_space: stream::PacketSpace,
            packet_number: u64,
            packet_len: u16,
            stream_offset: VarInt,
            payload_len: u16,
            lifetime: Duration,
        );

        /// Called when a packet was lost
        #[link_name = s2n_quic_dc__stream__send__packet_lost]
        pub fn on_packet_lost(
            credential_id: credentials::Id,
            stream_id: stream::Id,
            packet_space: stream::PacketSpace,
            packet_number: u64,
            packet_len: u16,
            stream_offset: VarInt,
            payload_len: u16,
            lifetime: Duration,
            needs_retransmission: bool,
        );

        /// Called when a packet was ACK'd
        #[link_name = s2n_quic_dc__stream__send__pto_backoff_reset]
        pub fn on_pto_backoff_reset(
            credential_id: credentials::Id,
            stream_id: stream::Id,
            previous_value: u32,
        );

        /// Called when the PTO timer is armed
        #[link_name = s2n_quic_dc__stream__send__pto_armed]
        pub fn on_pto_armed(
            credential_id: credentials::Id,
            stream_id: stream::Id,
            pto_period: Duration,
            pto_backoff: u32,
        );

        /// Called when a range of stream bytes are transmitted
        #[link_name = s2n_quic_dc__stream__send__transmit_stream]
        pub fn on_transmit_stream(
            credential_id: credentials::Id,
            stream_id: stream::Id,
            packet_space: stream::PacketSpace,
            packet_number: PacketNumber,
            stream_offset: VarInt,
            payload_len: u16,
            included_fin: bool,
            is_retransmission: bool,
        );

        /// Called when a range of stream bytes are transmitted as a probe
        #[link_name = s2n_quic_dc__stream__send__transmit_probe]
        pub fn on_transmit_probe(
            credential_id: credentials::Id,
            stream_id: stream::Id,
            packet_space: stream::PacketSpace,
            packet_number: PacketNumber,
            stream_offset: VarInt,
            payload_len: u16,
            included_fin: bool,
            is_retransmission: bool,
        );

        /// Called when a control packet is received
        #[link_name = s2n_quic_dc__stream__send__close]
        pub fn on_close(
            credential_id: credentials::Id,
            stream_id: stream::Id,
            packet_number: VarInt,
            error_code: VarInt,
        );
    }
);