Home
last modified time | relevance | path

Searched refs:MSG_COMPLETE (Results 1 - 10 of 10) sorted by relevance

/third_party/nghttp2/src/
H A Dshrpx_https_upstream.cc494 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in htp_hdrs_completecb()
531 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in htp_hdrs_completecb()
570 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in htp_bodycb()
597 downstream->set_request_state(DownstreamState::MSG_COMPLETE); in htp_msg_completecb()
600 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in htp_msg_completecb()
704 downstream->get_request_state() == DownstreamState::MSG_COMPLETE && in on_read()
705 downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in on_read()
781 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in on_write()
791 if (downstream->get_request_state() == DownstreamState::MSG_COMPLETE) { in on_write()
910 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in downstream_eof()
[all...]
H A Dshrpx_http2_upstream.cc190 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in on_header_callback2()
315 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in on_request_headers()
445 downstream->set_request_state(DownstreamState::MSG_COMPLETE); in on_request_headers()
448 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in on_request_headers()
514 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in initiate_downstream()
566 if (downstream->get_response_state() != DownstreamState::MSG_COMPLETE) { in on_frame_recv_callback()
571 downstream->set_request_state(DownstreamState::MSG_COMPLETE); in on_frame_recv_callback()
595 if (downstream->get_response_state() != DownstreamState::MSG_COMPLETE) { in on_frame_recv_callback()
600 downstream->set_request_state(DownstreamState::MSG_COMPLETE); in on_frame_recv_callback()
647 if (downstream->get_response_state() != DownstreamState::MSG_COMPLETE) { in on_data_chunk_recv_callback()
[all...]
H A Dshrpx_http3_upstream.cc1142 downstream->set_response_state(DownstreamState::MSG_COMPLETE); in downstream_eof()
1144 // For tunneled connection, MSG_COMPLETE signals in downstream_eof()
1152 DownstreamState::MSG_COMPLETE) { in downstream_eof()
1153 // If stream was not closed, then we set MSG_COMPLETE and let in downstream_eof()
1184 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in downstream_error()
1215 downstream->set_response_state(DownstreamState::MSG_COMPLETE); in downstream_error()
1239 if (downstream->get_response_state() != DownstreamState::MSG_COMPLETE && in downstream_read_data_callback()
1249 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE && in downstream_read_data_callback()
1305 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in on_downstream_header_complete()
1321 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in on_downstream_header_complete()
[all...]
H A Dshrpx_mruby.cc86 if (downstream->get_response_state() != DownstreamState::MSG_COMPLETE) { in run_app()
H A Dshrpx_http2_downstream_connection.cc148 case DownstreamState::MSG_COMPLETE: in submit_rst_stream()
191 downstream->get_request_state() == DownstreamState::MSG_COMPLETE && in http2_data_read_callback()
193 // will set MSG_COMPLETE to request state after upgrade response in http2_data_read_callback()
587 // on_stream_close_callback. Before that, after MSG_COMPLETE is set in attach_stream_data()
H A Dshrpx_mruby_module_response.cc212 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in response_return()
286 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in response_send_info()
H A Dshrpx_http2_session.cc859 // MSG_COMPLETE here. Upstream will take care of that. in on_stream_close_callback()
861 downstream->set_response_state(DownstreamState::MSG_COMPLETE); in on_stream_close_callback()
864 case DownstreamState::MSG_COMPLETE: in on_stream_close_callback()
1208 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) { in on_response_headers()
1249 downstream->set_response_state(DownstreamState::MSG_COMPLETE); in on_frame_recv_callback()
1292 downstream->set_response_state(DownstreamState::MSG_COMPLETE); in on_frame_recv_callback()
2301 promised_downstream->set_request_state(DownstreamState::MSG_COMPLETE); in handle_downstream_push_promise_complete()
H A Dshrpx_downstream.h304 MSG_COMPLETE, member in shrpx::DownstreamState
H A Dshrpx_downstream.cc1089 request_state_ == DownstreamState::MSG_COMPLETE) && in request_submission_ready()
1115 return dconn_ && response_state_ == DownstreamState::MSG_COMPLETE && in can_detach_downstream_connection()
1116 request_state_ == DownstreamState::MSG_COMPLETE && !upgraded_ && in can_detach_downstream_connection()
H A Dshrpx_http_downstream_connection.cc1196 downstream->set_response_state(DownstreamState::MSG_COMPLETE); in htp_msg_completecb()
1502 if (downstream_->get_response_state() == DownstreamState::MSG_COMPLETE) { in process_input()

Completed in 17 milliseconds