| 147 | } |
| 148 | |
| 149 | pub fn record_accessibility_snapshot(&self, duration_ms: u64, ok: bool, timed_out: bool) { |
| 150 | self.accessibility_snapshots.fetch_add(1, Ordering::Relaxed); |
| 151 | self.latest_accessibility_snapshot_ms |
| 152 | .store(duration_ms, Ordering::Relaxed); |
| 153 | update_max(&self.max_accessibility_snapshot_ms, duration_ms); |
| 154 | if !ok { |
| 155 | self.accessibility_snapshot_errors |
| 156 | .fetch_add(1, Ordering::Relaxed); |
| 157 | } |
| 158 | if timed_out { |
| 159 | self.accessibility_snapshot_timeouts |
| 160 | .fetch_add(1, Ordering::Relaxed); |
| 161 | } |
| 162 | if duration_ms >= 2_000 { |
| 163 | self.accessibility_snapshot_slow |
| 164 | .fetch_add(1, Ordering::Relaxed); |
| 165 | } |
| 166 | } |
| 167 | |
| 168 | pub fn record_client_stream_stats(&self, stats: ClientStreamStats) { |
| 169 | let mut snapshots = self |