Accept a new connection from a listener socket.
(self, listener)
| 279 | lambda fut: self.method_queue.defer(self.finish_request, conn, fut)) |
| 280 | |
| 281 | def accept(self, listener): |
| 282 | """Accept a new connection from a listener socket.""" |
| 283 | try: |
| 284 | client_sock, client_addr = listener.accept() |
| 285 | self.nr_conns += 1 |
| 286 | client_sock.setblocking(True) |
| 287 | |
| 288 | conn = TConn(self.cfg, client_sock, client_addr, listener.getsockname()) |
| 289 | |
| 290 | # Submit directly to thread pool for processing |
| 291 | self.enqueue_req(conn) |
| 292 | except OSError as e: |
| 293 | if e.errno not in (errno.EAGAIN, errno.ECONNABORTED, errno.EWOULDBLOCK): |
| 294 | raise |
| 295 | |
| 296 | def on_client_socket_readable(self, conn, client): |
| 297 | """Handle a keepalive connection becoming readable.""" |
nothing calls this directly
no test coverage detected