mirror of
https://github.com/bitcoin/bitcoin.git
synced 2025-02-23 12:33:26 -05:00
1973a9e4f1
p2p_ibd_txrelay expects no GETDATA to have been received by a peer after announcing a transaction. The reason is that the node is doing IBD, so transaction requests are not replied to. However, the way this is checked is wrong, and the check will pass even if the node **was not** in IBD. This is due to the mocktime not being properly initialized, so the check is always performed earlier than it should, making it impossible for the request to be there
91 lines
3.8 KiB
Python
Executable file
91 lines
3.8 KiB
Python
Executable file
#!/usr/bin/env python3
|
|
# Copyright (c) 2020-2021 The Bitcoin Core developers
|
|
# Distributed under the MIT software license, see the accompanying
|
|
# file COPYING or http://www.opensource.org/licenses/mit-license.php.
|
|
"""Test transaction relay behavior during IBD:
|
|
- Set fee filters to MAX_MONEY
|
|
- Don't request transactions
|
|
- Ignore all transaction messages
|
|
"""
|
|
|
|
from decimal import Decimal
|
|
import time
|
|
|
|
from test_framework.messages import (
|
|
CInv,
|
|
COIN,
|
|
CTransaction,
|
|
from_hex,
|
|
msg_inv,
|
|
msg_tx,
|
|
MSG_WTX,
|
|
)
|
|
from test_framework.p2p import (
|
|
NONPREF_PEER_TX_DELAY,
|
|
P2PDataStore,
|
|
P2PInterface,
|
|
p2p_lock
|
|
)
|
|
from test_framework.test_framework import BitcoinTestFramework
|
|
|
|
MAX_FEE_FILTER = Decimal(9170997) / COIN
|
|
NORMAL_FEE_FILTER = Decimal(100) / COIN
|
|
|
|
|
|
class P2PIBDTxRelayTest(BitcoinTestFramework):
|
|
def set_test_params(self):
|
|
self.setup_clean_chain = True
|
|
self.num_nodes = 2
|
|
self.extra_args = [
|
|
["-minrelaytxfee={}".format(NORMAL_FEE_FILTER)],
|
|
["-minrelaytxfee={}".format(NORMAL_FEE_FILTER)],
|
|
]
|
|
|
|
def run_test(self):
|
|
self.log.info("Check that nodes set minfilter to MAX_MONEY while still in IBD")
|
|
for node in self.nodes:
|
|
assert node.getblockchaininfo()['initialblockdownload']
|
|
self.wait_until(lambda: all(peer['minfeefilter'] == MAX_FEE_FILTER for peer in node.getpeerinfo()))
|
|
|
|
self.nodes[0].setmocktime(int(time.time()))
|
|
|
|
self.log.info("Check that nodes don't send getdatas for transactions while still in IBD")
|
|
peer_inver = self.nodes[0].add_p2p_connection(P2PDataStore())
|
|
txid = 0xdeadbeef
|
|
peer_inver.send_and_ping(msg_inv([CInv(t=MSG_WTX, h=txid)]))
|
|
# The node should not send a getdata, but if it did, it would first delay 2 seconds
|
|
self.nodes[0].bumpmocktime(NONPREF_PEER_TX_DELAY)
|
|
peer_inver.sync_with_ping()
|
|
with p2p_lock:
|
|
assert txid not in peer_inver.getdata_requests
|
|
self.nodes[0].disconnect_p2ps()
|
|
|
|
self.log.info("Check that nodes don't process unsolicited transactions while still in IBD")
|
|
# A transaction hex pulled from tx_valid.json. There are no valid transactions since no UTXOs
|
|
# exist yet, but it should be a well-formed transaction.
|
|
rawhex = "0100000001b14bdcbc3e01bdaad36cc08e81e69c82e1060bc14e518db2b49aa43ad90ba260000000004a01ff473" + \
|
|
"04402203f16c6f40162ab686621ef3000b04e75418a0c0cb2d8aebeac894ae360ac1e780220ddc15ecdfc3507ac48e168" + \
|
|
"1a33eb60996631bf6bf5bc0a0682c4db743ce7ca2b01ffffffff0140420f00000000001976a914660d4ef3a743e3e696a" + \
|
|
"d990364e555c271ad504b88ac00000000"
|
|
assert self.nodes[1].decoderawtransaction(rawhex) # returns a dict, should not throw
|
|
tx = from_hex(CTransaction(), rawhex)
|
|
peer_txer = self.nodes[0].add_p2p_connection(P2PInterface())
|
|
with self.nodes[0].assert_debug_log(expected_msgs=["received: tx"], unexpected_msgs=["was not accepted"]):
|
|
peer_txer.send_and_ping(msg_tx(tx))
|
|
self.nodes[0].disconnect_p2ps()
|
|
|
|
# Come out of IBD by generating a block
|
|
self.generate(self.nodes[0], 1)
|
|
|
|
self.log.info("Check that nodes reset minfilter after coming out of IBD")
|
|
for node in self.nodes:
|
|
assert not node.getblockchaininfo()['initialblockdownload']
|
|
self.wait_until(lambda: all(peer['minfeefilter'] == NORMAL_FEE_FILTER for peer in node.getpeerinfo()))
|
|
|
|
self.log.info("Check that nodes process the same transaction, even when unsolicited, when no longer in IBD")
|
|
peer_txer = self.nodes[0].add_p2p_connection(P2PInterface())
|
|
with self.nodes[0].assert_debug_log(expected_msgs=["was not accepted"]):
|
|
peer_txer.send_and_ping(msg_tx(tx))
|
|
|
|
if __name__ == '__main__':
|
|
P2PIBDTxRelayTest(__file__).main()
|