walkero
/
nghttp2
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

nghttpx: Use error_reply instead of RST_STREAM for http2 upstream request

This commit is contained in:
Tatsuhiro Tsujikawa 2014-07-03 00:12:16 +09:00
parent 93b3a44fb5
commit 9cddb05f54
1 changed files with 31 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/shrpx_http2_upstream.cc
View File

@ -298,7 +298,10 @@ int on_request_headers(Http2Upstream *upstream,
} }
if(!http2::check_http2_headers(nva)) { if(!http2::check_http2_headers(nva)) {
if(upstream->error_reply(downstream, 400) != 0) {
upstream->rst_stream(downstream, NGHTTP2_PROTOCOL_ERROR); upstream->rst_stream(downstream, NGHTTP2_PROTOCOL_ERROR);
}
return 0; return 0;
} }
@ -314,7 +317,11 @@ int on_request_headers(Http2Upstream *upstream,
if(is_connect) { if(is_connect) {
// Here we strictly require :authority header field. // Here we strictly require :authority header field.
if(scheme || path || !having_authority) { if(scheme || path || !having_authority) {
if(upstream->error_reply(downstream, 400) != 0) {
upstream->rst_stream(downstream, NGHTTP2_PROTOCOL_ERROR); upstream->rst_stream(downstream, NGHTTP2_PROTOCOL_ERROR);
}
return 0; return 0;
} }
} else { } else {
@ -325,7 +332,11 @@ int on_request_headers(Http2Upstream *upstream,
(get_config()->http2_proxy && !having_authority) || (get_config()->http2_proxy && !having_authority) ||
(!get_config()->http2_proxy && !having_authority && !having_host) || (!get_config()->http2_proxy && !having_authority && !having_host) ||
!http2::non_empty_value(path)) { !http2::non_empty_value(path)) {
if(upstream->error_reply(downstream, 400) != 0) {
upstream->rst_stream(downstream, NGHTTP2_PROTOCOL_ERROR); upstream->rst_stream(downstream, NGHTTP2_PROTOCOL_ERROR);
}
return 0; return 0;
} }
} }
@ -333,9 +344,13 @@ int on_request_headers(Http2Upstream *upstream,
(frame->hd.flags & NGHTTP2_FLAG_END_STREAM) == 0) { (frame->hd.flags & NGHTTP2_FLAG_END_STREAM) == 0) {
auto content_length = http2::get_header(nva, "content-length"); auto content_length = http2::get_header(nva, "content-length");
if(!content_length || http2::value_lws(content_length)) { if(!content_length || http2::value_lws(content_length)) {
// If content-length is missing,
// Downstream::push_upload_data_chunk will fail and // TODO We still need content-length here?
if(upstream->error_reply(downstream, 400) != 0) {
upstream->rst_stream(downstream, NGHTTP2_PROTOCOL_ERROR); upstream->rst_stream(downstream, NGHTTP2_PROTOCOL_ERROR);
}
return 0; return 0;
} }
} }
@ -350,14 +365,21 @@ int on_request_headers(Http2Upstream *upstream,
auto dconn = upstream->get_client_handler()->get_downstream_connection(); auto dconn = upstream->get_client_handler()->get_downstream_connection();
rv = dconn->attach_downstream(downstream); rv = dconn->attach_downstream(downstream);
if(rv != 0) { if(rv != 0) {
// If downstream connection fails, issue RST_STREAM. // downstream connection fails, send error page
if(upstream->error_reply(downstream, 503) != 0) {
upstream->rst_stream(downstream, NGHTTP2_INTERNAL_ERROR); upstream->rst_stream(downstream, NGHTTP2_INTERNAL_ERROR);
}
downstream->set_request_state(Downstream::CONNECT_FAIL); downstream->set_request_state(Downstream::CONNECT_FAIL);
return 0; return 0;
} }
rv = downstream->push_request_headers(); rv = downstream->push_request_headers();
if(rv != 0) { if(rv != 0) {
if(upstream->error_reply(downstream, 503) != 0) {
upstream->rst_stream(downstream, NGHTTP2_INTERNAL_ERROR); upstream->rst_stream(downstream, NGHTTP2_INTERNAL_ERROR);
}
return 0; return 0;
} }
downstream->set_request_state(Downstream::HEADER_COMPLETE); downstream->set_request_state(Downstream::HEADER_COMPLETE);