aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm/peer
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-11-06 14:29:42 +0100
committertv <tv@krebsco.de>2026-11-06 14:29:42 +0100
commitd6f6c7aad904e650e6c7371dbd4776f6f0be2388 (patch)
treec4cf94b5099e3ea31faddc7356459337127eb3f3 /src/swarm/peer
parent43305f5a0e2a87c68405989600b33e33c1ab70df (diff)
indirect probes
Diffstat (limited to 'src/swarm/peer')
-rw-r--r--src/swarm/peer/inbound.rs6
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(_)