()
| 444 | return |
| 445 | |
| 446 | def send_buffer(): |
| 447 | if self.to_send: |
| 448 | try: |
| 449 | written = self.ratelimit.write(self.stdin_fd, self.to_send.peek_front()) |
| 450 | self.tx_bytes += written |
| 451 | self.to_send.pop_front(written) |
| 452 | except OSError as e: |
| 453 | # io.write might raise EAGAIN even though select indicates |
| 454 | # that the fd should be writable. |
| 455 | # EWOULDBLOCK is added for defensive programming sake. |
| 456 | if e.errno not in [errno.EAGAIN, errno.EWOULDBLOCK]: |
| 457 | raise |
| 458 | |
| 459 | def pop_preload_msgid(chunkid): |
| 460 | msgid = self.chunkid_to_msgids[chunkid].pop(0) |
nothing calls this directly
no test coverage detected