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

fix: Always charge peer on strand

Browse Source
This commit is contained in:
Bart
2026-06-06 17:52:00 -04:00
parent 949887feb9
commit 2a73e11f51
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -392,8 +392,14 @@ PeerImp::removeTxQueue(uint256 const& hash)
void
PeerImp::charge(Resource::Charge const& fee, std::string const& context)
{
if (!strand_.running_in_this_thread())
{
post(strand_, [self = shared_from_this(), fee, context]() { self->charge(fee, context); });
return;
}
if ((usage_.charge(fee, context) == Resource::Disposition::Drop) &&
usage_.disconnect(pJournal_) && strand_.running_in_this_thread())
usage_.disconnect(pJournal_))
{
// Sever the connection
overlay_.incPeerDisconnectCharges();