(self, check_connections=True)
| 76 | self.handleRequest = request_handler |
| 77 | |
| 78 | def start(self, check_connections=True): |
| 79 | self.running = True |
| 80 | if check_connections: |
| 81 | self.thread_checker = gevent.spawn(self.checkConnections) |
| 82 | CryptConnection.manager.loadCerts() |
| 83 | if config.tor != "disable": |
| 84 | self.tor_manager.start() |
| 85 | if not self.port: |
| 86 | self.log.info("No port found, not binding") |
| 87 | return False |
| 88 | |
| 89 | self.log.debug("Binding to: %s:%s, (msgpack: %s), supported crypt: %s" % ( |
| 90 | self.ip, self.port, ".".join(map(str, msgpack.version)), |
| 91 | CryptConnection.manager.crypt_supported |
| 92 | )) |
| 93 | try: |
| 94 | self.stream_server = StreamServer( |
| 95 | (self.ip, self.port), self.handleIncomingConnection, spawn=self.pool, backlog=100 |
| 96 | ) |
| 97 | except Exception as err: |
| 98 | self.log.info("StreamServer create error: %s" % Debug.formatException(err)) |
| 99 | |
| 100 | def listen(self): |
| 101 | if not self.running: |
no test coverage detected