(self, cmd, data)
| 511 | return None # no data available right now |
| 512 | |
| 513 | def got_packet(self, cmd, data): |
| 514 | if cmd == CMD_EOF: |
| 515 | self.noread() |
| 516 | elif cmd == CMD_STOP_SENDING: |
| 517 | self.nowrite() |
| 518 | elif cmd == CMD_DATA: |
| 519 | self.buf.append(data) |
| 520 | else: |
| 521 | raise Exception('unknown command %d (%d bytes)' |
| 522 | % (cmd, len(data))) |
| 523 | |
| 524 | |
| 525 | def connect_dst(ip, port): |