|
|
|
@ -100,8 +100,8 @@ class MempoolPersistTest(BitcoinTestFramework):
|
|
|
|
|
|
|
|
|
|
# disconnect nodes & make a txn that remains in the unbroadcast set.
|
|
|
|
|
self.disconnect_nodes(0, 1)
|
|
|
|
|
assert(len(self.nodes[0].getpeerinfo()) == 0)
|
|
|
|
|
assert(len(self.nodes[0].p2ps) == 0)
|
|
|
|
|
assert_equal(len(self.nodes[0].getpeerinfo()), 0)
|
|
|
|
|
assert_equal(len(self.nodes[0].p2ps), 0)
|
|
|
|
|
self.mini_wallet.send_self_transfer(from_node=self.nodes[0])
|
|
|
|
|
self.connect_nodes(0, 2)
|
|
|
|
|
|
|
|
|
@ -178,8 +178,8 @@ class MempoolPersistTest(BitcoinTestFramework):
|
|
|
|
|
|
|
|
|
|
# ensure node0 doesn't have any connections
|
|
|
|
|
# make a transaction that will remain in the unbroadcast set
|
|
|
|
|
assert(len(node0.getpeerinfo()) == 0)
|
|
|
|
|
assert(len(node0.p2ps) == 0)
|
|
|
|
|
assert_equal(len(node0.getpeerinfo()), 0)
|
|
|
|
|
assert_equal(len(node0.p2ps), 0)
|
|
|
|
|
self.mini_wallet.send_self_transfer(from_node=node0)
|
|
|
|
|
|
|
|
|
|
# shutdown, then startup with wallet disabled
|
|
|
|
@ -187,8 +187,9 @@ class MempoolPersistTest(BitcoinTestFramework):
|
|
|
|
|
|
|
|
|
|
# check that txn gets broadcast due to unbroadcast logic
|
|
|
|
|
conn = node0.add_p2p_connection(P2PTxInvStore())
|
|
|
|
|
node0.mockscheduler(16*60) # 15 min + 1 for buffer
|
|
|
|
|
node0.mockscheduler(16 * 60) # 15 min + 1 for buffer
|
|
|
|
|
self.wait_until(lambda: len(conn.get_invs()) == 1)
|
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
|
|
|
|
|
|
|
if __name__ == "__main__":
|
|
|
|
|
MempoolPersistTest().main()
|
|
|
|
|