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
//! Decoded `RESP(STATS)`: delivery and telemetry counters (§4.6).
/// Firmware delivery and telemetry counters (§4.6).
///
/// Narrowed fields saturate, so a maxed counter never wraps to a small value. The three drop
/// counters are full width and never saturate: a count that stopped rising would hide ongoing loss.
/// [`session`](Self::session) wraps for the same reason.
///
/// Act on [`tx_drops`](Self::tx_drops), [`link_rx_drops`](Self::link_rx_drops) and
/// [`host_rx_drops`](Self::host_rx_drops): each counts the player's input going missing and should
/// read 0. [`relay_drops`](Self::relay_drops) is relayed traffic and commands that went no further, none
/// of it native input.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
pub struct Stats {
/// Pure-injection reports emitted (the no-halving / 1 kHz path).
pub inject_emits: u32,
/// Reports the clone's TX queue could not hold: player input the game PC never saw. Should
/// stay 0.
pub tx_drops: u16,
/// Backed-up reports merged instead of queued.
pub tx_merges: u16,
/// Deepest the TX queue has reached.
pub tx_maxdepth: u8,
/// Wedged-endpoint recoveries by the watchdog.
pub tx_wedges: u8,
/// Remote-wakeups issued.
pub wakeups: u16,
/// USB bus resets seen.
pub reset_count: u16,
/// `SET_CONFIGURATION` events (re-enumerations).
pub config_count: u16,
/// Input-carrying frames the clone-serving chip could not take off the inter-chip link: each a
/// mouse report or injected delta that never reached the wire. Should stay 0.
pub link_rx_drops: u32,
/// Same count for the chip reading the real device, relayed over the link.
pub host_rx_drops: u32,
/// Relayed traffic and commands that went no further: a vendor IN packet that found its endpoint's queue
/// full of the control PC's `RAW` packets, or a device's zero-length packet answering a poll the PC did
/// not make (the one poll the box runs ahead of a suspended PC); an OUT packet the box could not
/// queue, that failed three times on the device's bus, or that a bus reset or `SET_INTERFACE`
/// overtook; a relayed request or a flagged `MOVE` the box could not queue; and any frame other than
/// native input that either chip's link receive ring dropped. Counted apart from `tx_drops` because no
/// native input goes missing with it.
pub relay_drops: u32,
/// Times the box released host-set session state (locks, held input, subscriptions, rules,
/// transforms, the clip, an LED override). Wraps, so compare for inequality; 0 at boot. The crate
/// watches it and re-sends all of that but the LED.
pub session: u16,
}
impl Stats {
/// Decodes a `RESP(STATS)` payload (§4.6).
pub(crate) fn from_payload(p: &[u8]) -> Option<Self> {
if p.len() < 31 {
return None;
}
Some(Stats {
inject_emits: u32::from_le_bytes([p[1], p[2], p[3], p[4]]),
tx_drops: u16::from_le_bytes([p[5], p[6]]),
tx_merges: u16::from_le_bytes([p[7], p[8]]),
tx_maxdepth: p[9],
tx_wedges: p[10],
wakeups: u16::from_le_bytes([p[11], p[12]]),
reset_count: u16::from_le_bytes([p[13], p[14]]),
config_count: u16::from_le_bytes([p[15], p[16]]),
link_rx_drops: u32::from_le_bytes([p[17], p[18], p[19], p[20]]),
host_rx_drops: u32::from_le_bytes([p[21], p[22], p[23], p[24]]),
relay_drops: u32::from_le_bytes([p[25], p[26], p[27], p[28]]),
session: u16::from_le_bytes([p[29], p[30]]),
})
}
}