| /third_party/nghttp2/src/ |
| D | shrpx_live_check.cc | 105 : conn_(loop, -1, nullptr, worker->get_mcpool(), in LiveCheck()
135 ev_timer_stop(conn_.loop, &backoff_timer_); in ~LiveCheck()
149 conn_.rlimit.stopw(); in disconnect()
150 conn_.wlimit.stopw(); in disconnect()
152 ev_timer_stop(conn_.loop, &settings_timer_); in disconnect()
156 conn_.disconnect(); in disconnect()
187 ev_timer_start(conn_.loop, &backoff_timer_); in schedule()
224 conn_.set_ssl(ssl); in initiate_connection()
225 conn_.tls.client_session_cache = &addr_->tls_session_cache; in initiate_connection()
278 conn_.fd = util::create_nonblock_socket(raddr_->su.storage.ss_family); in initiate_connection()
[all …]
|
| D | shrpx_memcached_connection.cc | 104 : conn_(loop, -1, nullptr, mcpool, write_timeout, read_timeout, {}, {}, in MemcachedConnection()
118 MemcachedConnection::~MemcachedConnection() { conn_.disconnect(); } in ~MemcachedConnection()
143 conn_.disconnect(); in disconnect()
152 assert(conn_.fd == -1); in initiate_connection()
159 conn_.set_ssl(ssl); in initiate_connection()
160 conn_.tls.client_session_cache = &tls_session_cache_; in initiate_connection()
163 conn_.fd = util::create_nonblock_socket(addr_->su.storage.ss_family); in initiate_connection()
165 if (conn_.fd == -1) { in initiate_connection()
173 rv = connect(conn_.fd, &addr_->su.sa, addr_->len); in initiate_connection()
178 close(conn_.fd); in initiate_connection()
[all …]
|
| D | shrpx_http_downstream_connection.cc | 207 : conn_(loop, -1, nullptr, worker->get_mcpool(), in HttpDownstreamConnection()
220 ioctrl_(&conn_.rlimit),
306 if (conn_.fd == -1) { in initiate_connection()
382 conn_.fd = util::create_nonblock_socket(raddr->su.storage.ss_family); in initiate_connection()
384 if (conn_.fd == -1) { in initiate_connection()
396 rv = connect(conn_.fd, &raddr->su.sa, raddr->len); in initiate_connection()
423 conn_.set_ssl(ssl); in initiate_connection()
424 conn_.tls.client_session_cache = &addr_->tls_session_cache; in initiate_connection()
429 SSL_set_tlsext_host_name(conn_.tls.ssl, sni_name.c_str()); in initiate_connection()
434 SSL_set_session(conn_.tls.ssl, session); in initiate_connection()
[all …]
|
| D | shrpx_http2_session.cc | 187 conn_(loop, -1, nullptr, worker->get_mcpool(), in Http2Session()
248 conn_.rlimit.stopw(); in disconnect()
249 conn_.wlimit.stopw(); in disconnect()
251 ev_prepare_stop(conn_.loop, &prep_); in disconnect()
253 ev_timer_stop(conn_.loop, &initiate_connection_timer_); in disconnect()
254 ev_timer_stop(conn_.loop, &settings_timer_); in disconnect()
255 ev_timer_stop(conn_.loop, &connchk_timer_); in disconnect()
262 conn_.disconnect(); in disconnect()
396 conn_.fd = util::create_nonblock_socket(proxy.addr.su.storage.ss_family); in initiate_connection()
398 if (conn_.fd == -1) { in initiate_connection()
[all …]
|
| D | shrpx_client_handler.cc | 127 conn_.rlimit.stopw(); in read_clear()
131 if (!ev_is_active(&conn_.rev) || should_break) { in read_clear()
135 auto nread = conn_.read_clear(rb_.last(), rb_.wleft()); in read_clear()
166 auto nwrite = conn_.writev_clear(iov.data(), iovcnt); in write_clear()
178 conn_.wlimit.stopw(); in write_clear()
179 ev_timer_stop(conn_.loop, &conn_.wt); in write_clear()
189 auto nread = conn_.peek_clear(rb_.last(), rb_.wleft()); in proxy_protocol_peek_clear()
214 ev_timer_again(conn_.loop, &conn_.rt); in tls_handshake()
218 auto rv = conn_.tls_handshake(); in tls_handshake()
257 conn_.rlimit.stopw(); in read_tls()
[all …]
|
| D | h2load_http3_session.cc | 36 : client_(client), conn_(nullptr), npending_request_(0), reqidx_(0) {} in Http3Session()
38 Http3Session::~Http3Session() { nghttp3_conn_del(conn_); } in ~Http3Session()
106 conn_, stream_id, reinterpret_cast<nghttp3_nv *>(nva.data()), nva.size(), in submit_request_internal()
191 auto payloadlen = nghttp3_conn_get_frame_payload_left(conn_, stream_id); in begin_headers()
260 auto rv = nghttp3_conn_close_stream(conn_, stream_id, app_error_code); in close_stream()
276 auto rv = nghttp3_conn_shutdown_stream_read(conn_, stream_id); in shutdown_stream_read()
306 assert(conn_ == nullptr); in init_conn()
338 rv = nghttp3_conn_client_new(&conn_, &callbacks, &settings, mem, this); in init_conn()
355 rv = nghttp3_conn_bind_control_stream(conn_, ctrl_stream_id); in init_conn()
380 rv = nghttp3_conn_bind_qpack_streams(conn_, qpack_enc_stream_id, in init_conn()
[all …]
|
| D | shrpx_rate_limit.cc | 45 conn_(conn), in RateLimit()
111 if (!conn_ || !conn_->tls.ssl || in handle_tls_pending_read()
112 (SSL_pending(conn_->tls.ssl) == 0 && conn_->tls.rbuf.rleft() == 0 && in handle_tls_pending_read()
113 (!conn_->tls.initial_handshake_done || in handle_tls_pending_read()
114 conn_->tls.earlybuf.rleft() == 0))) { in handle_tls_pending_read()
|
| D | shrpx_http3_upstream.cc | 116 conn_{nullptr},
149 ngtcp2_conn_del(conn_); in ~Http3Upstream()
296 ngtcp2_conn_extend_max_stream_offset(conn_, stream_id, nconsumed); in recv_stream_data()
297 ngtcp2_conn_extend_max_offset(conn_, nconsumed); in recv_stream_data()
331 ngtcp2_conn_extend_max_streams_bidi(conn_, 1); in stream_close()
485 auto path = ngtcp2_conn_get_path(conn_); in handshake_completed()
501 auto rv = ngtcp2_conn_submit_new_token(conn_, token.data(), tokenlen); in handshake_completed()
692 rv = ngtcp2_conn_server_new(&conn_, &initial_hd.scid, &scid, &path, in init()
700 ngtcp2_conn_set_tls_native_handle(conn_, handler_->get_ssl()); in init()
742 auto max_udp_payload_size = ngtcp2_conn_get_max_tx_udp_payload_size(conn_); in write_streams()
[all …]
|
| D | shrpx_rate_limit.h | 59 Connection *conn_; variable
|
| D | shrpx_live_check.h | 94 Connection conn_;
|
| D | shrpx_http_downstream_connection.h | 96 Connection conn_;
|
| D | h2load_http3_session.h | 75 nghttp3_conn *conn_; variable
|
| D | shrpx_memcached_connection.h | 135 Connection conn_;
|
| D | shrpx_client_handler.h | 206 Connection conn_; variable
|
| D | shrpx_http2_session.h | 251 Connection conn_;
|
| D | shrpx_http3_upstream.h | 163 ngtcp2_conn *conn_; variable
|