111 static int (*oneshot_read_cq)(connection *con, chunkqueue *cq, off_t max_bytes);
474 static int server_oneshot_read_cq(connection *con, chunkqueue *cq, off_t max_bytes) {  in server_oneshot_read_cq()  argument
477     int fd = con->fd;  in server_oneshot_read_cq()
478     con->fd = oneshot_fdn->fd;  in server_oneshot_read_cq()
479     int rc = oneshot_read_cq(con, cq, max_bytes);  in server_oneshot_read_cq()
480     con->fd = fd;  in server_oneshot_read_cq()
486     int n = con->is_readable > 0 ? 0 : FDEVENT_IN;  in server_oneshot_read_cq()
489     fdevent_fdnode_event_set(con->srv->ev, oneshot_fdn, n);  in server_oneshot_read_cq()
495     connection *con = context;  in server_oneshot_handle_fdevent()  local
502     request_st * const r = &con->request;  in server_oneshot_handle_fdevent()
511     fdevent_fdnode_event_set(con->srv->ev, oneshot_fdn, n);  in server_oneshot_handle_fdevent()
513     fdnode * const fdn = con->fdn; /* fdn->ctx == con */  in server_oneshot_handle_fdevent()
515       ? (*fdn->handler)(con, revents)  in server_oneshot_handle_fdevent()
523         con->is_readable = 1; /*(can read 0 for end-of-stream)*/  in server_oneshot_handle_fdevent()
524         if (chunkqueue_is_empty(con->read_queue)) r->keep_alive = 0;  in server_oneshot_handle_fdevent()
543     connection *con;  in server_oneshot_init_pipe()  local
589     con = connection_accepted(srv, srv_socket, &cnt_addr, fdout);  in server_oneshot_init_pipe()
590     if (NULL == con) return 0;  in server_oneshot_init_pipe()
603     oneshot_read_cq = con->network_read;  in server_oneshot_init_pipe()
604     con->network_read = server_oneshot_read_cq;  in server_oneshot_init_pipe()
606       fdevent_register(srv->ev, fdin, server_oneshot_handle_fdevent, con);  in server_oneshot_init_pipe()
609     connection_state_machine(con);  in server_oneshot_init_pipe()
616 	connection *con;  in server_oneshot_init()  local
649 	con = connection_accepted(srv, srv_socket, &cnt_addr, fd);  in server_oneshot_init()
650 	if (NULL == con) return 0;  in server_oneshot_init()
652 	connection_state_machine(con);  in server_oneshot_init()
1936     for (connection *con = joblist, *jqnext; con != sentinel; con = jqnext) {  in __attribute_nonnull__()  local
1937         jqnext = con->jqnext;  in __attribute_nonnull__()
1938         con->jqnext = NULL;  in __attribute_nonnull__()
1939         connection_state_machine(con);  in __attribute_nonnull__()