aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm/peer.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-24 16:18:58 +0200
committertv <tv@krebsco.de>2026-10-24 16:18:58 +0200
commit2044eba5744be090d9a8111a91fc2589770f9e7a (patch)
tree21bbf8b43198e9ad92cfb2c5a86a9a306720a9ca /src/swarm/peer.rs
parentd816121dfe51f8ffbc36c93bbd52be21272482cd (diff)
add chunked download and use it during rejoin
Diffstat (limited to 'src/swarm/peer.rs')
-rw-r--r--src/swarm/peer.rs3
1 files changed, 3 insertions, 0 deletions
diff --git a/src/swarm/peer.rs b/src/swarm/peer.rs
index 3b85539..dd70bbb 100644
--- a/src/swarm/peer.rs
+++ b/src/swarm/peer.rs
@@ -824,6 +824,9 @@ pub(crate) async fn handle_message(
debug!(peer = %peer, error = %format!("{error:#}"), "PONG failed");
}
}
+ transport::ParsedMessage::Blob(blob) => {
+ crate::swarm::blob::handle(state, &peer, blob).await;
+ }
transport::ParsedMessage::Pong(remote) => {
state.lock_rtt().pong_received(&peer, Instant::now());
if reactivated || peer_swarm(state, &peer).await.is_none() {