diff options
| author | tv <tv@krebsco.de> | 2026-11-06 14:29:42 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-06 14:29:42 +0100 |
| commit | d6f6c7aad904e650e6c7371dbd4776f6f0be2388 (patch) | |
| tree | c4cf94b5099e3ea31faddc7356459337127eb3f3 /src/swarm/peer | |
| parent | 43305f5a0e2a87c68405989600b33e33c1ab70df (diff) | |
indirect probes
Diffstat (limited to 'src/swarm/peer')
| -rw-r--r-- | src/swarm/peer/inbound.rs | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/swarm/peer/inbound.rs b/src/swarm/peer/inbound.rs index 9b701b5..7154357 100644 --- a/src/swarm/peer/inbound.rs +++ b/src/swarm/peer/inbound.rs @@ -248,6 +248,12 @@ pub(crate) async fn handle_message( transport::ParsedMessage::LinksReply(reply) => { crate::swarm::links::received(state, &peer, reply); } + transport::ParsedMessage::Probe(request) => { + crate::swarm::working_links::answer(state, &peer, request).await; + } + transport::ParsedMessage::ProbeReply(reply) => { + crate::swarm::working_links::answered(state, &peer, reply); + } transport::ParsedMessage::Who(_) | transport::ParsedMessage::Me(_) | transport::ParsedMessage::Ping(_) |
