Lines Matching refs:req_
121 req_(balloc_),
314 for (auto &kv : req_.fs.headers()) {
325 for (auto &kv : req_.fs.headers()) {
354 for (auto &kv : req_.fs.headers()) {
398 for (auto &kv : req_.fs.headers()) {
418 for (auto &kv : req_.fs.headers()) {
664 req_.recv_body_length += datalen;
668 req_.unconsumed_body_length += datalen;
682 req_.unconsumed_body_length += datalen;
706 if (request_downstream_host_.empty() || req_.authority.empty()) {
718 req_.authority, upstream_scheme);
762 if (req_.fs.content_length == -1) {
766 if (req_.fs.content_length != req_.recv_body_length) {
769 << req_.fs.content_length
770 << ", received=" << req_.recv_body_length;
796 // This handles nonzero req_.connect_proto and h1 frontend requests
798 upgraded_ = (req_.method == HTTP_CONNECT ||
799 req_.connect_proto == ConnectProto::WEBSOCKET) &&
804 if (req_.method == HTTP_CONNECT) {
805 if (req_.connect_proto == ConnectProto::WEBSOCKET) {
830 upgraded_ = req_.upgrade_request;
837 if (req_.method == HTTP_CONNECT) {
838 req_.upgrade_request = true;
843 if (req_.method == HTTP_CONNECT) {
844 req_.upgrade_request = true;
845 } else if (req_.http_minor > 0) {
846 auto upgrade = req_.fs.header(http2::HD_UPGRADE);
852 req_.http2_upgrade_seen = true;
854 req_.upgrade_request = true;
859 req_.connect_proto = ConnectProto::WEBSOCKET;
864 auto transfer_encoding = req_.fs.header(http2::HD_TRANSFER_ENCODING);
866 req_.fs.content_length = -1;
869 auto expect = req_.fs.header(http2::HD_EXPECT);
893 return req_.http_major == 3 || req_.http_major == 2 ||
894 (req_.http_major == 1 && req_.http_minor == 1);
900 return req_.http2_upgrade_seen && req_.fs.header(http2::HD_HTTP2_SETTINGS) &&
905 auto http2_settings = req_.fs.header(http2::HD_HTTP2_SETTINGS);
938 http2::expect_response_body(req_.method, resp_.http_status);