(self)
| 476 | # queued message, ignoring the proper order. This ensures that if any |
| 477 | # messages are actually lost, that the message queue will be orderly flushed. |
| 478 | def print_timed_out_messages(self): |
| 479 | global last_message_time |
| 480 | with http_mutex: |
| 481 | now = tick() |
| 482 | max_message_queue_time = 5 |
| 483 | if len(self.http_message_queue) and now - last_message_time > max_message_queue_time: |
| 484 | self.print_next_message() |
| 485 | |
| 486 | # Skips to printing the next message in queue now, independent of whether |
| 487 | # there was missed messages in the sequence numbering. |
no test coverage detected