queue debug

Signed-off-by: Ian Jackson <ijackson@chiark.greenend.org.uk>

diff --git a/src/bin/client.rs b/src/bin/client.rs
index 1af2d305302586334600bd0d5d301342b9d7c5fd..e21020cc2c2c6fb77ddde43c1b4a0b7ab234eb80 100644 (file)
--- a/src/bin/client.rs
+++ b/src/bin/client.rs
@@ -256,7 +256,7 @@ async fn run_client<C:HCC>(
               Ok(())
             }, |e| error!("{} #{}: rx discarding: {}", &ic, req_num, e));
           
-            dbg!(&rx_queue.remaining());
+            dbg!(&rx_queue);
             rx_queue = default(); // xxx
           }
         }

diff --git a/src/queue.rs b/src/queue.rs
index a7e0bb51fa2f4ba7e67e73242f990df069b91009..21be105f86f7aeddf59fcceb5da7458e5aedab24 100644 (file)
--- a/src/queue.rs
+++ b/src/queue.rs
@@ -11,6 +11,16 @@ pub struct Queue {
   queue: VecDeque<Box<[u8]>>,
 }
 
+impl Debug for Queue {
+  #[throws(fmt::Error)]
+  fn fmt(&self, f: &mut fmt::Formatter) {
+    write!(f, "Queue{{content={},eaten1={},queue=[",
+           self.content, self.eaten1)?;
+    for q in &self.queue { write!(f, "{},", q.len())?; }
+    write!(f, "]}}")?;
+  }
+}
+
 impl Queue {
   pub fn push<B: Into<Box<[u8]>>>(&mut self, b: B) {
     self.push_(b.into());