Initialize the connection
(self, message)
| 199 | return self._info |
| 200 | |
| 201 | def _init_conn(self, message): |
| 202 | """Initialize the connection""" |
| 203 | if len(message) != 4: |
| 204 | logger.warning("Invalid connection from %s", self.name()) |
| 205 | self.close() |
| 206 | magic = struct.unpack("<i", message)[0] |
| 207 | if magic != RPC_TRACKER_MAGIC: |
| 208 | logger.warning("Invalid magic from %s", self.name()) |
| 209 | self.close() |
| 210 | self.write_message(struct.pack("<i", RPC_TRACKER_MAGIC), binary=True) |
| 211 | self._init_req_nbytes = 0 |
| 212 | |
| 213 | def on_message(self, message): |
| 214 | """Callback when a message is received. |
no test coverage detected