Handle a pending (deferred) connection becoming readable.
(self, conn, client)
| 302 | self.enqueue_req(conn) |
| 303 | |
| 304 | def on_pending_socket_readable(self, conn, client): |
| 305 | """Handle a pending (deferred) connection becoming readable.""" |
| 306 | self.poller.unregister(client) |
| 307 | self.pending_conns.remove(conn) |
| 308 | |
| 309 | # Mark data as ready so we don't wait again in handle() |
| 310 | conn.data_ready = True |
| 311 | |
| 312 | # Submit to thread pool for processing |
| 313 | self.enqueue_req(conn) |
| 314 | |
| 315 | def murder_keepalived(self): |
| 316 | """Close expired keepalive connections.""" |