packet loss phase start msg

Author: kavehtehrani

src/engine/mod.rs

@@ -355,13 +355,9 @@ impl TestEngine {
             cancel.clone(),
         )
         .await?;
-
-        event_tx
-            .send(TestEvent::PhaseStarted {
-                phase: Phase::PacketLoss,
-            })
-            .await
-            .ok();
+        // Note: PhaseStarted::PacketLoss is emitted from inside the upload function
+        // the moment its tick loop ends, so the dashboard can switch immediately
+        // without waiting for upload-task drain.
 
         let mut experimental_udp = None;
         let mut udp_error = None;

src/engine/throughput.rs

@@ -335,6 +335,16 @@ pub async fn run_upload_with_loaded_latency(
         tokio::time::sleep(Duration::from_millis(200)).await;
     }
 
+    // Tick loop has ended — from the user's perspective the upload phase is over.
+    // Announce the next phase now so the dashboard updates immediately, even though
+    // the worker drain and latency probe await below may take a moment.
+    event_tx
+        .send(TestEvent::PhaseStarted {
+            phase: Phase::PacketLoss,
+        })
+        .await
+        .ok();
+
     stop.store(true, Ordering::Relaxed);
     for h in handles {
         let _ = h.await;

src/tui/dashboard.rs

@@ -491,10 +491,12 @@ pub fn draw_dashboard(area: Rect, f: &mut Frame, state: &UiState) {
             udp_inner,
         );
     } else {
-        f.render_widget(
-            Paragraph::new("Packet loss probe starts after upload phase..."),
-            udp_inner,
-        );
+        let msg = if state.phase == crate::model::Phase::PacketLoss {
+            "Packet loss probe starting..."
+        } else {
+            "Packet loss probe starts after upload phase..."
+        };
+        f.render_widget(Paragraph::new(msg), udp_inner);
     }
 
     // Network Information and Keyboard Shortcuts side-by-side