(self, message)
| 578 | self.handle_write() |
| 579 | |
| 580 | def HandleConnected(self, message): |
| 581 | if 'success' in message and self.state == self.STATE_CONNECTING: |
| 582 | response = chr(0x05) |
| 583 | if message['success']: |
| 584 | response += chr(0x00) |
| 585 | logging.debug('[{0:d}] Connected to {1}'.format(self.client_id, self.hostname)) |
| 586 | self.state = self.STATE_CONNECTED |
| 587 | else: |
| 588 | response += chr(0x04) |
| 589 | self.state = self.STATE_ERROR |
| 590 | response += chr(0x00) |
| 591 | response += self.requested_address |
| 592 | self.buffer += response |
| 593 | self.handle_write() |
| 594 | |
| 595 | |
| 596 | ######################################################################################################################## |
no test coverage detected