@ -11,9 +11,7 @@ from test_framework.p2p import P2PTxInvStore
from test_framework . test_framework import BitcoinTestFramework
from test_framework . test_framework import BitcoinTestFramework
from test_framework . util import (
from test_framework . util import (
assert_equal ,
assert_equal ,
connect_nodes ,
create_confirmed_utxos ,
create_confirmed_utxos ,
disconnect_nodes ,
)
)
MAX_INITIAL_BROADCAST_DELAY = 15 * 60 # 15 minutes in seconds
MAX_INITIAL_BROADCAST_DELAY = 15 * 60 # 15 minutes in seconds
@ -36,7 +34,7 @@ class MempoolUnbroadcastTest(BitcoinTestFramework):
min_relay_fee = node . getnetworkinfo ( ) [ " relayfee " ]
min_relay_fee = node . getnetworkinfo ( ) [ " relayfee " ]
utxos = create_confirmed_utxos ( min_relay_fee , node , 10 )
utxos = create_confirmed_utxos ( min_relay_fee , node , 10 )
disconnect_nodes ( node , 1 )
self . disconnect_nodes ( 0 , 1 )
self . log . info ( " Generate transactions that only node 0 knows about " )
self . log . info ( " Generate transactions that only node 0 knows about " )
@ -70,7 +68,7 @@ class MempoolUnbroadcastTest(BitcoinTestFramework):
self . restart_node ( 0 )
self . restart_node ( 0 )
self . log . info ( " Reconnect nodes & check if they are sent to node 1 " )
self . log . info ( " Reconnect nodes & check if they are sent to node 1 " )
connect_nodes ( node , 1 )
self . connect_nodes ( 0 , 1 )
# fast forward into the future & ensure that the second node has the txns
# fast forward into the future & ensure that the second node has the txns
node . mockscheduler ( MAX_INITIAL_BROADCAST_DELAY )
node . mockscheduler ( MAX_INITIAL_BROADCAST_DELAY )
@ -91,7 +89,7 @@ class MempoolUnbroadcastTest(BitcoinTestFramework):
time . sleep ( 2 ) # allow sufficient time for possibility of broadcast
time . sleep ( 2 ) # allow sufficient time for possibility of broadcast
assert_equal ( len ( conn . get_invs ( ) ) , 0 )
assert_equal ( len ( conn . get_invs ( ) ) , 0 )
disconnect_nodes ( node , 1 )
self . disconnect_nodes ( 0 , 1 )
node . disconnect_p2ps ( )
node . disconnect_p2ps ( )
def test_txn_removal ( self ) :
def test_txn_removal ( self ) :