Skip to content

Commit

Permalink
Add more comments about the queue size etc.
Browse files Browse the repository at this point in the history
  • Loading branch information
rklaehn committed Mar 13, 2024
1 parent 84b03ad commit a383f32
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 0 deletions.
2 changes: 2 additions & 0 deletions iroh-bytes/src/store/bao_file.rs
Original file line number Diff line number Diff line change
Expand Up @@ -468,6 +468,8 @@ pub struct BaoFileHandle {
pub(crate) storage: Arc<RwLock<BaoFileStorage>>,
config: Arc<BaoFileConfig>,
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,
}
Expand Down
2 changes: 2 additions & 0 deletions iroh-bytes/src/store/file.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand Down

0 comments on commit a383f32

Please sign in to comment.