(self, message)
| 249 | in_pipe.SendMessage(message) |
| 250 | |
| 251 | def handle_message(self, message): |
| 252 | if message['message'] == 'data' and 'data' in message and len(message['data']): |
| 253 | self.buffer += message['data'] |
| 254 | if self.state == self.STATE_CONNECTED: |
| 255 | self.handle_write() |
| 256 | elif message['message'] == 'resolve': |
| 257 | self.HandleResolve(message) |
| 258 | elif message['message'] == 'connect': |
| 259 | self.HandleConnect(message) |
| 260 | elif message['message'] == 'closed': |
| 261 | if len(self.buffer) == 0: |
| 262 | self.handle_close() |
| 263 | else: |
| 264 | self.needs_close = True |
| 265 | |
| 266 | def handle_error(self): |
| 267 | logging.warning('[{0:d}] Error'.format(self.client_id)) |
no test coverage detected