43 static connection *connection_init(server *srv);
47 static connection *connections_get_new_connection(server *srv) {  in connections_get_new_connection()  argument
49     --srv->lim_conns;  in connections_get_new_connection()
50     if (srv->conns_pool) {  in connections_get_new_connection()
51         con = srv->conns_pool;  in connections_get_new_connection()
52         srv->conns_pool = con->next;  in connections_get_new_connection()
55         con = connection_init(srv);  in connections_get_new_connection()
59     if ((con->next = srv->conns))  in connections_get_new_connection()
61     return (srv->conns = con);  in connections_get_new_connection()
64 static void connection_del(server *srv, connection *con) {  in connection_del()  argument
70         srv->conns = con->next;  in connection_del()
72     con->next = srv->conns_pool;  in connection_del()
73     srv->conns_pool = con;  in connection_del()
74     ++srv->lim_conns;  in connection_del()
82 	server * const srv = con->srv;  in connection_close()  local
92 	fdevent_fdnode_event_del(srv->ev, con->fdn);  in connection_close()
93 	fdevent_unregister(srv->ev, con->fdn);  in connection_close()
100 		--srv->cur_fds;  in connection_close()
111 	connection_del(srv, con);  in connection_close()
500 static connection *connection_init(server *srv) {  in connection_init()  argument
503 	con->srv = srv;  in connection_init()
504 	con->plugin_slots = srv->plugin_slots;  in connection_init()
505 	con->config_data_base = srv->config_data_base;  in connection_init()
508 	request_init_data(r, con, srv);  in connection_init()
513 	con->plugin_ctx = ck_calloc(srv->plugins.used + 1, sizeof(void *));  in connection_init()
534 void connections_pool_clear(server * const srv) {  in connections_pool_clear()  argument
536     while ((con = srv->conns_pool)) {  in connections_pool_clear()
537         srv->conns_pool = con->next;  in connections_pool_clear()
542 void connections_free(server *srv) {  in connections_free()  argument
543     connections_pool_clear(srv);  in connections_free()
546     while ((con = srv->conns)) {  in connections_free()
547         srv->conns = con->next;  in connections_free()
898     return con->srv->network_backend_write(con->fd,cq,max_bytes,r->conf.errh);  in connection_write_cq()
904 connection *connection_accepted(server *srv, const server_socket *srv_socket, sock_addr *cnt_addr, …  in connection_accepted()  argument
907 		srv->cur_fds++;  in connection_accepted()
911 		log_error(srv->errh, __FILE__, __LINE__, "accepted() %d", cnt);  in connection_accepted()
914 		con = connections_get_new_connection(srv);  in connection_accepted()
917 		con->fdn = fdevent_register(srv->ev, con->fd, connection_handle_fdevent, con);  in connection_accepted()
1077             fdevent_fdnode_event_set(con->srv->ev, con->fdn, events);  in connection_revents_err()
1090             fdevent_fdnode_event_set(con->srv->ev, con->fdn, events);  in connection_revents_err()
1166     fdevent_fdnode_event_set(con->srv->ev, con->fdn, n);  in connection_set_fdevent_interest()
1529 void connection_periodic_maint (server * const srv, const unix_time64_t cur_ts) {  in connection_periodic_maint()  argument
1531     for (connection *con = srv->conns, *tc; con; con = tc) {  in connection_periodic_maint()
1537 void connection_graceful_shutdown_maint (server *srv) {  in connection_graceful_shutdown_maint()  argument
1539       (srv->graceful_expire_ts && srv->graceful_expire_ts < log_monotonic_secs);  in connection_graceful_shutdown_maint()
1540     for (connection *con = srv->conns, *tc; con; con = tc) {  in connection_graceful_shutdown_maint()