Lines Matching refs:upstream
61 auto upstream = static_cast<Http2Upstream *>(user_data);
63 ULOG(INFO, upstream) << "Stream stream_id=" << stream_id
76 upstream->consume(stream_id, req.unconsumed_body_length);
81 upstream->remove_downstream(downstream);
98 upstream->remove_downstream(downstream);
169 if (config->http2.upstream.debug.frame_debug) {
176 auto upstream = static_cast<Http2Upstream *>(user_data);
195 ULOG(INFO, upstream) << "Too large or many header field size="
205 if (upstream->error_reply(downstream, 431) != 0) {
238 auto upstream = static_cast<Http2Upstream *>(user_data);
249 ULOG(INFO, upstream) << "Invalid header field for stream_id="
255 upstream->rst_stream(downstream, NGHTTP2_PROTOCOL_ERROR);
264 auto upstream = static_cast<Http2Upstream *>(user_data);
270 ULOG(INFO, upstream) << "Received upstream request HEADERS stream_id="
274 upstream->on_start_request(frame);
336 auto &dump = config->http2.upstream.debug.dump;
548 if (get_config()->http2.upstream.debug.frame_debug) {
551 auto upstream = static_cast<Http2Upstream *>(user_data);
552 auto handler = upstream->get_client_handler();
567 upstream->rst_stream(downstream, NGHTTP2_INTERNAL_ERROR);
588 return upstream->on_request_headers(downstream, frame);
596 upstream->rst_stream(downstream, NGHTTP2_INTERNAL_ERROR);
609 upstream->stop_settings_timer();
616 ULOG(INFO, upstream) << "GOAWAY received: last-stream-id="
632 auto upstream = static_cast<Http2Upstream *>(user_data);
637 if (upstream->consume(stream_id, len) != 0) {
648 upstream->rst_stream(downstream, NGHTTP2_INTERNAL_ERROR);
651 if (upstream->consume(stream_id, len) != 0) {
665 if (get_config()->http2.upstream.debug.frame_debug) {
668 auto upstream = static_cast<Http2Upstream *>(user_data);
669 auto handler = upstream->get_client_handler();
690 ULOG(INFO, upstream)
697 upstream->rst_stream(downstream, NGHTTP2_NO_ERROR);
704 upstream->start_settings_timer();
717 upstream, handler->get_mcpool(), promised_stream_id);
772 upstream->add_pending_downstream(std::move(promised_downstream));
779 if (upstream->error_reply(ptr, 500) != 0) {
780 upstream->rst_stream(ptr, NGHTTP2_INTERNAL_ERROR);
787 upstream->start_downstream(ptr);
796 ULOG(INFO, upstream) << "Sending GOAWAY: last-stream-id="
812 auto upstream = static_cast<Http2Upstream *>(user_data);
814 ULOG(INFO, upstream) << "Failed to send control frame type="
826 upstream->rst_stream(downstream, NGHTTP2_INTERNAL_ERROR);
842 auto upstream = static_cast<Http2Upstream *>(downstream->get_upstream());
845 auto wb = upstream->get_response_buf();
873 auto max_buffer_size = upstream->get_max_buffer_size();
881 // NGHTTP2_REFUSED_STREAM is important because it tells upstream
895 auto upstream = static_cast<Http2Upstream *>(w->data);
896 auto handler = upstream->get_client_handler();
897 ULOG(INFO, upstream) << "SETTINGS timeout";
898 if (upstream->terminate_session(NGHTTP2_SETTINGS_TIMEOUT) != 0) {
908 auto upstream = static_cast<Http2Upstream *>(w->data);
909 auto handler = upstream->get_client_handler();
910 upstream->submit_goaway();
917 auto upstream = static_cast<Http2Upstream *>(w->data);
918 upstream->check_shutdown();
1002 if (config->http2.upstream.debug.frame_debug) {
1038 nghttp2_session_server_new2(&session_, http2conf.upstream.callbacks, this,
1040 ? http2conf.upstream.alt_mode_option
1041 : http2conf.upstream.option);
1052 entry[0].value = http2conf.upstream.max_concurrent_streams;
1058 entry[1].value = http2conf.upstream.window_size;
1070 if (http2conf.upstream.decoder_dynamic_table_size !=
1073 entry[nentry].value = http2conf.upstream.decoder_dynamic_table_size;
1086 : http2conf.upstream.optimize_window_size
1087 ? std::min(http2conf.upstream.connection_window_size,
1089 : http2conf.upstream.connection_window_size;
1102 http2conf.upstream.timeout.settings, 0.);
1116 if (http2conf.upstream.optimize_write_buffer_size) {
1135 config->conn.upstream.timeout.http2_read);
1187 if ((http2conf.upstream.optimize_write_buffer_size ||
1188 http2conf.upstream.optimize_window_size) &&
1194 if (http2conf.upstream.optimize_write_buffer_size) {
1198 if (http2conf.upstream.optimize_window_size) {
1201 auto window_size = std::min(http2conf.upstream.connection_window_size,
1255 // RST_STREAM to the upstream and delete downstream connection
1448 auto upstream = static_cast<Http2Upstream *>(user_data);
1454 auto max_buffer_size = upstream->get_max_buffer_size();
1456 auto buffer = upstream->get_response_buf();
1461 ULOG(INFO, upstream) << "Buffer is almost full. Skip write DATA";
1856 if (http2conf.upstream.debug.dump.response_header) {
1857 http2::dump_nv(http2conf.upstream.debug.dump.response_header, nva.data(),