Lines Matching refs:upstream
54 auto upstream = static_cast<Http3Upstream *>(w->data);
56 if (upstream->handle_expiry() != 0 || upstream->on_write() != 0) {
63 auto handler = upstream->get_client_handler();
71 auto upstream = static_cast<Http3Upstream *>(w->data);
72 auto handler = upstream->get_client_handler();
74 if (upstream->submit_goaway() != 0) {
82 auto upstream = static_cast<Http3Upstream *>(w->data);
83 auto handler = upstream->get_client_handler();
85 if (upstream->check_shutdown() != 0) {
107 auto upstream = static_cast<Http3Upstream *>(handler->get_upstream());
108 return upstream->get_conn();
179 auto upstream = static_cast<Http3Upstream *>(user_data);
181 upstream->qlog_write(data, datalen, flags & NGTCP2_QLOG_WRITE_FLAG_FIN);
207 auto upstream = static_cast<Http3Upstream *>(user_data);
208 auto handler = upstream->get_client_handler();
235 auto upstream = static_cast<Http3Upstream *>(user_data);
236 auto handler = upstream->get_client_handler();
271 auto upstream = static_cast<Http3Upstream *>(user_data);
273 if (upstream->recv_stream_data(flags, stream_id, data, datalen) != 0) {
306 auto upstream = static_cast<Http3Upstream *>(user_data);
312 if (upstream->stream_close(stream_id, app_error_code) != 0) {
348 auto upstream = static_cast<Http3Upstream *>(user_data);
350 if (upstream->acked_stream_data_offset(stream_id, datalen) != 0) {
378 auto upstream = static_cast<Http3Upstream *>(user_data);
380 if (upstream->extend_max_stream_data(stream_id) != 0) {
406 auto upstream = static_cast<Http3Upstream *>(user_data);
408 upstream->extend_max_remote_streams_bidi(max_streams);
422 auto upstream = static_cast<Http3Upstream *>(user_data);
424 if (upstream->stream_reset(stream_id) != 0) {
469 auto upstream = static_cast<Http3Upstream *>(user_data);
471 if (upstream->http_shutdown_stream_read(stream_id) != 0) {
481 auto upstream = static_cast<Http3Upstream *>(user_data);
483 if (upstream->handshake_completed() != 0) {
514 auto upstream = static_cast<Http3Upstream *>(user_data);
515 if (upstream->send_new_token(&path->remote) != 0) {
559 auto upstream = static_cast<Http3Upstream *>(user_data);
560 if (upstream->setup_httpconn() != 0) {
637 if (quicconf.upstream.debug.log) {
641 if (!quicconf.upstream.qlog.dir.empty()) {
642 auto fd = open_qlog_file(quicconf.upstream.qlog.dir, scid);
651 quicconf.upstream.initial_rtt * NGTCP2_SECONDS);
652 settings.cc_algo = quicconf.upstream.congestion_controller;
653 settings.max_window = http3conf.upstream.max_connection_window_size;
654 settings.max_stream_window = http3conf.upstream.max_window_size;
665 params.initial_max_streams_bidi = http3conf.upstream.max_concurrent_streams;
668 params.initial_max_data = http3conf.upstream.connection_window_size;
669 params.initial_max_stream_data_bidi_remote = http3conf.upstream.window_size;
670 params.initial_max_stream_data_uni = http3conf.upstream.window_size;
672 quicconf.upstream.timeout.idle * NGTCP2_SECONDS);
675 if (quicconf.upstream.early_data) {
1042 // NGHTTP2_REFUSED_STREAM is important because it tells upstream
1060 // RST_STREAM to the upstream and delete downstream connection
1230 auto upstream = static_cast<Http3Upstream *>(conn_user_data);
1259 upstream->shutdown_stream_read(stream_id, NGHTTP3_H3_NO_ERROR) != 0) {
2022 auto upstream = static_cast<Http3Upstream *>(user_data);
2024 upstream->consume(stream_id, nconsumed);
2034 auto upstream = static_cast<Http3Upstream *>(user_data);
2039 if (upstream->http_acked_stream_data(downstream, datalen) != 0) {
2074 auto upstream = static_cast<Http3Upstream *>(user_data);
2075 upstream->http_begin_request_headers(stream_id);
2086 auto upstream = static_cast<Http3Upstream *>(user_data);
2093 if (upstream->http_recv_request_header(downstream, token, name, value, flags,
2107 auto upstream = static_cast<Http3Upstream *>(user_data);
2114 if (upstream->http_recv_request_header(downstream, token, name, value, flags,
2183 auto upstream = static_cast<Http3Upstream *>(user_data);
2184 auto handler = upstream->get_client_handler();
2191 if (upstream->http_end_request_headers(downstream, fin) != 0) {
2426 auto upstream = static_cast<Http3Upstream *>(user_data);
2429 if (upstream->http_recv_data(downstream, data, datalen) != 0) {
2457 auto upstream = static_cast<Http3Upstream *>(user_data);
2464 if (upstream->http_end_stream(downstream) != 0) {
2490 auto upstream = static_cast<Http3Upstream *>(conn_user_data);
2497 if (upstream->http_stream_close(downstream, app_error_code) != 0) {
2556 auto upstream = static_cast<Http3Upstream *>(user_data);
2558 if (upstream->http_stop_sending(stream_id, app_error_code) != 0) {
2583 auto upstream = static_cast<Http3Upstream *>(user_data);
2585 if (upstream->http_reset_stream(stream_id, app_error_code) != 0) {