(self, action, payload, trans)
| 120 | return trans_id, struct.pack('!QLL', self.conn_id, action, trans_id) |
| 121 | |
| 122 | def _process_response(self, action, payload, trans): |
| 123 | if action == CONNECT: |
| 124 | return self._process_connect(payload, trans) |
| 125 | elif action == ANNOUNCE: |
| 126 | return self._process_announce(payload, trans) |
| 127 | elif action == SCRAPE: |
| 128 | return self._process_scrape(payload, trans) |
| 129 | elif action == ERROR: |
| 130 | return self._process_error(payload, trans) |
| 131 | else: |
| 132 | raise UdpTrackerClientException( |
| 133 | 'Unknown action response: {}'.format(action)) |
| 134 | |
| 135 | def _process_connect(self, payload, trans): |
| 136 | self.conn_id = struct.unpack('!Q', payload)[0] |
no test coverage detected