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
|
#
# SPDX-FileCopyrightText: 2016 - 2026 Dimitri Staessens
# SPDX-License-Identifier: LGPL-2.1-only
#
"""
QoS specification for Ouroboros flows.
"""
from __future__ import annotations
from dataclasses import dataclass
from enum import IntEnum
DEFAULT_PEER_TIMEOUT = 120000
UINT32_MAX = 0xFFFFFFFF
UINT64_MAX = 0xFFFFFFFFFFFFFFFF
class QoSService(IntEnum):
"""
Mirrors ``enum qos_service`` in ``ouroboros/qos.h``.
"""
RAW = 0 # No FRCT; best-effort raw messages
MESSAGE = 1 # FRCT, reliable ordered messages
STREAM = 2 # FRCT, reliable ordered byte stream
@dataclass(frozen=True)
class QoSSpec:
"""
QoS specification for a flow.
:ivar service: :class:`QoSService` (gates FRCT when > 0).
:ivar delay: Maximum one-way delay in ms.
:ivar bandwidth: Required bandwidth in bits/s.
:ivar availability: Class of 9s (number of nines of uptime).
:ivar loss: Maximum packet loss (per million).
:ivar ber: Maximum bit error rate (errors per billion).
:ivar max_gap: Maximum interruption in ms.
:ivar timeout: Peer timeout in ms (default 120000 ms).
"""
service: QoSService = QoSService.RAW
delay: int = UINT32_MAX
bandwidth: int = 0
availability: int = 0
loss: int = 1
ber: int = 1
max_gap: int = UINT32_MAX
timeout: int = DEFAULT_PEER_TIMEOUT
# Predefined QoS specs, mirroring the static const qosspec_t values in
# ouroboros/qos.h. "_safe" sets ber=0 (integrity check); "rt" trades
# reliability for latency.
QOS_RAW = QoSSpec(
service=QoSService.RAW,
delay=UINT32_MAX, bandwidth=0, availability=0,
loss=1, ber=1,
max_gap=UINT32_MAX, timeout=0)
QOS_RAW_SAFE = QoSSpec(
service=QoSService.RAW,
delay=UINT32_MAX, bandwidth=0, availability=0,
loss=1, ber=0,
max_gap=UINT32_MAX, timeout=0)
QOS_RT = QoSSpec(
service=QoSService.MESSAGE,
delay=100, bandwidth=UINT64_MAX, availability=3,
loss=1, ber=1,
max_gap=100, timeout=DEFAULT_PEER_TIMEOUT)
QOS_RT_SAFE = QoSSpec(
service=QoSService.MESSAGE,
delay=100, bandwidth=UINT64_MAX, availability=3,
loss=1, ber=0,
max_gap=100, timeout=DEFAULT_PEER_TIMEOUT)
QOS_MSG = QoSSpec(
service=QoSService.MESSAGE,
delay=1000, bandwidth=0, availability=0,
loss=0, ber=0,
max_gap=2000, timeout=DEFAULT_PEER_TIMEOUT)
QOS_STREAM = QoSSpec(
service=QoSService.STREAM,
delay=1000, bandwidth=0, availability=0,
loss=0, ber=0,
max_gap=2000, timeout=DEFAULT_PEER_TIMEOUT)
|
