(self, response)
| 250 | return self.decoderesponse(response) |
| 251 | |
| 252 | def decoderesponse(self, response): |
| 253 | how, what = response |
| 254 | if how == "OK": |
| 255 | return what |
| 256 | if how == "QUEUED": |
| 257 | return None |
| 258 | if how == "EXCEPTION": |
| 259 | self.debug("decoderesponse: EXCEPTION") |
| 260 | return None |
| 261 | if how == "EOF": |
| 262 | self.debug("decoderesponse: EOF") |
| 263 | self.decode_interrupthook() |
| 264 | return None |
| 265 | if how == "ERROR": |
| 266 | self.debug("decoderesponse: Internal ERROR:", what) |
| 267 | raise RuntimeError(what) |
| 268 | if how == "CALLEXC": |
| 269 | self.debug("decoderesponse: Call Exception:", what) |
| 270 | raise what |
| 271 | raise SystemError(how, what) |
| 272 | |
| 273 | def decode_interrupthook(self): |
| 274 | "" |
no test coverage detected