From a383f32bdd2b8fac534a2e66c1ab35b0158682e5 Mon Sep 17 00:00:00 2001 From: Ruediger Klaehn Date: Wed, 13 Mar 2024 16:58:44 +0200 Subject: [PATCH] Add more comments about the queue size etc. --- iroh-bytes/src/store/bao_file.rs | 2 ++ iroh-bytes/src/store/file.rs | 2 ++ 2 files changed, 4 insertions(+) diff --git a/iroh-bytes/src/store/bao_file.rs b/iroh-bytes/src/store/bao_file.rs index 72bac88e2c..4ebfae03ad 100644 --- a/iroh-bytes/src/store/bao_file.rs +++ b/iroh-bytes/src/store/bao_file.rs @@ -468,6 +468,8 @@ pub struct BaoFileHandle { pub(crate) storage: Arc>, config: Arc, hash: Hash, + /// An unqiue id for the handle, used for ensuring that a handle is dropped + /// and recreated in tests. #[cfg(test)] pub(crate) id: u64, } diff --git a/iroh-bytes/src/store/file.rs b/iroh-bytes/src/store/file.rs index e15687437f..ecebcc3c69 100644 --- a/iroh-bytes/src/store/file.rs +++ b/iroh-bytes/src/store/file.rs @@ -1369,6 +1369,8 @@ impl Actor { let tables = Tables::new(&txn)?; drop(tables); txn.commit()?; + // make the channel relatively large. there are some messages that don't + // require a response, it's fine if they pile up a bit. let (tx, rx) = flume::bounded(1024); let tx2 = tx.clone(); let tx3 = tx.clone();