(self, after_fork=False)
| 67 | self._reset(after_fork=True) |
| 68 | |
| 69 | def _reset(self, after_fork=False): |
| 70 | if after_fork: |
| 71 | self._notempty._at_fork_reinit() |
| 72 | else: |
| 73 | self._notempty = threading.Condition(threading.Lock()) |
| 74 | self._buffer = collections.deque() |
| 75 | self._thread = None |
| 76 | self._jointhread = None |
| 77 | self._joincancelled = False |
| 78 | self._closed = False |
| 79 | self._close = None |
| 80 | self._send_bytes = self._writer.send_bytes |
| 81 | self._recv_bytes = self._reader.recv_bytes |
| 82 | self._poll = self._reader.poll |
| 83 | |
| 84 | def put(self, obj, block=True, timeout=None): |
| 85 | if self._closed: |
no test coverage detected