(self, cmd, data)
| 566 | return None # no data available right now |
| 567 | |
| 568 | def got_packet(self, cmd, data): |
| 569 | if cmd == CMD_TCP_EOF: |
| 570 | # Remote side already knows the status - set flag but don't notify |
| 571 | self.setnoread() |
| 572 | elif cmd == CMD_TCP_STOP_SENDING: |
| 573 | # Remote side already knows the status - set flag but don't notify |
| 574 | self.setnowrite() |
| 575 | elif cmd == CMD_TCP_DATA: |
| 576 | self.buf.append(data) |
| 577 | else: |
| 578 | raise Exception('unknown command %d (%d bytes)' |
| 579 | % (cmd, len(data))) |
| 580 | |
| 581 | |
| 582 | def connect_dst(family, ip, port): |
nothing calls this directly
no test coverage detected