(self, message)
| 439 | out_pipe.SendMessage(message) |
| 440 | |
| 441 | def handle_message(self, message): |
| 442 | if message['message'] == 'data' and 'data' in message and len(message['data']) > 0: |
| 443 | self.buffer += message['data'] |
| 444 | if self.state == self.STATE_CONNECTED: |
| 445 | self.handle_write() |
| 446 | elif message['message'] == 'resolved': |
| 447 | self.HandleResolved(message) |
| 448 | elif message['message'] == 'connected': |
| 449 | self.HandleConnected(message) |
| 450 | self.handle_write() |
| 451 | elif message['message'] == 'closed': |
| 452 | if len(self.buffer) == 0: |
| 453 | logging.info('[{0:d}] Server connection close being processed, closing Browser connection'.format(self.client_id)) |
| 454 | self.handle_close() |
| 455 | else: |
| 456 | logging.info('[{0:d}] Server connection close being processed, queuing browser connection close'.format(self.client_id)) |
| 457 | self.needs_close = True |
| 458 | |
| 459 | def writable(self): |
| 460 | return len(self.buffer) > 0 |
nothing calls this directly
no test coverage detected