mirror of
https://github.com/wownero/wownero.git
synced 2026-10-22 18:08:34 +02:00
Fix ZMQ-PUB reporting of mempool txes that were initially in stem phase
This commit is contained in:
committed by
Lee *!* Clagett
parent
f99ee72d4b
commit
05eb7a212e
@@ -1138,7 +1138,7 @@ namespace cryptonote
|
|||||||
const bool res = m_mempool.add_tx(tx, tx_hash, blob, tx_weight, tvc, tx_relay, relayed, version);
|
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 new incoming tx passed verification and entered the pool, notify ZMQ
|
||||||
if (!tvc.m_verifivation_failed && tvc.m_added_to_pool && matches_category(tx_relay, relay_category::legacy))
|
if (!tvc.m_verifivation_failed && res && matches_category(tx_relay, relay_category::legacy))
|
||||||
{
|
{
|
||||||
m_blockchain_storage.notify_txpool_event({txpool_event{
|
m_blockchain_storage.notify_txpool_event({txpool_event{
|
||||||
.tx = tx,
|
.tx = tx,
|
||||||
|
|||||||
@@ -116,6 +116,8 @@ namespace cryptonote
|
|||||||
* @tx_relay how the transaction was received
|
* @tx_relay how the transaction was received
|
||||||
* @param tx_weight the transaction's weight
|
* @param tx_weight the transaction's weight
|
||||||
* @param valid_input_verification_id a previously valid verID if non-null
|
* @param valid_input_verification_id a previously valid verID if non-null
|
||||||
|
* @return True if tx passes verification checks AND is first observation
|
||||||
|
* of tx in `broadcasted` relay method.
|
||||||
*/
|
*/
|
||||||
bool add_tx(transaction &tx, const crypto::hash &id, const cryptonote::blobdata &blob,
|
bool add_tx(transaction &tx, const crypto::hash &id, const cryptonote::blobdata &blob,
|
||||||
size_t tx_weight, tx_verification_context& tvc, relay_method tx_relay, bool relayed,
|
size_t tx_weight, tx_verification_context& tvc, relay_method tx_relay, bool relayed,
|
||||||
@@ -144,7 +146,8 @@ namespace cryptonote
|
|||||||
* passes the non-input consensus tests (e.g. for newly received relayed txs), then leave
|
* passes the non-input consensus tests (e.g. for newly received relayed txs), then leave
|
||||||
* "nic_verified_hf_version" as its default value of 0 (there is no v0 fork).
|
* "nic_verified_hf_version" as its default value of 0 (there is no v0 fork).
|
||||||
*
|
*
|
||||||
* @return true if the transaction passes validations, otherwise false
|
* @return True if tx passes verification checks AND is first observation
|
||||||
|
* of tx in `broadcasted` relay method.
|
||||||
*/
|
*/
|
||||||
bool add_tx(transaction &tx, tx_verification_context& tvc, relay_method tx_relay, bool relayed,
|
bool add_tx(transaction &tx, tx_verification_context& tvc, relay_method tx_relay, bool relayed,
|
||||||
uint8_t version, uint8_t nic_verified_hf_version = 0,
|
uint8_t version, uint8_t nic_verified_hf_version = 0,
|
||||||
|
|||||||
Reference in New Issue
Block a user