mirror of
https://github.com/bitcoin/bitcoin.git
synced 2025-11-21 03:21:56 +01:00
test: Update test framework p2p protocol version to 70016
This new p2p protocol version allows to use WTXIDs for tx relay.
This commit is contained in:
committed by
Suhas Daftuar
parent
dd78d1d641
commit
9a5392fdf6
@@ -59,6 +59,8 @@ from test_framework.messages import (
|
||||
MSG_TYPE_MASK,
|
||||
msg_verack,
|
||||
msg_version,
|
||||
MSG_WTX,
|
||||
msg_wtxidrelay,
|
||||
NODE_NETWORK,
|
||||
NODE_WITNESS,
|
||||
sha256,
|
||||
@@ -96,6 +98,7 @@ MESSAGEMAP = {
|
||||
b"tx": msg_tx,
|
||||
b"verack": msg_verack,
|
||||
b"version": msg_version,
|
||||
b"wtxidrelay": msg_wtxidrelay,
|
||||
}
|
||||
|
||||
MAGIC_BYTES = {
|
||||
@@ -356,6 +359,7 @@ class P2PInterface(P2PConnection):
|
||||
def on_sendcmpct(self, message): pass
|
||||
def on_sendheaders(self, message): pass
|
||||
def on_tx(self, message): pass
|
||||
def on_wtxidrelay(self, message): pass
|
||||
|
||||
def on_inv(self, message):
|
||||
want = msg_getdata()
|
||||
@@ -654,7 +658,7 @@ class P2PTxInvStore(P2PInterface):
|
||||
super().on_inv(message) # Send getdata in response.
|
||||
# Store how many times invs have been received for each tx.
|
||||
for i in message.inv:
|
||||
if i.type == MSG_TX:
|
||||
if (i.type == MSG_TX) or (i.type == MSG_WTX):
|
||||
# save txid
|
||||
self.tx_invs_received[i.hash] += 1
|
||||
|
||||
|
||||
Reference in New Issue
Block a user