Enable or disable accepting new connections.
(self, enabled)
| 259 | super().handle_quit(sig, frame) |
| 260 | |
| 261 | def set_accept_enabled(self, enabled): |
| 262 | """Enable or disable accepting new connections.""" |
| 263 | if enabled == self._accepting: |
| 264 | return |
| 265 | |
| 266 | for listener in self.sockets: |
| 267 | if enabled: |
| 268 | listener.setblocking(False) |
| 269 | self.poller.register(listener, selectors.EVENT_READ, self.accept) |
| 270 | else: |
| 271 | self.poller.unregister(listener) |
| 272 | |
| 273 | self._accepting = enabled |
| 274 | |
| 275 | def enqueue_req(self, conn): |
| 276 | """Submit connection to thread pool for processing.""" |