Changeset View
Changeset View
Standalone View
Standalone View
test/functional/p2p_timeouts.py
| Show First 20 Lines • Show All 45 Lines • ▼ Show 20 Lines | def run_test(self): | ||||
| TestP2PConn(), send_version=False) | TestP2PConn(), send_version=False) | ||||
| no_send_node = self.nodes[0].add_p2p_connection( | no_send_node = self.nodes[0].add_p2p_connection( | ||||
| TestP2PConn(), send_version=False) | TestP2PConn(), send_version=False) | ||||
| network_thread_start() | network_thread_start() | ||||
| sleep(1) | sleep(1) | ||||
| assert no_verack_node.connected | assert no_verack_node.is_connected | ||||
| assert no_version_node.connected | assert no_version_node.is_connected | ||||
| assert no_send_node.connected | assert no_send_node.is_connected | ||||
| no_verack_node.send_message(msg_ping()) | no_verack_node.send_message(msg_ping()) | ||||
| no_version_node.send_message(msg_ping()) | no_version_node.send_message(msg_ping()) | ||||
| sleep(30) | sleep(30) | ||||
| assert "version" in no_verack_node.last_message | assert "version" in no_verack_node.last_message | ||||
| assert no_verack_node.connected | assert no_verack_node.is_connected | ||||
| assert no_version_node.connected | assert no_version_node.is_connected | ||||
| assert no_send_node.connected | assert no_send_node.is_connected | ||||
| no_verack_node.send_message(msg_ping()) | no_verack_node.send_message(msg_ping()) | ||||
| no_version_node.send_message(msg_ping()) | no_version_node.send_message(msg_ping()) | ||||
| sleep(31) | sleep(31) | ||||
| assert not no_verack_node.connected | assert not no_verack_node.is_connected | ||||
| assert not no_version_node.connected | assert not no_version_node.is_connected | ||||
| assert not no_send_node.connected | assert not no_send_node.is_connected | ||||
| if __name__ == '__main__': | if __name__ == '__main__': | ||||
| TimeoutsTest().main() | TimeoutsTest().main() | ||||