()
| 744 | assert not is_preloaded or cmd == "get", "is_preloaded is only supported for 'get'" |
| 745 | |
| 746 | def send_buffer(): |
| 747 | if self.to_send: |
| 748 | try: |
| 749 | written = self.ratelimit.write(self.stdin_fd, self.to_send.peek_front()) |
| 750 | self.tx_bytes += written |
| 751 | self.to_send.pop_front(written) |
| 752 | except OSError as e: |
| 753 | # io.write might raise EAGAIN even though select indicates |
| 754 | # that the fd should be writable. |
| 755 | # EWOULDBLOCK is added for defensive programming sake. |
| 756 | if e.errno not in [errno.EAGAIN, errno.EWOULDBLOCK]: |
| 757 | raise |
| 758 | |
| 759 | def pop_preload_msgid(chunkid): |
| 760 | msgid = self.chunkid_to_msgids[chunkid].pop(0) |
nothing calls this directly
no test coverage detected