@@ -43,6 +43,7 @@ bool TxOrphanage::AddTx(const CTransactionRef& tx, NodeId peer)
43
43
m_outpoint_to_orphan_it[txin.prevout ].insert (ret.first );
44
44
}
45
45
m_total_orphan_usage += sz;
46
+ m_total_announcements += 1 ;
46
47
auto & peer_info = m_peer_orphanage_info.try_emplace (peer).first ->second ;
47
48
peer_info.m_total_usage += sz;
48
49
@@ -60,6 +61,7 @@ bool TxOrphanage::AddAnnouncer(const Wtxid& wtxid, NodeId peer)
60
61
if (ret.second ) {
61
62
auto & peer_info = m_peer_orphanage_info.try_emplace (peer).first ->second ;
62
63
peer_info.m_total_usage += it->second .GetUsage ();
64
+ m_total_announcements += 1 ;
63
65
LogDebug (BCLog::TXPACKAGES, " added peer=%d as announcer of orphan tx %s\n " , peer, wtxid.ToString ());
64
66
return true ;
65
67
}
@@ -84,6 +86,7 @@ int TxOrphanage::EraseTx(const Wtxid& wtxid)
84
86
85
87
const auto tx_size{it->second .GetUsage ()};
86
88
m_total_orphan_usage -= tx_size;
89
+ m_total_announcements -= it->second .announcers .size ();
87
90
// Decrement each announcer's m_total_usage
88
91
for (const auto & peer : it->second .announcers ) {
89
92
auto peer_it = m_peer_orphanage_info.find (peer);
@@ -126,6 +129,7 @@ void TxOrphanage::EraseForPeer(NodeId peer)
126
129
auto orphan_it = orphan.announcers .find (peer);
127
130
if (orphan_it != orphan.announcers .end ()) {
128
131
orphan.announcers .erase (peer);
132
+ m_total_announcements -= 1 ;
129
133
130
134
// No remaining announcers: clean up entry
131
135
if (orphan.announcers .empty ()) {
0 commit comments