From 9dfcdb47a7af32ea99d201a38bfbe311e23f7f4b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Patryk=20B=C4=99za?= Date: Fri, 16 Jan 2026 14:38:42 +0100 Subject: [PATCH] feat(p2p): introduce new EchoPing and EchoPong message types Fixes #1781 --- crates/node/src/p2p.rs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/crates/node/src/p2p.rs b/crates/node/src/p2p.rs index b170fdf50d..3cd5396f78 100644 --- a/crates/node/src/p2p.rs +++ b/crates/node/src/p2p.rs @@ -99,6 +99,8 @@ impl Drop for DropToCancel { #[derive(BorshSerialize, BorshDeserialize)] enum Packet { Ping, + EchoPing(u64), + EchoPong(u64), MpcMessage(MpcMessage), IndexerHeight(IndexerHeightMessage), } @@ -427,8 +429,9 @@ pub async fn new_tls_mesh_network( let packet = Packet::try_from_slice(&buf) .context("Failed to deserialize packet")?; match packet { - Packet::Ping => { + Packet::Ping | Packet::EchoPing(_) | Packet::EchoPong(_) => { // Do nothing. Pings are just for TCP keepalive. + // EchoPing/EchoPong are recognized but ignored until https://github.com/near/mpc/pull/1687 is merged. } Packet::MpcMessage(mpc_message) => { message_sender.send(PeerMessage::Mpc(MpcPeerMessage {