(self, msg, streaming=False)
| 46 | self.connection.sendRawfile(file, read_bytes) |
| 47 | |
| 48 | def response(self, msg, streaming=False): |
| 49 | if self.responded: |
| 50 | if config.verbose: |
| 51 | self.log.debug("Req id %s already responded" % self.req_id) |
| 52 | return |
| 53 | if not isinstance(msg, dict): # If msg not a dict create a {"body": msg} |
| 54 | msg = {"body": msg} |
| 55 | msg["cmd"] = "response" |
| 56 | msg["to"] = self.req_id |
| 57 | self.responded = True |
| 58 | self.send(msg, streaming=streaming) |
| 59 | |
| 60 | # Route file requests |
| 61 | def route(self, cmd, req_id, params): |
no test coverage detected