(self)
| 120 | self._thread = None |
| 121 | |
| 122 | def _start(self): |
| 123 | from .connection import Listener |
| 124 | assert self._listener is None, "Already have Listener" |
| 125 | util.debug('starting listener and thread for sending handles') |
| 126 | self._listener = Listener(authkey=process.current_process().authkey, backlog=128) |
| 127 | self._address = self._listener.address |
| 128 | t = threading.Thread(target=self._serve) |
| 129 | t.daemon = True |
| 130 | t.start() |
| 131 | self._thread = t |
| 132 | |
| 133 | def _serve(self): |
| 134 | if hasattr(signal, 'pthread_sigmask'): |