Handle a keepalive connection becoming readable.
(self, conn, client)
| 294 | raise |
| 295 | |
| 296 | def on_client_socket_readable(self, conn, client): |
| 297 | """Handle a keepalive connection becoming readable.""" |
| 298 | self.poller.unregister(client) |
| 299 | self.keepalived_conns.remove(conn) |
| 300 | |
| 301 | # Submit to thread pool for processing |
| 302 | self.enqueue_req(conn) |
| 303 | |
| 304 | def on_pending_socket_readable(self, conn, client): |
| 305 | """Handle a pending (deferred) connection becoming readable.""" |
nothing calls this directly
no test coverage detected