Register resource, returning an identifier.
(self, send, close)
| 70 | util.register_after_fork(self, _ResourceSharer._afterfork) |
| 71 | |
| 72 | def register(self, send, close): |
| 73 | '''Register resource, returning an identifier.''' |
| 74 | with self._lock: |
| 75 | if self._address is None: |
| 76 | self._start() |
| 77 | self._key += 1 |
| 78 | self._cache[self._key] = (send, close) |
| 79 | return (self._address, self._key) |
| 80 | |
| 81 | @staticmethod |
| 82 | def get_connection(ident): |