From db3c4e997f03a660ac37a6bdf86c6215726a71bd Mon Sep 17 00:00:00 2001 From: tv Date: Wed, 28 Oct 2026 01:47:47 +0100 Subject: rename PING/PONG to STATUS/STATUS_REPLY --- src/simtest/identity.rs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'src/simtest/identity.rs') diff --git a/src/simtest/identity.rs b/src/simtest/identity.rs index ec5d665..b789bda 100644 --- a/src/simtest/identity.rs +++ b/src/simtest/identity.rs @@ -15,7 +15,7 @@ use crate::swarm::members; use crate::transport::identity::{WHO_LABEL, signed}; use crate::transport::sim::SimNet; use crate::transport::{ - Destination, HeadsSummary, IdentityProof, Keepalive, ParsedMessage, Transport, + Destination, HeadsSummary, IdentityProof, ParsedMessage, Status, Transport, }; const SOON: Duration = Duration::from_secs(20); @@ -97,8 +97,8 @@ async fn members_find_each_other_through_the_member_list() { } } -fn ping(node: &AppState) -> ParsedMessage { - ParsedMessage::Ping(Keepalive { +fn status(node: &AppState) -> ParsedMessage { + ParsedMessage::Status(Status { heads: HeadsSummary::of(Vec::new()), epoch: node.local_epoch(), epoch_seq: 0, @@ -129,7 +129,7 @@ async fn a_proof_holds_only_at_its_address() { who(&ghost, "sim:ghost", "sim:b"), ] { sim.net.inject("ghost", "a", &forged).await.unwrap(); - sim.net.inject("ghost", "a", &ping(&a)).await.unwrap(); + sim.net.inject("ghost", "a", &status(&a)).await.unwrap(); assert!(a.get_peer_state(&ghost.id()).await.is_none()); } let counts = a.transport.stats().identity.unwrap().counts; @@ -140,7 +140,7 @@ async fn a_proof_holds_only_at_its_address() { .inject("ghost", "a", &who(&ghost, "sim:ghost", "sim:a")) .await .unwrap(); - sim.net.inject("ghost", "a", &ping(&a)).await.unwrap(); + sim.net.inject("ghost", "a", &status(&a)).await.unwrap(); assert!(a.get_peer_state(&ghost.id()).await.is_some()); // Known by its node ID, not by its address. assert!(a.get_peer_state("ghost").await.is_none()); -- cgit v1.3.1