Ensure ProcessMessages is called on this connection
(self, timeout=60)
| 552 | self.sync_with_ping() |
| 553 | |
| 554 | def sync_with_ping(self, timeout=60): |
| 555 | """Ensure ProcessMessages is called on this connection""" |
| 556 | self.send_message(msg_ping(nonce=self.ping_counter)) |
| 557 | |
| 558 | def test_function(): |
| 559 | return self.last_message.get("pong") and self.last_message["pong"].nonce == self.ping_counter |
| 560 | |
| 561 | self.wait_until(test_function, timeout=timeout) |
| 562 | self.ping_counter += 1 |
| 563 | |
| 564 | |
| 565 | # One lock for synchronizing all data access between the network event loop (see |