aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorj-berman <justinberman@protonmail.com>2026-04-15 16:42:29 -0700
committerj-berman <justinberman@protonmail.com>2026-04-24 09:03:45 -0700
commit7d5e4842a4876d1b9a60ceddd412c3e168770036 (patch)
tree0fcbd79ee04d9858d2ede1087e9f0a8c007b5ded /src
parent7879d9b68b278f8e9e72955cf6fe9fe3369ba1be (diff)
downloadmonzero-core-7d5e4842a4876d1b9a60ceddd412c3e168770036.tar.gz
monzero-core-7d5e4842a4876d1b9a60ceddd412c3e168770036.tar.xz
monzero-core-7d5e4842a4876d1b9a60ceddd412c3e168770036.zip
tx_pool: notify txpool event when stem bumps to fluff
Diffstat (limited to 'src')
-rw-r--r--src/cryptonote_core/cryptonote_core.cpp2
-rw-r--r--src/cryptonote_core/tx_pool.cpp8
2 files changed, 5 insertions, 5 deletions
diff --git a/src/cryptonote_core/cryptonote_core.cpp b/src/cryptonote_core/cryptonote_core.cpp
index b80fba05c..8063405de 100644
--- a/src/cryptonote_core/cryptonote_core.cpp
+++ b/src/cryptonote_core/cryptonote_core.cpp
@@ -1089,7 +1089,7 @@ namespace cryptonote
const bool res = m_mempool.add_tx(tx, tx_hash, blob, tx_weight, tvc, tx_relay, relayed, version);
// If new incoming tx passed verification and entered the pool, notify ZMQ
- if (!tvc.m_verifivation_failed && res && matches_category(tx_relay, relay_category::legacy))
+ if (!tvc.m_verifivation_failed && res && matches_category(tvc.m_relay, relay_category::legacy))
{
m_blockchain_storage.notify_txpool_event({txpool_event{
.tx = tx,
diff --git a/src/cryptonote_core/tx_pool.cpp b/src/cryptonote_core/tx_pool.cpp
index 3bc508037..badcde361 100644
--- a/src/cryptonote_core/tx_pool.cpp
+++ b/src/cryptonote_core/tx_pool.cpp
@@ -337,16 +337,16 @@ namespace cryptonote
MERROR("internal error: error adding transaction to txpool: " << e.what());
return false;
}
-
- static_assert(unsigned(relay_method::none) == 0, "expected relay_method::none value to be zero");
- if(meta.fee > 0 && tx_relay != relay_method::forward)
- tvc.m_relay = tx_relay;
}
tvc.m_verifivation_failed = false;
if (tvc.m_added_to_pool)
m_txpool_weight += tx_weight;
+ static_assert(unsigned(relay_method::none) == 0, "expected relay_method::none value to be zero");
+ if (meta.fee > 0 && tx_relay != relay_method::forward)
+ tvc.m_relay = tx_relay;
+
++m_cookie;
MINFO("Transaction added to pool: txid " << id << " weight: " << tx_weight << " fee/byte: " << (fee / (double)(tx_weight ? tx_weight : 1)) << ", count: " << m_added_txs_by_id.size());