Add PieceProvider::get_from_cache() that supports connected peers a…

…nd retrieving pieces more efficiently in batches
autonomys · Oct 14, 2024 · 81751cf · 81751cf
1 parent 2a2d3e8
commit 81751cf
Show file tree

Hide file tree

Showing 5 changed files with 605 additions and 7 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/subspace-networking/Cargo.toml b/crates/subspace-networking/Cargo.toml
@@ -44,6 +44,7 @@ subspace-core-primitives = { version = "0.1.0", path = "../subspace-core-primiti
 subspace-metrics = { version = "0.1.0", path = "../../shared/subspace-metrics" }
 thiserror = "1.0.64"
 tokio = { version = "1.40.0", features = ["macros", "parking_lot", "rt-multi-thread", "signal", "sync", "time"] }
+tokio-stream = "0.1.16"
 tracing = "0.1.40"
 tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
 unsigned-varint = { version = "0.8.0", features = ["futures", "asynchronous_codec"] }

diff --git a/crates/subspace-networking/src/lib.rs b/crates/subspace-networking/src/lib.rs
@@ -15,6 +15,7 @@
 
 //! Networking functionality of Subspace Network, primarily used for DSN (Distributed Storage
 //! Network).
+
 #![feature(const_option, impl_trait_in_assoc_type, ip, try_blocks)]
 #![warn(missing_docs)]