Home
last modified time | relevance | path

Searched refs:con (Results 1 – 25 of 45) sorted by relevance

12

/lighttpd1.4/src/
H A Dconnections.c60 con->next->prev = con; in connections_get_new_connection()
66 con->next->prev = con->prev; in connection_del()
68 con->prev->next = con->next; in connection_del()
78 if (con->fd < 0) con->fd = -con->fd; in connection_close()
109 con->fd = -1; in connection_close()
138 if (con->network_read(con, con->read_queue, MAX_READ_LIMIT) < 0) in connection_read_for_eos_ssl()
301 ret = con->network_write(con, cq, max_bytes); in connection_write_chunkqueue()
917 con->fdn = fdevent_register(srv->ev, con->fd, connection_handle_fdevent, con); in connection_accepted()
1531 for (connection *con = srv->conns, *tc; con; con = tc) { in connection_periodic_maint() local
1540 for (connection *con = srv->conns, *tc; con; con = tc) { in connection_graceful_shutdown_maint() local
[all …]
H A Dh2.c348 h2con * const h2c = con->h2; in h2_send_goaway_rst_stream()
375 h2con * const h2c = con->h2; in h2_send_goaway()
408 h2_send_goaway(con, e); in h2_send_goaway_e()
765 r = &con->request; in h2_recv_window_update()
2017 con->plugin_ctx[0] = (void *)(uintptr_t)con->network_read; in h2_init_con()
2783 ++con->request_count; in h2_init_stream()
2836 UNUSED(con); in h2_release_stream()
2887 con->network_write(con, cq, len); in h2_retire_con()
2903 con->h2 = NULL; in h2_retire_con()
2935 connection * const con = h2r->con; in h2_con_upgrade_h2c() local
[all …]
H A Dreqpool.c56 r->con = con; in request_init_data()
60 r->dst_addr = &con->dst_addr; in request_init_data()
61 r->dst_addr_buf = &con->dst_addr_buf; in request_init_data()
164 && NULL == r->con->plugin_ctx[pd->id]) continue;
168 r->con->plugin_ctx[pd->id] = NULL;
179 connection * const con = r->con; in request_reset_ex()
180 server * const srv = con->srv; in request_reset_ex()
291 request_acquire (connection * const con) in request_acquire() argument
299 request_init_data(r, con, con->srv); in request_acquire()
302 r->con = con; in request_acquire()
[all …]
H A Dh2.h93 void h2_send_goaway (connection *con, request_h2error_t e);
95 int h2_parse_frames (connection *con);
97 int h2_want_read (connection *con);
99 void h2_init_con (request_st * restrict h2r, connection * restrict con, const buffer * restrict htt…
101 int h2_send_1xx (request_st *r, connection *con);
103 void h2_send_100_continue (request_st *r, connection *con);
105 void h2_send_headers (request_st *r, connection *con);
107 uint32_t h2_send_cqdata (request_st *r, connection *con, struct chunkqueue *cq, uint32_t dlen);
109 void h2_send_end_stream (request_st *r, connection *con);
111 void h2_retire_stream (request_st *r, connection *con);
[all …]
H A Drequest.h137 connection *con; member
237 #define http_con_state_is_keep_alive(con) \ argument
238 ((con)->h2 \
239 ? 0 == (con)->h2->rused \
240 : http_request_state_is_keep_alive(&(con)->request))
242 #define http_con_state_append(b, con) \ argument
243 (http_con_state_is_keep_alive(con) \
245 : http_request_state_append((b), (con)->request.state))
247 #define http_con_state_short(con) \ argument
248 (http_con_state_is_keep_alive(con) \
[all …]
H A Dmod_extforward.c1106 r->con->dst_addr_buf.ptr); in URIHANDLER_FUNC()
1134 connection * const con = r->con; in REQUEST_FUNC() local
1135 r->dst_addr = &con->dst_addr; in REQUEST_FUNC()
1151 con->plugin_ctx[p->id] = NULL; in CONNECTION_FUNC()
1181 con->dst_addr_buf.ptr); in CONNECTION_FUNC()
1467 sock_addr_inet_ntop_copy_buffer(&con->dst_addr_buf, &con->dst_addr); in mod_extforward_hap_PROXY_v1()
1527 sock_addr_inet_ntop_copy_buffer(&con->dst_addr_buf, &con->dst_addr); in mod_extforward_hap_PROXY_v2()
1541 sock_addr_inet_ntop_copy_buffer(&con->dst_addr_buf, &con->dst_addr); in mod_extforward_hap_PROXY_v2()
1679 case -1: errh = con->srv->errh; in mod_extforward_network_read()
1682 case -2: errh = con->srv->errh; in mod_extforward_network_read()
[all …]
H A Dbase.h41 int (* network_write)(struct connection *con, chunkqueue *cq, off_t max_bytes);
42 int (* network_read)(struct connection *con, chunkqueue *cq, off_t max_bytes);
68 #define joblist_append(con) connection_jq_append(con) argument
70 static inline void connection_jq_append(connection * const restrict con);
71 static inline void connection_jq_append(connection * const restrict con) in connection_jq_append() argument
73 if (!con->jqnext) { in connection_jq_append()
74 con->jqnext = log_con_jqueue; in connection_jq_append()
75 log_con_jqueue = con; in connection_jq_append()
H A Dserver.c477 int fd = con->fd; in server_oneshot_read_cq()
478 con->fd = oneshot_fdn->fd; in server_oneshot_read_cq()
480 con->fd = fd; in server_oneshot_read_cq()
495 connection *con = context; in server_oneshot_handle_fdevent() local
543 connection *con; in server_oneshot_init_pipe() local
590 if (NULL == con) return 0; in server_oneshot_init_pipe()
616 connection *con; in server_oneshot_init() local
650 if (NULL == con) return 0; 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__()
[all …]
H A Dplugin.h13 static handler_t x(connection *con, void *p_d)
58 handler_t (* handle_connection_accept) (connection *con, void *p_d); /* after accept() socket */
59 handler_t (* handle_connection_shut_wr)(connection *con, void *p_d); /* done writing to socket */
60 …handler_t (* handle_connection_close) (connection *con, void *p_d); /* before close() of socket …
H A Dmod_echo.c46 joblist_append(r->con); in mod_echo_request_body()
65 r->con->is_readable = 1; /* trigger optimistic read from client */ in mod_echo_request_body()
87 rc = r->con->reqbody_read(r); in SUBREQUEST_FUNC()
104 handler_t rc = r->con->reqbody_read(r); in SUBREQUEST_FUNC()
H A Dplugins.h22 handler_t plugins_call_handle_connection_accept(connection *con);
23 handler_t plugins_call_handle_connection_shut_wr(connection *con);
24 handler_t plugins_call_handle_connection_close(connection *con);
H A Dresponse.c32 http_response_delay (connection * const con) in http_response_delay() argument
34 if (config_feature_bool(con->srv, "auth.delay-invalid-creds", 1)){ in http_response_delay()
36 con->is_writable = 0; in http_response_delay()
37 con->traffic_limit_reached = 1; in http_response_delay()
74 connection * const con = r->con; in http_response_write_header_partial_1xx() local
76 chunkqueue * const cq = con->write_queue; in http_response_write_header_partial_1xx()
77 con->write_queue = &r->write_queue; in http_response_write_header_partial_1xx()
95 r->con->keep_alive_idle = r->conf.max_keep_alive_idle; in http_response_write_header()
113 http_response_delay(r->con); in http_response_write_header()
127 if (cq != r->con->write_queue) in http_response_write_header()
[all …]
H A Dmod_gnutls.c147 connection *con; member
2281 con->is_writable = -1; in mod_gnutls_write_err()
2283 con->is_readable = -1; in mod_gnutls_write_err()
2310 con->is_writable = -1; in mod_gnutls_read_err()
2311 con->is_readable = 0; in mod_gnutls_read_err()
2316 con->is_readable = 0; in mod_gnutls_read_err()
2325 return con->network_read(con, cq, max_bytes); in mod_gnutls_read_err()
2574 con->is_readable = 0; in connection_read_cq_ssl()
2602 hctx->con = con; in CONNECTION_FUNC()
2605 con->plugin_ctx[p->id] = hctx; in CONNECTION_FUNC()
[all …]
H A Dmod_status.c240 for (const connection *con = srv->conns; con; con = con->next) { in mod_status_html_rtable() local
241 const request_st * const r = &con->request; in mod_status_html_rtable()
242 h2con * const h2c = con->h2; in mod_status_html_rtable()
680 server * const srv = r->con->srv; in mod_status_handle_server_status()
723 server * const srv = r->con->srv; in mod_status_handle_server_config()
835 const connection * const con = r->con; in REQUESTDONE_FUNC() local
838 if (r == &con->request) /*(HTTP/1.x or only HTTP/2 stream 0)*/ in REQUESTDONE_FUNC()
839 p->bytes_written_1s += con->bytes_written_cur_second; in REQUESTDONE_FUNC()
H A Dmod_wstunnel.c604 for (connection *con = srv->conns; con; con = con->next) { in TRIGGER_FUNC() local
605 request_st * const r = &con->request; in TRIGGER_FUNC()
613 if (cur_ts - con->read_idle_ts > r->conf.max_read_idle) { in TRIGGER_FUNC()
614 DEBUG_LOG_INFO("timeout client (fd=%d)", con->fd); in TRIGGER_FUNC()
617 joblist_append(con); in TRIGGER_FUNC()
620 con->read_idle_ts = cur_ts; in TRIGGER_FUNC()
629 joblist_append(con); in TRIGGER_FUNC()
929 r->con->fd, len); in send_ietf_00()
939 r->con->fd, (long long)chunkqueue_length(cq)); in recv_ietf_00()
1109 r->con->fd, len+siz); in send_rfc_6455()
[all …]
H A Dconnections.h19 int connection_send_1xx (request_st *r, connection *con);
23 void connection_state_machine(connection *con);
H A Dreqpool.h14 void request_init_data (request_st *r, connection *con, server *srv);
20 request_st * request_acquire (connection *con);
H A Dmod_openssl.c176 connection *con; member
2962 con->is_readable = -1; in mod_openssl_write_err()
2965 con->is_writable = -1; in mod_openssl_write_err()
3148 con->dst_addr_buf.ptr); in connection_read_cq_ssl()
3190 con->is_writable = -1; in connection_read_cq_ssl()
3193 con->is_readable = 0; in connection_read_cq_ssl()
3283 con->is_readable = 0; in connection_read_cq_ssl()
3302 hctx->con = con; in CONNECTION_FUNC()
3303 hctx->tmp_buf = con->srv->tmp_buf; in CONNECTION_FUNC()
3305 con->plugin_ctx[p->id] = hctx; in CONNECTION_FUNC()
[all …]
H A Dmod_mbedtls.c195 connection *con; member
1992 con->is_readable = -1; in mod_mbedtls_ssl_write_err()
1995 con->is_writable = -1; in mod_mbedtls_ssl_write_err()
2224 hctx->con->is_readable = 0; in mod_mbedtls_ssl_handshake()
2276 con->is_writable = -1; in connection_read_cq_ssl()
2279 con->is_readable = 0; in connection_read_cq_ssl()
2284 con->is_readable = 0; in connection_read_cq_ssl()
2300 con->is_readable = 0; in connection_read_cq_ssl()
2329 hctx->con = con; in CONNECTION_FUNC()
2332 con->plugin_ctx[p->id] = hctx; in CONNECTION_FUNC()
[all …]
H A Dhttp_cgi.c250 const connection * const con = r->con; in http_cgi_headers() local
251 const server_socket * const srv_sock = con->srv_socket; in http_cgi_headers()
271 if (0 == getsockname(con->fd,(struct sockaddr *)&addrbuf,&addrlen)){ in http_cgi_headers()
333 con->srv->request_env(r); in http_cgi_headers()
H A Dmod_cgi.c80 connection *con; /* dumb pointer */ member
471 joblist_append(hctx->con); in cgi_handle_fdevent_send()
565 r->con->srv->plugins_request_reset(r); in cgi_local_redir()
594 joblist_append(hctx->con); in cgi_handle_fdevent()
718 --r->con->srv->cur_fds; in cgi_write_request()
953 ++r->con->srv->cur_fds; in cgi_create_env()
966 ++r->con->srv->cur_fds; in cgi_create_env()
1025 hctx->ev = r->con->srv->ev; in URIHANDLER_FUNC()
1027 hctx->con = r->con; in URIHANDLER_FUNC()
1121 handler_t rc = r->con->reqbody_read(r); in SUBREQUEST_FUNC()
[all …]
H A Dmod_wolfssl.c197 connection *con; member
2778 con->is_readable = -1; in connection_write_cq_ssl()
2781 con->is_writable = -1; in connection_write_cq_ssl()
2891 con->is_writable = -1; in connection_read_cq_ssl()
2894 con->is_readable = 0; in connection_read_cq_ssl()
2983 con->is_readable = 0; in connection_read_cq_ssl()
3002 hctx->con = con; in CONNECTION_FUNC()
3003 hctx->tmp_buf = con->srv->tmp_buf; in CONNECTION_FUNC()
3005 con->plugin_ctx[p->id] = hctx; in CONNECTION_FUNC()
3034 hctx->con->is_ssl_sock = 0; in mod_openssl_detach()
[all …]
H A Dstat_cache.h49 #define stat_cache_content_type_get(con, r) stat_cache_content_type_get_by_xattr((sce), (r)->conf.m… argument
52 #define stat_cache_content_type_get(con, r) stat_cache_content_type_get_by_ext((sce), (r)->conf.mim… argument
H A Dmod_nss.c190 connection *con; member
2128 con->is_writable = -1; in mod_nss_write_err()
2156 con->is_readable = 0; in mod_nss_read_err()
2282 return mod_nss_read_err(con, hctx); in connection_read_cq_ssl()
2284 con->is_readable = 0; in connection_read_cq_ssl()
2303 request_st * const r = &con->request; in CONNECTION_FUNC()
2305 hctx->con = con; in CONNECTION_FUNC()
2306 hctx->tmp_buf = con->srv->tmp_buf; in CONNECTION_FUNC()
2308 con->plugin_ctx[p->id] = hctx; in CONNECTION_FUNC()
2391 hctx->con->is_ssl_sock = 0; in mod_nss_detach()
[all …]
/lighttpd1.4/src/t/
H A Dtest_mod_userdir.c170 connection con; in test_mod_userdir() local
174 memset(&con, 0, sizeof(connection)); in test_mod_userdir()
181 r.con = &con; in test_mod_userdir()
182 con.srv = &srv; in test_mod_userdir()

12