diff options
author | Anthony Towns <aj@erisian.com.au> | 2018-01-25 09:44:29 +1000 |
---|---|---|
committer | Anthony Towns <aj@erisian.com.au> | 2018-01-25 09:44:29 +1000 |
commit | 61b8f7f273022d3163f998ff5d66d53ca0460c8b (patch) | |
tree | f0c697967c9a15ea61758170af0cd0418ab34585 /test/functional/p2p_timeouts.py | |
parent | 90600bc7db2a8047c93bc10d403e862141ada770 (diff) | |
download | bitcoin-61b8f7f273022d3163f998ff5d66d53ca0460c8b.tar.xz |
[tests] Rename p2p_* functional tests.
Diffstat (limited to 'test/functional/p2p_timeouts.py')
-rwxr-xr-x | test/functional/p2p_timeouts.py | 75 |
1 files changed, 75 insertions, 0 deletions
diff --git a/test/functional/p2p_timeouts.py b/test/functional/p2p_timeouts.py new file mode 100755 index 0000000000..6d21095cc6 --- /dev/null +++ b/test/functional/p2p_timeouts.py @@ -0,0 +1,75 @@ +#!/usr/bin/env python3 +# Copyright (c) 2016-2017 The Bitcoin Core developers +# Distributed under the MIT software license, see the accompanying +# file COPYING or http://www.opensource.org/licenses/mit-license.php. +"""Test various net timeouts. + +- Create three bitcoind nodes: + + no_verack_node - we never send a verack in response to their version + no_version_node - we never send a version (only a ping) + no_send_node - we never send any P2P message. + +- Start all three nodes +- Wait 1 second +- Assert that we're connected +- Send a ping to no_verack_node and no_version_node +- Wait 30 seconds +- Assert that we're still connected +- Send a ping to no_verack_node and no_version_node +- Wait 31 seconds +- Assert that we're no longer connected (timeout to receive version/verack is 60 seconds) +""" + +from time import sleep + +from test_framework.mininode import * +from test_framework.test_framework import BitcoinTestFramework +from test_framework.util import * + +class TestNode(P2PInterface): + def on_version(self, message): + # Don't send a verack in response + pass + +class TimeoutsTest(BitcoinTestFramework): + def set_test_params(self): + self.setup_clean_chain = True + self.num_nodes = 1 + + def run_test(self): + # Setup the p2p connections and start up the network thread. + no_verack_node = self.nodes[0].add_p2p_connection(TestNode()) + no_version_node = self.nodes[0].add_p2p_connection(TestNode(), send_version=False) + no_send_node = self.nodes[0].add_p2p_connection(TestNode(), send_version=False) + + network_thread_start() + + sleep(1) + + assert no_verack_node.connected + assert no_version_node.connected + assert no_send_node.connected + + no_verack_node.send_message(msg_ping()) + no_version_node.send_message(msg_ping()) + + sleep(30) + + assert "version" in no_verack_node.last_message + + assert no_verack_node.connected + assert no_version_node.connected + assert no_send_node.connected + + no_verack_node.send_message(msg_ping()) + no_version_node.send_message(msg_ping()) + + sleep(31) + + assert not no_verack_node.connected + assert not no_version_node.connected + assert not no_send_node.connected + +if __name__ == '__main__': + TimeoutsTest().main() |