streamtop 1.5.0

Terminal HLS, DASH, and IPTV stream monitor with wire probes, TR 101 290, SCTE-35, and Prometheus metrics
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

//! Passive transport anomaly hints from timing (read-only heuristics).

use crate::models::DiagnosticReasonCode;

#[derive(Debug, Clone, Copy, Default)]
pub struct MiddleboxHints {
    pub tcp_reset_suspected: bool,
}

impl MiddleboxHints {
    pub fn reason_code(self) -> Option<&'static str> {
        if self.tcp_reset_suspected {
            Some(DiagnosticReasonCode::ErrTcpIoReset.as_str())
        } else {
            None
        }
    }
}

/// Heuristic: TCP connect succeeded but transfer ended before any bytes with I/O error class.
pub fn classify_transport_failure(
    connected: bool,
    bytes_received: u64,
    io_error: bool,
) -> MiddleboxHints {
    MiddleboxHints {
        tcp_reset_suspected: connected && bytes_received == 0 && io_error,
    }
}