From 55b968aa1d70955ad593a83bde24b01bce5db747 Mon Sep 17 00:00:00 2001
From: Ian Jackson <ijackson@chiark.greenend.org.uk>
Date: Wed, 4 Aug 2021 23:30:05 +0100
Subject: [PATCH] enforce tx queue expiry

Signed-off-by: Ian Jackson <ijackson@chiark.greenend.org.uk>
---
 src/bin/client.rs | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/src/bin/client.rs b/src/bin/client.rs
index a1cdce4..d82496e 100644
--- a/src/bin/client.rs
+++ b/src/bin/client.rs
@@ -230,6 +230,15 @@ async fn run_client<C:HCC>(
           let () = y.context("write rx data to ipif")?;
         },
 
+        () = async {
+          let expires = tx_queue.front().unwrap().expires;
+          tokio::time::sleep_until(expires).await
+        },
+        if ! tx_queue.is_empty() =>
+        {
+          let _ = tx_queue.pop_front();
+        },
+
         data = tx_stream.next_segment(),
         if tx_queue.is_empty() =>
         {
-- 
2.30.2