diff options
| author | tv <tv@krebsco.de> | 2026-11-06 16:47:32 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-06 16:47:32 +0100 |
| commit | ab8f5447680da56ce658abbc33c222219c3204ef (patch) | |
| tree | 93ed572d120cf29b7e440c31194bafd021e8a5a6 /src/swarm/peer | |
| parent | 7c0f90b327ad567c4e5e6a96cda433d774182dac (diff) | |
plumtree
Diffstat (limited to 'src/swarm/peer')
| -rw-r--r-- | src/swarm/peer/inbound.rs | 12 |
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(_) |
