Changeset View
Changeset View
Standalone View
Standalone View
test/functional/p2p-leaktests.py
| Show First 20 Lines • Show All 141 Lines • ▼ Show 20 Lines | def run_test(self): | ||||
| self.nodes[0].generate(1) | self.nodes[0].generate(1) | ||||
| # Give the node enough time to possibly leak out a message | # Give the node enough time to possibly leak out a message | ||||
| time.sleep(5) | time.sleep(5) | ||||
| # This node should have been banned | # This node should have been banned | ||||
| assert not no_version_bannode.connected | assert not no_version_bannode.connected | ||||
| for _ in range(3): | self.nodes[0].disconnect_p2ps() | ||||
| self.nodes[0].disconnect_p2p() | |||||
| # Wait until all connections are closed | # Wait until all connections are closed | ||||
| wait_until(lambda: len(self.nodes[0].getpeerinfo()) == 0) | wait_until(lambda: len(self.nodes[0].getpeerinfo()) == 0) | ||||
| # Make sure no unexpected messages came in | # Make sure no unexpected messages came in | ||||
| assert(no_version_bannode.unexpected_msg == False) | assert(no_version_bannode.unexpected_msg == False) | ||||
| assert(no_version_idlenode.unexpected_msg == False) | assert(no_version_idlenode.unexpected_msg == False) | ||||
| assert(no_verack_idlenode.unexpected_msg == False) | assert(no_verack_idlenode.unexpected_msg == False) | ||||
| if __name__ == '__main__': | if __name__ == '__main__': | ||||
| P2PLeakTest().main() | P2PLeakTest().main() | ||||