(self)
| 300 | time.sleep(0.01) |
| 301 | |
| 302 | def start(self): |
| 303 | super(NetworkingThread, self).start() |
| 304 | |
| 305 | self._uniOutSocket = socket.socket(self._get_inet(), socket.SOCK_DGRAM) |
| 306 | |
| 307 | self._multiInSocket = self._createMulticastInSocket() |
| 308 | self._selector.register(self._multiInSocket, selectors.EVENT_WRITE | selectors.EVENT_READ) |
| 309 | |
| 310 | self._multiOutUniInSockets = {} # FIXME synchronisation |
| 311 | |
| 312 | def join(self, **kwargs): |
| 313 | assert self._quitEvent.is_set() |