Changeset View
Changeset View
Standalone View
Standalone View
test/functional/test_framework/mininode.py
| Show All 21 Lines | |||||
| import threading | import threading | ||||
| from test_framework.messages import ( | from test_framework.messages import ( | ||||
| CBlockHeader, | CBlockHeader, | ||||
| MIN_VERSION_SUPPORTED, | MIN_VERSION_SUPPORTED, | ||||
| msg_addr, | msg_addr, | ||||
| msg_avapoll, | msg_avapoll, | ||||
| msg_tcpavaresponse, | msg_tcpavaresponse, | ||||
| msg_avahello, | |||||
| msg_block, | msg_block, | ||||
| MSG_BLOCK, | MSG_BLOCK, | ||||
| msg_blocktxn, | msg_blocktxn, | ||||
| msg_cfcheckpt, | msg_cfcheckpt, | ||||
| msg_cfheaders, | msg_cfheaders, | ||||
| msg_cfilter, | msg_cfilter, | ||||
| msg_cmpctblock, | msg_cmpctblock, | ||||
| msg_feefilter, | msg_feefilter, | ||||
| Show All 25 Lines | |||||
| 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"avapoll": msg_avapoll, | b"avapoll": msg_avapoll, | ||||
| b"avaresponse": msg_tcpavaresponse, | b"avaresponse": msg_tcpavaresponse, | ||||
| b"avahello": msg_avahello, | |||||
| b"block": msg_block, | b"block": msg_block, | ||||
| b"blocktxn": msg_blocktxn, | b"blocktxn": msg_blocktxn, | ||||
| b"cfcheckpt": msg_cfcheckpt, | b"cfcheckpt": msg_cfcheckpt, | ||||
| b"cfheaders": msg_cfheaders, | b"cfheaders": msg_cfheaders, | ||||
| b"cfilter": msg_cfilter, | b"cfilter": msg_cfilter, | ||||
| b"cmpctblock": msg_cmpctblock, | b"cmpctblock": msg_cmpctblock, | ||||
| b"feefilter": msg_feefilter, | b"feefilter": msg_feefilter, | ||||
| b"filteradd": msg_filteradd, | b"filteradd": msg_filteradd, | ||||
| ▲ Show 20 Lines • Show All 250 Lines • ▼ Show 20 Lines | def peer_connect(self, *args, services=NODE_NETWORK, | ||||
| if send_version: | if send_version: | ||||
| # Send a version msg | # Send a version msg | ||||
| vt = msg_version() | vt = msg_version() | ||||
| vt.nServices = services | vt.nServices = services | ||||
| vt.addrTo.ip = self.dstaddr | vt.addrTo.ip = self.dstaddr | ||||
| vt.addrTo.port = self.dstport | vt.addrTo.port = self.dstport | ||||
| vt.addrFrom.ip = "0.0.0.0" | vt.addrFrom.ip = "0.0.0.0" | ||||
| vt.addrFrom.port = 0 | vt.addrFrom.port = 0 | ||||
| # Will be sent soon after connection_made | # Will be sent soon after connection_made | ||||
| self.on_connection_send_msg = vt | self.on_connection_send_msg = vt | ||||
| return create_conn | return create_conn | ||||
| # Message receiving methods | # Message receiving methods | ||||
| def on_message(self, message): | def on_message(self, message): | ||||
| Show All 22 Lines | def on_close(self): | ||||
| pass | pass | ||||
| def on_addr(self, message): pass | def on_addr(self, message): pass | ||||
| def on_avapoll(self, message): pass | def on_avapoll(self, message): pass | ||||
| def on_avaresponse(self, message): pass | def on_avaresponse(self, message): pass | ||||
| def on_avahello(self, message): pass | |||||
| def on_block(self, message): pass | def on_block(self, message): pass | ||||
| def on_blocktxn(self, message): pass | def on_blocktxn(self, message): pass | ||||
| def on_cfcheckpt(self, message): pass | def on_cfcheckpt(self, message): pass | ||||
| def on_cfheaders(self, message): pass | def on_cfheaders(self, message): pass | ||||
| ▲ Show 20 Lines • Show All 353 Lines • Show Last 20 Lines | |||||