Changeset View
Changeset View
Standalone View
Standalone View
test/functional/feature_maxuploadtarget.py
| Show First 20 Lines • Show All 93 Lines • ▼ Show 20 Lines | def run_test(self): | ||||
| max_bytes_per_day = 200 * 1024 * 1024 | max_bytes_per_day = 200 * 1024 * 1024 | ||||
| daily_buffer = 144 * LEGACY_MAX_BLOCK_SIZE | daily_buffer = 144 * LEGACY_MAX_BLOCK_SIZE | ||||
| max_bytes_available = max_bytes_per_day - daily_buffer | max_bytes_available = max_bytes_per_day - daily_buffer | ||||
| success_count = max_bytes_available // old_block_size | success_count = max_bytes_available // old_block_size | ||||
| # 144MB will be reserved for relaying new blocks, so expect this to | # 144MB will be reserved for relaying new blocks, so expect this to | ||||
| # succeed for ~70 tries. | # succeed for ~70 tries. | ||||
| for i in range(success_count): | for i in range(success_count): | ||||
| p2p_conns[0].send_message(getdata_request) | p2p_conns[0].send_and_ping(getdata_request) | ||||
| p2p_conns[0].sync_with_ping() | |||||
| assert_equal(p2p_conns[0].block_receive_map[big_old_block], i + 1) | assert_equal(p2p_conns[0].block_receive_map[big_old_block], i + 1) | ||||
| assert_equal(len(self.nodes[0].getpeerinfo()), 3) | assert_equal(len(self.nodes[0].getpeerinfo()), 3) | ||||
| # At most a couple more tries should succeed (depending on how long | # At most a couple more tries should succeed (depending on how long | ||||
| # the test has been running so far). | # the test has been running so far). | ||||
| for i in range(3): | for i in range(3): | ||||
| p2p_conns[0].send_message(getdata_request) | p2p_conns[0].send_message(getdata_request) | ||||
| p2p_conns[0].wait_for_disconnect() | p2p_conns[0].wait_for_disconnect() | ||||
| assert_equal(len(self.nodes[0].getpeerinfo()), 2) | assert_equal(len(self.nodes[0].getpeerinfo()), 2) | ||||
| self.log.info( | self.log.info( | ||||
| "Peer 0 disconnected after downloading old block too many times") | "Peer 0 disconnected after downloading old block too many times") | ||||
| # Requesting the current block on p2p_conns[1] should succeed indefinitely, | # Requesting the current block on p2p_conns[1] should succeed indefinitely, | ||||
| # even when over the max upload target. | # even when over the max upload target. | ||||
| # We'll try 200 times | # We'll try 200 times | ||||
| getdata_request.inv = [CInv(2, big_new_block)] | getdata_request.inv = [CInv(2, big_new_block)] | ||||
| for i in range(200): | for i in range(200): | ||||
| p2p_conns[1].send_message(getdata_request) | p2p_conns[1].send_and_ping(getdata_request) | ||||
| p2p_conns[1].sync_with_ping() | |||||
| assert_equal(p2p_conns[1].block_receive_map[big_new_block], i + 1) | assert_equal(p2p_conns[1].block_receive_map[big_new_block], i + 1) | ||||
| self.log.info("Peer 1 able to repeatedly download new block") | self.log.info("Peer 1 able to repeatedly download new block") | ||||
| # But if p2p_conns[1] tries for an old block, it gets disconnected | # But if p2p_conns[1] tries for an old block, it gets disconnected | ||||
| # too. | # too. | ||||
| getdata_request.inv = [CInv(2, big_old_block)] | getdata_request.inv = [CInv(2, big_old_block)] | ||||
| p2p_conns[1].send_message(getdata_request) | p2p_conns[1].send_message(getdata_request) | ||||
| p2p_conns[1].wait_for_disconnect() | p2p_conns[1].wait_for_disconnect() | ||||
| assert_equal(len(self.nodes[0].getpeerinfo()), 1) | assert_equal(len(self.nodes[0].getpeerinfo()), 1) | ||||
| self.log.info("Peer 1 disconnected after trying to download old block") | self.log.info("Peer 1 disconnected after trying to download old block") | ||||
| self.log.info("Advancing system time on node to clear counters...") | self.log.info("Advancing system time on node to clear counters...") | ||||
| # If we advance the time by 24 hours, then the counters should reset, | # If we advance the time by 24 hours, then the counters should reset, | ||||
| # and p2p_conns[2] should be able to retrieve the old block. | # and p2p_conns[2] should be able to retrieve the old block. | ||||
| self.nodes[0].setmocktime(int(time.time())) | self.nodes[0].setmocktime(int(time.time())) | ||||
| p2p_conns[2].sync_with_ping() | p2p_conns[2].sync_with_ping() | ||||
| p2p_conns[2].send_message(getdata_request) | p2p_conns[2].send_and_ping(getdata_request) | ||||
| p2p_conns[2].sync_with_ping() | |||||
| assert_equal(p2p_conns[2].block_receive_map[big_old_block], 1) | assert_equal(p2p_conns[2].block_receive_map[big_old_block], 1) | ||||
| self.log.info("Peer 2 able to download old block") | self.log.info("Peer 2 able to download old block") | ||||
| self.nodes[0].disconnect_p2ps() | self.nodes[0].disconnect_p2ps() | ||||
| # stop and start node 0 with 1MB maxuploadtarget, whitelist 127.0.0.1 | # stop and start node 0 with 1MB maxuploadtarget, whitelist 127.0.0.1 | ||||
| self.log.info("Restarting nodes with -whitelist=127.0.0.1") | self.log.info("Restarting nodes with -whitelist=127.0.0.1") | ||||
| self.stop_node(0) | self.stop_node(0) | ||||
| self.start_node(0, ["-whitelist=127.0.0.1", | self.start_node(0, ["-whitelist=127.0.0.1", | ||||
| "-maxuploadtarget=1", "-blockmaxsize=999000"]) | "-maxuploadtarget=1", "-blockmaxsize=999000"]) | ||||
| # Reconnect to self.nodes[0] | # Reconnect to self.nodes[0] | ||||
| self.nodes[0].add_p2p_connection(TestP2PConn()) | self.nodes[0].add_p2p_connection(TestP2PConn()) | ||||
| # retrieve 20 blocks which should be enough to break the 1MB limit | # retrieve 20 blocks which should be enough to break the 1MB limit | ||||
| getdata_request.inv = [CInv(2, big_new_block)] | getdata_request.inv = [CInv(2, big_new_block)] | ||||
| for i in range(20): | for i in range(20): | ||||
| self.nodes[0].p2p.send_message(getdata_request) | self.nodes[0].p2p.send_and_ping(getdata_request) | ||||
| self.nodes[0].p2p.sync_with_ping() | |||||
| assert_equal( | assert_equal( | ||||
| self.nodes[0].p2p.block_receive_map[big_new_block], i + 1) | self.nodes[0].p2p.block_receive_map[big_new_block], i + 1) | ||||
| getdata_request.inv = [CInv(2, big_old_block)] | getdata_request.inv = [CInv(2, big_old_block)] | ||||
| self.nodes[0].p2p.send_and_ping(getdata_request) | self.nodes[0].p2p.send_and_ping(getdata_request) | ||||
| # node is still connected because of the whitelist | # node is still connected because of the whitelist | ||||
| assert_equal(len(self.nodes[0].getpeerinfo()), 1) | assert_equal(len(self.nodes[0].getpeerinfo()), 1) | ||||
| self.log.info( | self.log.info( | ||||
| "Peer still connected after trying to download old block (whitelisted)") | "Peer still connected after trying to download old block (whitelisted)") | ||||
| if __name__ == '__main__': | if __name__ == '__main__': | ||||
| MaxUploadTest().main() | MaxUploadTest().main() | ||||