(self)
| 314 | self.handle_close() |
| 315 | |
| 316 | def handle_read(self): |
| 317 | try: |
| 318 | while True: |
| 319 | data = self.recv(1460) |
| 320 | if data: |
| 321 | if self.state == self.STATE_CONNECTED: |
| 322 | logging.debug('[{0:d}] TCP <= {1:d} byte(s)'.format(self.client_id, len(data))) |
| 323 | self.SendMessage('data', {'data': data}) |
| 324 | else: |
| 325 | return |
| 326 | except: |
| 327 | pass |
| 328 | |
| 329 | def HandleResolve(self, message): |
| 330 | global in_pipe, map_localhost, lock, background_activity_count |
nothing calls this directly
no test coverage detected