aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm/peer
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-11-06 16:47:32 +0100
committertv <tv@krebsco.de>2026-11-06 16:47:32 +0100
commitab8f5447680da56ce658abbc33c222219c3204ef (patch)
tree93ed572d120cf29b7e440c31194bafd021e8a5a6 /src/swarm/peer
parent7c0f90b327ad567c4e5e6a96cda433d774182dac (diff)
plumtree
Diffstat (limited to 'src/swarm/peer')
-rw-r--r--src/swarm/peer/inbound.rs12
1 files changed, 12 insertions, 0 deletions
diff --git a/src/swarm/peer/inbound.rs b/src/swarm/peer/inbound.rs
index 7154357..ddcc376 100644
--- a/src/swarm/peer/inbound.rs
+++ b/src/swarm/peer/inbound.rs
@@ -254,6 +254,18 @@ pub(crate) async fn handle_message(
transport::ParsedMessage::ProbeReply(reply) => {
crate::swarm::working_links::answered(state, &peer, reply);
}
+ transport::ParsedMessage::Prune(link) => {
+ state
+ .dissemination
+ .linked(state, &peer, link.writer, false)
+ .await;
+ }
+ transport::ParsedMessage::Graft(link) => {
+ state
+ .dissemination
+ .linked(state, &peer, link.writer, true)
+ .await;
+ }
transport::ParsedMessage::Who(_)
| transport::ParsedMessage::Me(_)
| transport::ParsedMessage::Ping(_)