(self, message)
| 330 | return seq |
| 331 | |
| 332 | def putmessage(self, message): |
| 333 | self.debug("putmessage:%d:" % message[0]) |
| 334 | try: |
| 335 | s = dumps(message) |
| 336 | except pickle.PicklingError: |
| 337 | print("Cannot pickle:", repr(message), file=sys.__stderr__) |
| 338 | raise |
| 339 | s = struct.pack("<i", len(s)) + s |
| 340 | while len(s) > 0: |
| 341 | try: |
| 342 | r, w, x = select.select([], [self.sock], []) |
| 343 | n = self.sock.send(s[:BUFSIZE]) |
| 344 | except (AttributeError, TypeError): |
| 345 | raise OSError("socket no longer exists") |
| 346 | s = s[n:] |
| 347 | |
| 348 | buff = b'' |
| 349 | bufneed = 4 |
no test coverage detected