Signed-off-by: Ian Jackson <ijackson@chiark.greenend.org.uk>
let mut rx_queue: FrameQueue = default();
- async {
+ let trouble = async {
loop {
let rx_queue_space =
if rx_queue.remaining() < ic.max_batch_down.sat() {
},
}
}
- }.await
+ }.await;
+
+ drop(tx_stream);
+
+ match ipif.wait().await {
+ Err(e) => error!("{}: also, failed to await ipif child: {}", &ic, e),
+ Ok(st) if st.success() => { },
+ Ok(st) => error!("{}: ipif process failed: {}", &ic, st),
+ }
+
+ trouble
}
#[tokio::main]