(self)
| 396 | super().__init__(**kwargs) |
| 397 | |
| 398 | def _startThreads(self): |
| 399 | if self._networkingThread_v4 is not None: |
| 400 | return |
| 401 | |
| 402 | self._networkingThread_v4 = NetworkingThreadIPv4(self) |
| 403 | self._networkingThread_v4.start() |
| 404 | self._addrsMonitorThread_v4 = AddressMonitorThread(self, socket.AF_INET) |
| 405 | self._addrsMonitorThread_v4.start() |
| 406 | logger.debug("networking threads started") |
| 407 | |
| 408 | try: |
| 409 | self._networkingThread_v6 = NetworkingThreadIPv6(self) |
| 410 | self._networkingThread_v6.start() |
| 411 | self._addrsMonitorThread_v6 = AddressMonitorThread(self, socket.AF_INET6) |
| 412 | self._addrsMonitorThread_v6.start() |
| 413 | except OSError as e: |
| 414 | logger.debug("IPv6 not supported: %s", e) |
| 415 | self._networkingThread_v6 = None |
| 416 | self._addrsMonitorThread_v6 = None |
| 417 | logger.debug("address monitoring threads started") |
| 418 | |
| 419 | def _stopThreads(self): |
| 420 | if self._networkingThread_v4 is not None: |
no test coverage detected