Changeset View
Changeset View
Standalone View
Standalone View
test/functional/test_framework/mininode.py
| Show First 20 Lines • Show All 463 Lines • ▼ Show 20 Lines | def sync_with_ping(self, timeout=60): | ||||
| def test_function(): | def test_function(): | ||||
| if not self.last_message.get("pong"): | if not self.last_message.get("pong"): | ||||
| return False | return False | ||||
| return self.last_message["pong"].nonce == self.ping_counter | return self.last_message["pong"].nonce == self.ping_counter | ||||
| wait_until(test_function, timeout=timeout, lock=mininode_lock) | wait_until(test_function, timeout=timeout, lock=mininode_lock) | ||||
| self.ping_counter += 1 | self.ping_counter += 1 | ||||
| # One lock for synchronizing all data access between the network event loop (see | # One lock for synchronizing all data access between the networking thread (see | ||||
| # NetworkThread below) and the thread running the test logic. For simplicity, | # NetworkThread below) and the thread running the test logic. For simplicity, | ||||
| # P2PConnection acquires this lock whenever delivering a message to a P2PInterface. | # P2PConnection acquires this lock whenever delivering a message to a P2PInterface. | ||||
| # This lock should be acquired in the thread running the test logic to synchronize | # This lock should be acquired in the thread running the test logic to synchronize | ||||
| # access to any data shared with the P2PInterface or P2PConnection. | # access to any data shared with the P2PInterface or P2PConnection. | ||||
| mininode_lock = threading.RLock() | mininode_lock = threading.RLock() | ||||
| class NetworkThread(threading.Thread): | class NetworkThread(threading.Thread): | ||||
| ▲ Show 20 Lines • Show All 153 Lines • Show Last 20 Lines | |||||