Add frame stats to for path status frames (#94)

Author: flub

quinn-proto/src/connection/mod.rs

@@ -4143,7 +4143,7 @@ impl Connection {
                 error_code,
             }
             .encode(buf);
-            // TODO(flub): frame stats?
+            self.stats.frame_tx.path_abandon += 1;
         }
 
         // PATH_AVAILABLE & PATH_BACKUP
@@ -4164,6 +4164,7 @@ impl Connection {
                         status_seq_no: seq,
                     }
                     .encode(buf);
+                    self.stats.frame_tx.path_available += 1;
                     trace!(?path_id, %seq, "PATH_AVAILABLE")
                 }
                 PathStatus::Backup => {
@@ -4172,10 +4173,10 @@ impl Connection {
                         status_seq_no: seq,
                     }
                     .encode(buf);
+                    self.stats.frame_tx.path_backup += 1;
                     trace!(?path_id, %seq, "PATH_BACKUP")
                 }
             }
-            // TODO(flub): frame stats?
         }
 
         // RESET_STREAM, STOP_SENDING, MAX_DATA, MAX_STREAM_DATA, MAX_STREAMS

quinn-proto/src/tests/multipath.rs

@@ -110,4 +110,16 @@ fn path_status() {
         server_conn.remote_path_status(PathId::ZERO).unwrap(),
         PathStatus::Backup
     );
+
+    let client_stats = pair.client_conn_mut(client_ch).stats();
+    assert_eq!(client_stats.frame_tx.path_available, 0);
+    assert_eq!(client_stats.frame_tx.path_backup, 1);
+    assert_eq!(client_stats.frame_rx.path_available, 0);
+    assert_eq!(client_stats.frame_rx.path_backup, 0);
+
+    let server_stats = pair.server_conn_mut(server_ch).stats();
+    assert_eq!(server_stats.frame_tx.path_available, 0);
+    assert_eq!(server_stats.frame_tx.path_backup, 0);
+    assert_eq!(server_stats.frame_rx.path_available, 0);
+    assert_eq!(server_stats.frame_rx.path_backup, 1);
 }