Changeset View
Changeset View
Standalone View
Standalone View
test/functional/test_framework/mininode.py
Show All 14 Lines | |||||
from collections import defaultdict | from collections import defaultdict | ||||
from io import BytesIO | from io import BytesIO | ||||
import logging | import logging | ||||
import socket | import socket | ||||
import struct | import struct | ||||
import sys | import sys | ||||
import threading | import threading | ||||
from test_framework.messages import * | from test_framework.messages import ( | ||||
MIN_VERSION_SUPPORTED, | |||||
msg_addr, | |||||
msg_block, | |||||
msg_blocktxn, | |||||
msg_cmpctblock, | |||||
msg_feefilter, | |||||
msg_getaddr, | |||||
msg_getblocks, | |||||
msg_getblocktxn, | |||||
msg_getdata, | |||||
msg_getheaders, | |||||
msg_headers, | |||||
msg_inv, | |||||
msg_mempool, | |||||
msg_ping, | |||||
msg_pong, | |||||
msg_reject, | |||||
msg_sendcmpct, | |||||
msg_sendheaders, | |||||
msg_tx, | |||||
msg_verack, | |||||
msg_version, | |||||
NODE_NETWORK, | |||||
READ_BUFFER_SIZE, | |||||
sha256, | |||||
) | |||||
from test_framework.util import wait_until | from test_framework.util import wait_until | ||||
logger = logging.getLogger("TestFramework.mininode") | logger = logging.getLogger("TestFramework.mininode") | ||||
MESSAGEMAP = { | MESSAGEMAP = { | ||||
b"addr": msg_addr, | b"addr": msg_addr, | ||||
b"block": msg_block, | b"block": msg_block, | ||||
b"blocktxn": msg_blocktxn, | b"blocktxn": msg_blocktxn, | ||||
▲ Show 20 Lines • Show All 467 Lines • Show Last 20 Lines |