(self, seq_num, log, data)
| 453 | http_message_queue = [] |
| 454 | |
| 455 | def handle_incoming_message(self, seq_num, log, data): |
| 456 | global have_received_messages |
| 457 | with http_mutex: |
| 458 | have_received_messages = True |
| 459 | |
| 460 | if seq_num == -1: |
| 461 | # Message arrived without a sequence number? Just log immediately |
| 462 | log(data) |
| 463 | elif seq_num == self.expected_http_seq_num: |
| 464 | log(data) |
| 465 | self.expected_http_seq_num += 1 |
| 466 | self.print_messages_due() |
| 467 | elif seq_num < self.expected_http_seq_num: |
| 468 | log(data) |
| 469 | else: |
| 470 | self.http_message_queue += [(seq_num, data, log)] |
| 471 | self.http_message_queue.sort(key=itemgetter(0)) |
| 472 | if len(self.http_message_queue) > 16: |
| 473 | self.print_next_message() |
| 474 | |
| 475 | # If it's been too long since we got a message, prints out the oldest |
| 476 | # queued message, ignoring the proper order. This ensures that if any |
no test coverage detected