(self, wait)
| 381 | return packet |
| 382 | |
| 383 | def pollmessage(self, wait): |
| 384 | packet = self.pollpacket(wait) |
| 385 | if packet is None: |
| 386 | return None |
| 387 | try: |
| 388 | message = pickle.loads(packet) |
| 389 | except pickle.UnpicklingError: |
| 390 | print("-----------------------", file=sys.__stderr__) |
| 391 | print("cannot unpickle packet:", repr(packet), file=sys.__stderr__) |
| 392 | traceback.print_stack(file=sys.__stderr__) |
| 393 | print("-----------------------", file=sys.__stderr__) |
| 394 | raise |
| 395 | return message |
| 396 | |
| 397 | def pollresponse(self, myseq, wait): |
| 398 | """Handle messages received on the socket. |
no test coverage detected