ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2026-08-21 06:10:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: Clean up pong replies

Browse Source
This commit is contained in:
Bart
2026-07-16 16:25:00 -04:00
committed by Ayaz Salikhov
parent 4a9ee54c88
commit 5ab95748d4
2 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
include/xrpl/proto/xrpl.proto
View File

@@ -293,14 +293,15 @@ message TMLedgerData {
}
message TMPing {
// Previously used - don't reuse.
reserved 3, 4;
enum pingType {
ptPING = 0; // we want a reply
ptPONG = 1; // this is a reply
}
required pingType type = 1;
optional uint32 seq = 2; // detect stale replies, ensure other side is reading
optional uint64 pingTime = 3; // know when we think we sent the ping
optional uint64 netTime = 4;
optional uint32 seq = 2; // detect stale replies, ensure other side is reading
}
message TMSquelch {

9
src/xrpld/overlay/detail/PeerImp.cpp
View File

@@ -1113,10 +1113,13 @@ PeerImp::onMessage(std::shared_ptr<protocol::TMPing> const& m)
{
if (m->type() == protocol::TMPing::ptPING)
{
// We have received a ping request, reply with a pong
// We have received a ping request, reply with a pong.
fee_.update(Resource::kFeeModerateBurdenPeer, "ping request");
m->set_type(protocol::TMPing::ptPONG);
send(std::make_shared<Message>(*m, protocol::mtPING));
protocol::TMPing pong;
pong.set_type(protocol::TMPing::ptPONG);
if (m->has_seq())
pong.set_seq(m->seq());
send(std::make_shared<Message>(pong, protocol::mtPING));
return;
}