| Index: net/http/http_response_headers.cc
|
| diff --git a/net/http/http_response_headers.cc b/net/http/http_response_headers.cc
|
| deleted file mode 100644
|
| index 3aef42a6b17a724925dbb23a71a341d7e903826e..0000000000000000000000000000000000000000
|
| --- a/net/http/http_response_headers.cc
|
| +++ /dev/null
|
| @@ -1,1452 +0,0 @@
|
| -// Copyright (c) 2012 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -// The rules for header parsing were borrowed from Firefox:
|
| -// http://lxr.mozilla.org/seamonkey/source/netwerk/protocol/http/src/nsHttpResponseHead.cpp
|
| -// The rules for parsing content-types were also borrowed from Firefox:
|
| -// http://lxr.mozilla.org/mozilla/source/netwerk/base/src/nsURLHelper.cpp#834
|
| -
|
| -#include "net/http/http_response_headers.h"
|
| -
|
| -#include <algorithm>
|
| -
|
| -#include "base/format_macros.h"
|
| -#include "base/logging.h"
|
| -#include "base/metrics/histogram.h"
|
| -#include "base/pickle.h"
|
| -#include "base/strings/string_number_conversions.h"
|
| -#include "base/strings/string_piece.h"
|
| -#include "base/strings/string_util.h"
|
| -#include "base/strings/stringprintf.h"
|
| -#include "base/time/time.h"
|
| -#include "base/values.h"
|
| -#include "net/base/escape.h"
|
| -#include "net/http/http_byte_range.h"
|
| -#include "net/http/http_log_util.h"
|
| -#include "net/http/http_util.h"
|
| -
|
| -using base::StringPiece;
|
| -using base::Time;
|
| -using base::TimeDelta;
|
| -
|
| -namespace net {
|
| -
|
| -//-----------------------------------------------------------------------------
|
| -
|
| -namespace {
|
| -
|
| -// These headers are RFC 2616 hop-by-hop headers;
|
| -// not to be stored by caches.
|
| -const char* const kHopByHopResponseHeaders[] = {
|
| - "connection",
|
| - "proxy-connection",
|
| - "keep-alive",
|
| - "trailer",
|
| - "transfer-encoding",
|
| - "upgrade"
|
| -};
|
| -
|
| -// These headers are challenge response headers;
|
| -// not to be stored by caches.
|
| -const char* const kChallengeResponseHeaders[] = {
|
| - "www-authenticate",
|
| - "proxy-authenticate"
|
| -};
|
| -
|
| -// These headers are cookie setting headers;
|
| -// not to be stored by caches or disclosed otherwise.
|
| -const char* const kCookieResponseHeaders[] = {
|
| - "set-cookie",
|
| - "set-cookie2"
|
| -};
|
| -
|
| -// By default, do not cache Strict-Transport-Security or Public-Key-Pins.
|
| -// This avoids erroneously re-processing them on page loads from cache ---
|
| -// they are defined to be valid only on live and error-free HTTPS
|
| -// connections.
|
| -const char* const kSecurityStateHeaders[] = {
|
| - "strict-transport-security",
|
| - "public-key-pins"
|
| -};
|
| -
|
| -// These response headers are not copied from a 304/206 response to the cached
|
| -// response headers. This list is based on Mozilla's nsHttpResponseHead.cpp.
|
| -const char* const kNonUpdatedHeaders[] = {
|
| - "connection",
|
| - "proxy-connection",
|
| - "keep-alive",
|
| - "www-authenticate",
|
| - "proxy-authenticate",
|
| - "trailer",
|
| - "transfer-encoding",
|
| - "upgrade",
|
| - "etag",
|
| - "x-frame-options",
|
| - "x-xss-protection",
|
| -};
|
| -
|
| -// Some header prefixes mean "Don't copy this header from a 304 response.".
|
| -// Rather than listing all the relevant headers, we can consolidate them into
|
| -// this list:
|
| -const char* const kNonUpdatedHeaderPrefixes[] = {
|
| - "content-",
|
| - "x-content-",
|
| - "x-webkit-"
|
| -};
|
| -
|
| -bool ShouldUpdateHeader(const std::string::const_iterator& name_begin,
|
| - const std::string::const_iterator& name_end) {
|
| - for (size_t i = 0; i < arraysize(kNonUpdatedHeaders); ++i) {
|
| - if (LowerCaseEqualsASCII(name_begin, name_end, kNonUpdatedHeaders[i]))
|
| - return false;
|
| - }
|
| - for (size_t i = 0; i < arraysize(kNonUpdatedHeaderPrefixes); ++i) {
|
| - if (StartsWithASCII(std::string(name_begin, name_end),
|
| - kNonUpdatedHeaderPrefixes[i], false))
|
| - return false;
|
| - }
|
| - return true;
|
| -}
|
| -
|
| -void CheckDoesNotHaveEmbededNulls(const std::string& str) {
|
| - // Care needs to be taken when adding values to the raw headers string to
|
| - // make sure it does not contain embeded NULLs. Any embeded '\0' may be
|
| - // understood as line terminators and change how header lines get tokenized.
|
| - CHECK(str.find('\0') == std::string::npos);
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -const char HttpResponseHeaders::kContentRange[] = "Content-Range";
|
| -
|
| -struct HttpResponseHeaders::ParsedHeader {
|
| - // A header "continuation" contains only a subsequent value for the
|
| - // preceding header. (Header values are comma separated.)
|
| - bool is_continuation() const { return name_begin == name_end; }
|
| -
|
| - std::string::const_iterator name_begin;
|
| - std::string::const_iterator name_end;
|
| - std::string::const_iterator value_begin;
|
| - std::string::const_iterator value_end;
|
| -};
|
| -
|
| -//-----------------------------------------------------------------------------
|
| -
|
| -HttpResponseHeaders::HttpResponseHeaders(const std::string& raw_input)
|
| - : response_code_(-1) {
|
| - Parse(raw_input);
|
| -
|
| - // The most important thing to do with this histogram is find out
|
| - // the existence of unusual HTTP status codes. As it happens
|
| - // right now, there aren't double-constructions of response headers
|
| - // using this constructor, so our counts should also be accurate,
|
| - // without instantiating the histogram in two places. It is also
|
| - // important that this histogram not collect data in the other
|
| - // constructor, which rebuilds an histogram from a pickle, since
|
| - // that would actually create a double call between the original
|
| - // HttpResponseHeader that was serialized, and initialization of the
|
| - // new object from that pickle.
|
| - UMA_HISTOGRAM_CUSTOM_ENUMERATION("Net.HttpResponseCode",
|
| - HttpUtil::MapStatusCodeForHistogram(
|
| - response_code_),
|
| - // Note the third argument is only
|
| - // evaluated once, see macro
|
| - // definition for details.
|
| - HttpUtil::GetStatusCodesForHistogram());
|
| -}
|
| -
|
| -HttpResponseHeaders::HttpResponseHeaders(PickleIterator* iter)
|
| - : response_code_(-1) {
|
| - std::string raw_input;
|
| - if (iter->ReadString(&raw_input))
|
| - Parse(raw_input);
|
| -}
|
| -
|
| -void HttpResponseHeaders::Persist(Pickle* pickle, PersistOptions options) {
|
| - if (options == PERSIST_RAW) {
|
| - pickle->WriteString(raw_headers_);
|
| - return; // Done.
|
| - }
|
| -
|
| - HeaderSet filter_headers;
|
| -
|
| - // Construct set of headers to filter out based on options.
|
| - if ((options & PERSIST_SANS_NON_CACHEABLE) == PERSIST_SANS_NON_CACHEABLE)
|
| - AddNonCacheableHeaders(&filter_headers);
|
| -
|
| - if ((options & PERSIST_SANS_COOKIES) == PERSIST_SANS_COOKIES)
|
| - AddCookieHeaders(&filter_headers);
|
| -
|
| - if ((options & PERSIST_SANS_CHALLENGES) == PERSIST_SANS_CHALLENGES)
|
| - AddChallengeHeaders(&filter_headers);
|
| -
|
| - if ((options & PERSIST_SANS_HOP_BY_HOP) == PERSIST_SANS_HOP_BY_HOP)
|
| - AddHopByHopHeaders(&filter_headers);
|
| -
|
| - if ((options & PERSIST_SANS_RANGES) == PERSIST_SANS_RANGES)
|
| - AddHopContentRangeHeaders(&filter_headers);
|
| -
|
| - if ((options & PERSIST_SANS_SECURITY_STATE) == PERSIST_SANS_SECURITY_STATE)
|
| - AddSecurityStateHeaders(&filter_headers);
|
| -
|
| - std::string blob;
|
| - blob.reserve(raw_headers_.size());
|
| -
|
| - // This copies the status line w/ terminator null.
|
| - // Note raw_headers_ has embedded nulls instead of \n,
|
| - // so this just copies the first header line.
|
| - blob.assign(raw_headers_.c_str(), strlen(raw_headers_.c_str()) + 1);
|
| -
|
| - for (size_t i = 0; i < parsed_.size(); ++i) {
|
| - DCHECK(!parsed_[i].is_continuation());
|
| -
|
| - // Locate the start of the next header.
|
| - size_t k = i;
|
| - while (++k < parsed_.size() && parsed_[k].is_continuation()) {}
|
| - --k;
|
| -
|
| - std::string header_name(parsed_[i].name_begin, parsed_[i].name_end);
|
| - base::StringToLowerASCII(&header_name);
|
| -
|
| - if (filter_headers.find(header_name) == filter_headers.end()) {
|
| - // Make sure there is a null after the value.
|
| - blob.append(parsed_[i].name_begin, parsed_[k].value_end);
|
| - blob.push_back('\0');
|
| - }
|
| -
|
| - i = k;
|
| - }
|
| - blob.push_back('\0');
|
| -
|
| - pickle->WriteString(blob);
|
| -}
|
| -
|
| -void HttpResponseHeaders::Update(const HttpResponseHeaders& new_headers) {
|
| - DCHECK(new_headers.response_code() == 304 ||
|
| - new_headers.response_code() == 206);
|
| -
|
| - // Copy up to the null byte. This just copies the status line.
|
| - std::string new_raw_headers(raw_headers_.c_str());
|
| - new_raw_headers.push_back('\0');
|
| -
|
| - HeaderSet updated_headers;
|
| -
|
| - // NOTE: we write the new headers then the old headers for convenience. The
|
| - // order should not matter.
|
| -
|
| - // Figure out which headers we want to take from new_headers:
|
| - for (size_t i = 0; i < new_headers.parsed_.size(); ++i) {
|
| - const HeaderList& new_parsed = new_headers.parsed_;
|
| -
|
| - DCHECK(!new_parsed[i].is_continuation());
|
| -
|
| - // Locate the start of the next header.
|
| - size_t k = i;
|
| - while (++k < new_parsed.size() && new_parsed[k].is_continuation()) {}
|
| - --k;
|
| -
|
| - const std::string::const_iterator& name_begin = new_parsed[i].name_begin;
|
| - const std::string::const_iterator& name_end = new_parsed[i].name_end;
|
| - if (ShouldUpdateHeader(name_begin, name_end)) {
|
| - std::string name(name_begin, name_end);
|
| - base::StringToLowerASCII(&name);
|
| - updated_headers.insert(name);
|
| -
|
| - // Preserve this header line in the merged result, making sure there is
|
| - // a null after the value.
|
| - new_raw_headers.append(name_begin, new_parsed[k].value_end);
|
| - new_raw_headers.push_back('\0');
|
| - }
|
| -
|
| - i = k;
|
| - }
|
| -
|
| - // Now, build the new raw headers.
|
| - MergeWithHeaders(new_raw_headers, updated_headers);
|
| -}
|
| -
|
| -void HttpResponseHeaders::MergeWithHeaders(const std::string& raw_headers,
|
| - const HeaderSet& headers_to_remove) {
|
| - std::string new_raw_headers(raw_headers);
|
| - for (size_t i = 0; i < parsed_.size(); ++i) {
|
| - DCHECK(!parsed_[i].is_continuation());
|
| -
|
| - // Locate the start of the next header.
|
| - size_t k = i;
|
| - while (++k < parsed_.size() && parsed_[k].is_continuation()) {}
|
| - --k;
|
| -
|
| - std::string name(parsed_[i].name_begin, parsed_[i].name_end);
|
| - base::StringToLowerASCII(&name);
|
| - if (headers_to_remove.find(name) == headers_to_remove.end()) {
|
| - // It's ok to preserve this header in the final result.
|
| - new_raw_headers.append(parsed_[i].name_begin, parsed_[k].value_end);
|
| - new_raw_headers.push_back('\0');
|
| - }
|
| -
|
| - i = k;
|
| - }
|
| - new_raw_headers.push_back('\0');
|
| -
|
| - // Make this object hold the new data.
|
| - raw_headers_.clear();
|
| - parsed_.clear();
|
| - Parse(new_raw_headers);
|
| -}
|
| -
|
| -void HttpResponseHeaders::RemoveHeader(const std::string& name) {
|
| - // Copy up to the null byte. This just copies the status line.
|
| - std::string new_raw_headers(raw_headers_.c_str());
|
| - new_raw_headers.push_back('\0');
|
| -
|
| - std::string lowercase_name(name);
|
| - base::StringToLowerASCII(&lowercase_name);
|
| - HeaderSet to_remove;
|
| - to_remove.insert(lowercase_name);
|
| - MergeWithHeaders(new_raw_headers, to_remove);
|
| -}
|
| -
|
| -void HttpResponseHeaders::RemoveHeaderLine(const std::string& name,
|
| - const std::string& value) {
|
| - std::string name_lowercase(name);
|
| - base::StringToLowerASCII(&name_lowercase);
|
| -
|
| - std::string new_raw_headers(GetStatusLine());
|
| - new_raw_headers.push_back('\0');
|
| -
|
| - new_raw_headers.reserve(raw_headers_.size());
|
| -
|
| - void* iter = NULL;
|
| - std::string old_header_name;
|
| - std::string old_header_value;
|
| - while (EnumerateHeaderLines(&iter, &old_header_name, &old_header_value)) {
|
| - std::string old_header_name_lowercase(name);
|
| - base::StringToLowerASCII(&old_header_name_lowercase);
|
| -
|
| - if (name_lowercase == old_header_name_lowercase &&
|
| - value == old_header_value)
|
| - continue;
|
| -
|
| - new_raw_headers.append(old_header_name);
|
| - new_raw_headers.push_back(':');
|
| - new_raw_headers.push_back(' ');
|
| - new_raw_headers.append(old_header_value);
|
| - new_raw_headers.push_back('\0');
|
| - }
|
| - new_raw_headers.push_back('\0');
|
| -
|
| - // Make this object hold the new data.
|
| - raw_headers_.clear();
|
| - parsed_.clear();
|
| - Parse(new_raw_headers);
|
| -}
|
| -
|
| -void HttpResponseHeaders::AddHeader(const std::string& header) {
|
| - CheckDoesNotHaveEmbededNulls(header);
|
| - DCHECK_EQ('\0', raw_headers_[raw_headers_.size() - 2]);
|
| - DCHECK_EQ('\0', raw_headers_[raw_headers_.size() - 1]);
|
| - // Don't copy the last null.
|
| - std::string new_raw_headers(raw_headers_, 0, raw_headers_.size() - 1);
|
| - new_raw_headers.append(header);
|
| - new_raw_headers.push_back('\0');
|
| - new_raw_headers.push_back('\0');
|
| -
|
| - // Make this object hold the new data.
|
| - raw_headers_.clear();
|
| - parsed_.clear();
|
| - Parse(new_raw_headers);
|
| -}
|
| -
|
| -void HttpResponseHeaders::ReplaceStatusLine(const std::string& new_status) {
|
| - CheckDoesNotHaveEmbededNulls(new_status);
|
| - // Copy up to the null byte. This just copies the status line.
|
| - std::string new_raw_headers(new_status);
|
| - new_raw_headers.push_back('\0');
|
| -
|
| - HeaderSet empty_to_remove;
|
| - MergeWithHeaders(new_raw_headers, empty_to_remove);
|
| -}
|
| -
|
| -void HttpResponseHeaders::UpdateWithNewRange(
|
| - const HttpByteRange& byte_range,
|
| - int64 resource_size,
|
| - bool replace_status_line) {
|
| - DCHECK(byte_range.IsValid());
|
| - DCHECK(byte_range.HasFirstBytePosition());
|
| - DCHECK(byte_range.HasLastBytePosition());
|
| -
|
| - const char kLengthHeader[] = "Content-Length";
|
| - const char kRangeHeader[] = "Content-Range";
|
| -
|
| - RemoveHeader(kLengthHeader);
|
| - RemoveHeader(kRangeHeader);
|
| -
|
| - int64 start = byte_range.first_byte_position();
|
| - int64 end = byte_range.last_byte_position();
|
| - int64 range_len = end - start + 1;
|
| -
|
| - if (replace_status_line)
|
| - ReplaceStatusLine("HTTP/1.1 206 Partial Content");
|
| -
|
| - AddHeader(base::StringPrintf("%s: bytes %" PRId64 "-%" PRId64 "/%" PRId64,
|
| - kRangeHeader, start, end, resource_size));
|
| - AddHeader(base::StringPrintf("%s: %" PRId64, kLengthHeader, range_len));
|
| -}
|
| -
|
| -void HttpResponseHeaders::Parse(const std::string& raw_input) {
|
| - raw_headers_.reserve(raw_input.size());
|
| -
|
| - // ParseStatusLine adds a normalized status line to raw_headers_
|
| - std::string::const_iterator line_begin = raw_input.begin();
|
| - std::string::const_iterator line_end =
|
| - std::find(line_begin, raw_input.end(), '\0');
|
| - // has_headers = true, if there is any data following the status line.
|
| - // Used by ParseStatusLine() to decide if a HTTP/0.9 is really a HTTP/1.0.
|
| - bool has_headers = (line_end != raw_input.end() &&
|
| - (line_end + 1) != raw_input.end() &&
|
| - *(line_end + 1) != '\0');
|
| - ParseStatusLine(line_begin, line_end, has_headers);
|
| - raw_headers_.push_back('\0'); // Terminate status line with a null.
|
| -
|
| - if (line_end == raw_input.end()) {
|
| - raw_headers_.push_back('\0'); // Ensure the headers end with a double null.
|
| -
|
| - DCHECK_EQ('\0', raw_headers_[raw_headers_.size() - 2]);
|
| - DCHECK_EQ('\0', raw_headers_[raw_headers_.size() - 1]);
|
| - return;
|
| - }
|
| -
|
| - // Including a terminating null byte.
|
| - size_t status_line_len = raw_headers_.size();
|
| -
|
| - // Now, we add the rest of the raw headers to raw_headers_, and begin parsing
|
| - // it (to populate our parsed_ vector).
|
| - raw_headers_.append(line_end + 1, raw_input.end());
|
| -
|
| - // Ensure the headers end with a double null.
|
| - while (raw_headers_.size() < 2 ||
|
| - raw_headers_[raw_headers_.size() - 2] != '\0' ||
|
| - raw_headers_[raw_headers_.size() - 1] != '\0') {
|
| - raw_headers_.push_back('\0');
|
| - }
|
| -
|
| - // Adjust to point at the null byte following the status line
|
| - line_end = raw_headers_.begin() + status_line_len - 1;
|
| -
|
| - HttpUtil::HeadersIterator headers(line_end + 1, raw_headers_.end(),
|
| - std::string(1, '\0'));
|
| - while (headers.GetNext()) {
|
| - AddHeader(headers.name_begin(),
|
| - headers.name_end(),
|
| - headers.values_begin(),
|
| - headers.values_end());
|
| - }
|
| -
|
| - DCHECK_EQ('\0', raw_headers_[raw_headers_.size() - 2]);
|
| - DCHECK_EQ('\0', raw_headers_[raw_headers_.size() - 1]);
|
| -}
|
| -
|
| -// Append all of our headers to the final output string.
|
| -void HttpResponseHeaders::GetNormalizedHeaders(std::string* output) const {
|
| - // copy up to the null byte. this just copies the status line.
|
| - output->assign(raw_headers_.c_str());
|
| -
|
| - // headers may appear multiple times (not necessarily in succession) in the
|
| - // header data, so we build a map from header name to generated header lines.
|
| - // to preserve the order of the original headers, the actual values are kept
|
| - // in a separate list. finally, the list of headers is flattened to form
|
| - // the normalized block of headers.
|
| - //
|
| - // NOTE: We take special care to preserve the whitespace around any commas
|
| - // that may occur in the original response headers. Because our consumer may
|
| - // be a web app, we cannot be certain of the semantics of commas despite the
|
| - // fact that RFC 2616 says that they should be regarded as value separators.
|
| - //
|
| - typedef base::hash_map<std::string, size_t> HeadersMap;
|
| - HeadersMap headers_map;
|
| - HeadersMap::iterator iter = headers_map.end();
|
| -
|
| - std::vector<std::string> headers;
|
| -
|
| - for (size_t i = 0; i < parsed_.size(); ++i) {
|
| - DCHECK(!parsed_[i].is_continuation());
|
| -
|
| - std::string name(parsed_[i].name_begin, parsed_[i].name_end);
|
| - std::string lower_name = base::StringToLowerASCII(name);
|
| -
|
| - iter = headers_map.find(lower_name);
|
| - if (iter == headers_map.end()) {
|
| - iter = headers_map.insert(
|
| - HeadersMap::value_type(lower_name, headers.size())).first;
|
| - headers.push_back(name + ": ");
|
| - } else {
|
| - headers[iter->second].append(", ");
|
| - }
|
| -
|
| - std::string::const_iterator value_begin = parsed_[i].value_begin;
|
| - std::string::const_iterator value_end = parsed_[i].value_end;
|
| - while (++i < parsed_.size() && parsed_[i].is_continuation())
|
| - value_end = parsed_[i].value_end;
|
| - --i;
|
| -
|
| - headers[iter->second].append(value_begin, value_end);
|
| - }
|
| -
|
| - for (size_t i = 0; i < headers.size(); ++i) {
|
| - output->push_back('\n');
|
| - output->append(headers[i]);
|
| - }
|
| -
|
| - output->push_back('\n');
|
| -}
|
| -
|
| -bool HttpResponseHeaders::GetNormalizedHeader(const std::string& name,
|
| - std::string* value) const {
|
| - // If you hit this assertion, please use EnumerateHeader instead!
|
| - DCHECK(!HttpUtil::IsNonCoalescingHeader(name));
|
| -
|
| - value->clear();
|
| -
|
| - bool found = false;
|
| - size_t i = 0;
|
| - while (i < parsed_.size()) {
|
| - i = FindHeader(i, name);
|
| - if (i == std::string::npos)
|
| - break;
|
| -
|
| - found = true;
|
| -
|
| - if (!value->empty())
|
| - value->append(", ");
|
| -
|
| - std::string::const_iterator value_begin = parsed_[i].value_begin;
|
| - std::string::const_iterator value_end = parsed_[i].value_end;
|
| - while (++i < parsed_.size() && parsed_[i].is_continuation())
|
| - value_end = parsed_[i].value_end;
|
| - value->append(value_begin, value_end);
|
| - }
|
| -
|
| - return found;
|
| -}
|
| -
|
| -std::string HttpResponseHeaders::GetStatusLine() const {
|
| - // copy up to the null byte.
|
| - return std::string(raw_headers_.c_str());
|
| -}
|
| -
|
| -std::string HttpResponseHeaders::GetStatusText() const {
|
| - // GetStatusLine() is already normalized, so it has the format:
|
| - // <http_version> SP <response_code> SP <status_text>
|
| - std::string status_text = GetStatusLine();
|
| - std::string::const_iterator begin = status_text.begin();
|
| - std::string::const_iterator end = status_text.end();
|
| - for (int i = 0; i < 2; ++i)
|
| - begin = std::find(begin, end, ' ') + 1;
|
| - return std::string(begin, end);
|
| -}
|
| -
|
| -bool HttpResponseHeaders::EnumerateHeaderLines(void** iter,
|
| - std::string* name,
|
| - std::string* value) const {
|
| - size_t i = reinterpret_cast<size_t>(*iter);
|
| - if (i == parsed_.size())
|
| - return false;
|
| -
|
| - DCHECK(!parsed_[i].is_continuation());
|
| -
|
| - name->assign(parsed_[i].name_begin, parsed_[i].name_end);
|
| -
|
| - std::string::const_iterator value_begin = parsed_[i].value_begin;
|
| - std::string::const_iterator value_end = parsed_[i].value_end;
|
| - while (++i < parsed_.size() && parsed_[i].is_continuation())
|
| - value_end = parsed_[i].value_end;
|
| -
|
| - value->assign(value_begin, value_end);
|
| -
|
| - *iter = reinterpret_cast<void*>(i);
|
| - return true;
|
| -}
|
| -
|
| -bool HttpResponseHeaders::EnumerateHeader(void** iter,
|
| - const base::StringPiece& name,
|
| - std::string* value) const {
|
| - size_t i;
|
| - if (!iter || !*iter) {
|
| - i = FindHeader(0, name);
|
| - } else {
|
| - i = reinterpret_cast<size_t>(*iter);
|
| - if (i >= parsed_.size()) {
|
| - i = std::string::npos;
|
| - } else if (!parsed_[i].is_continuation()) {
|
| - i = FindHeader(i, name);
|
| - }
|
| - }
|
| -
|
| - if (i == std::string::npos) {
|
| - value->clear();
|
| - return false;
|
| - }
|
| -
|
| - if (iter)
|
| - *iter = reinterpret_cast<void*>(i + 1);
|
| - value->assign(parsed_[i].value_begin, parsed_[i].value_end);
|
| - return true;
|
| -}
|
| -
|
| -bool HttpResponseHeaders::HasHeaderValue(const base::StringPiece& name,
|
| - const base::StringPiece& value) const {
|
| - // The value has to be an exact match. This is important since
|
| - // 'cache-control: no-cache' != 'cache-control: no-cache="foo"'
|
| - void* iter = NULL;
|
| - std::string temp;
|
| - while (EnumerateHeader(&iter, name, &temp)) {
|
| - if (value.size() == temp.size() &&
|
| - std::equal(temp.begin(), temp.end(), value.begin(),
|
| - base::CaseInsensitiveCompare<char>()))
|
| - return true;
|
| - }
|
| - return false;
|
| -}
|
| -
|
| -bool HttpResponseHeaders::HasHeader(const base::StringPiece& name) const {
|
| - return FindHeader(0, name) != std::string::npos;
|
| -}
|
| -
|
| -HttpResponseHeaders::HttpResponseHeaders() : response_code_(-1) {
|
| -}
|
| -
|
| -HttpResponseHeaders::~HttpResponseHeaders() {
|
| -}
|
| -
|
| -// Note: this implementation implicitly assumes that line_end points at a valid
|
| -// sentinel character (such as '\0').
|
| -// static
|
| -HttpVersion HttpResponseHeaders::ParseVersion(
|
| - std::string::const_iterator line_begin,
|
| - std::string::const_iterator line_end) {
|
| - std::string::const_iterator p = line_begin;
|
| -
|
| - // RFC2616 sec 3.1: HTTP-Version = "HTTP" "/" 1*DIGIT "." 1*DIGIT
|
| - // TODO: (1*DIGIT apparently means one or more digits, but we only handle 1).
|
| - // TODO: handle leading zeros, which is allowed by the rfc1616 sec 3.1.
|
| -
|
| - if ((line_end - p < 4) || !LowerCaseEqualsASCII(p, p + 4, "http")) {
|
| - DVLOG(1) << "missing status line";
|
| - return HttpVersion();
|
| - }
|
| -
|
| - p += 4;
|
| -
|
| - if (p >= line_end || *p != '/') {
|
| - DVLOG(1) << "missing version";
|
| - return HttpVersion();
|
| - }
|
| -
|
| - std::string::const_iterator dot = std::find(p, line_end, '.');
|
| - if (dot == line_end) {
|
| - DVLOG(1) << "malformed version";
|
| - return HttpVersion();
|
| - }
|
| -
|
| - ++p; // from / to first digit.
|
| - ++dot; // from . to second digit.
|
| -
|
| - if (!(*p >= '0' && *p <= '9' && *dot >= '0' && *dot <= '9')) {
|
| - DVLOG(1) << "malformed version number";
|
| - return HttpVersion();
|
| - }
|
| -
|
| - uint16 major = *p - '0';
|
| - uint16 minor = *dot - '0';
|
| -
|
| - return HttpVersion(major, minor);
|
| -}
|
| -
|
| -// Note: this implementation implicitly assumes that line_end points at a valid
|
| -// sentinel character (such as '\0').
|
| -void HttpResponseHeaders::ParseStatusLine(
|
| - std::string::const_iterator line_begin,
|
| - std::string::const_iterator line_end,
|
| - bool has_headers) {
|
| - // Extract the version number
|
| - parsed_http_version_ = ParseVersion(line_begin, line_end);
|
| -
|
| - // Clamp the version number to one of: {0.9, 1.0, 1.1}
|
| - if (parsed_http_version_ == HttpVersion(0, 9) && !has_headers) {
|
| - http_version_ = HttpVersion(0, 9);
|
| - raw_headers_ = "HTTP/0.9";
|
| - } else if (parsed_http_version_ >= HttpVersion(1, 1)) {
|
| - http_version_ = HttpVersion(1, 1);
|
| - raw_headers_ = "HTTP/1.1";
|
| - } else {
|
| - // Treat everything else like HTTP 1.0
|
| - http_version_ = HttpVersion(1, 0);
|
| - raw_headers_ = "HTTP/1.0";
|
| - }
|
| - if (parsed_http_version_ != http_version_) {
|
| - DVLOG(1) << "assuming HTTP/" << http_version_.major_value() << "."
|
| - << http_version_.minor_value();
|
| - }
|
| -
|
| - // TODO(eroman): this doesn't make sense if ParseVersion failed.
|
| - std::string::const_iterator p = std::find(line_begin, line_end, ' ');
|
| -
|
| - if (p == line_end) {
|
| - DVLOG(1) << "missing response status; assuming 200 OK";
|
| - raw_headers_.append(" 200 OK");
|
| - response_code_ = 200;
|
| - return;
|
| - }
|
| -
|
| - // Skip whitespace.
|
| - while (*p == ' ')
|
| - ++p;
|
| -
|
| - std::string::const_iterator code = p;
|
| - while (*p >= '0' && *p <= '9')
|
| - ++p;
|
| -
|
| - if (p == code) {
|
| - DVLOG(1) << "missing response status number; assuming 200";
|
| - raw_headers_.append(" 200 OK");
|
| - response_code_ = 200;
|
| - return;
|
| - }
|
| - raw_headers_.push_back(' ');
|
| - raw_headers_.append(code, p);
|
| - raw_headers_.push_back(' ');
|
| - base::StringToInt(StringPiece(code, p), &response_code_);
|
| -
|
| - // Skip whitespace.
|
| - while (*p == ' ')
|
| - ++p;
|
| -
|
| - // Trim trailing whitespace.
|
| - while (line_end > p && line_end[-1] == ' ')
|
| - --line_end;
|
| -
|
| - if (p == line_end) {
|
| - DVLOG(1) << "missing response status text; assuming OK";
|
| - // Not super critical what we put here. Just use "OK"
|
| - // even if it isn't descriptive of response_code_.
|
| - raw_headers_.append("OK");
|
| - } else {
|
| - raw_headers_.append(p, line_end);
|
| - }
|
| -}
|
| -
|
| -size_t HttpResponseHeaders::FindHeader(size_t from,
|
| - const base::StringPiece& search) const {
|
| - for (size_t i = from; i < parsed_.size(); ++i) {
|
| - if (parsed_[i].is_continuation())
|
| - continue;
|
| - const std::string::const_iterator& name_begin = parsed_[i].name_begin;
|
| - const std::string::const_iterator& name_end = parsed_[i].name_end;
|
| - if (static_cast<size_t>(name_end - name_begin) == search.size() &&
|
| - std::equal(name_begin, name_end, search.begin(),
|
| - base::CaseInsensitiveCompare<char>()))
|
| - return i;
|
| - }
|
| -
|
| - return std::string::npos;
|
| -}
|
| -
|
| -bool HttpResponseHeaders::GetCacheControlDirective(const StringPiece& directive,
|
| - TimeDelta* result) const {
|
| - StringPiece name("cache-control");
|
| - std::string value;
|
| -
|
| - size_t directive_size = directive.size();
|
| -
|
| - void* iter = NULL;
|
| - while (EnumerateHeader(&iter, name, &value)) {
|
| - if (value.size() > directive_size + 1 &&
|
| - LowerCaseEqualsASCII(value.begin(),
|
| - value.begin() + directive_size,
|
| - directive.begin()) &&
|
| - value[directive_size] == '=') {
|
| - int64 seconds;
|
| - base::StringToInt64(
|
| - StringPiece(value.begin() + directive_size + 1, value.end()),
|
| - &seconds);
|
| - *result = TimeDelta::FromSeconds(seconds);
|
| - return true;
|
| - }
|
| - }
|
| -
|
| - return false;
|
| -}
|
| -
|
| -void HttpResponseHeaders::AddHeader(std::string::const_iterator name_begin,
|
| - std::string::const_iterator name_end,
|
| - std::string::const_iterator values_begin,
|
| - std::string::const_iterator values_end) {
|
| - // If the header can be coalesced, then we should split it up.
|
| - if (values_begin == values_end ||
|
| - HttpUtil::IsNonCoalescingHeader(name_begin, name_end)) {
|
| - AddToParsed(name_begin, name_end, values_begin, values_end);
|
| - } else {
|
| - HttpUtil::ValuesIterator it(values_begin, values_end, ',');
|
| - while (it.GetNext()) {
|
| - AddToParsed(name_begin, name_end, it.value_begin(), it.value_end());
|
| - // clobber these so that subsequent values are treated as continuations
|
| - name_begin = name_end = raw_headers_.end();
|
| - }
|
| - }
|
| -}
|
| -
|
| -void HttpResponseHeaders::AddToParsed(std::string::const_iterator name_begin,
|
| - std::string::const_iterator name_end,
|
| - std::string::const_iterator value_begin,
|
| - std::string::const_iterator value_end) {
|
| - ParsedHeader header;
|
| - header.name_begin = name_begin;
|
| - header.name_end = name_end;
|
| - header.value_begin = value_begin;
|
| - header.value_end = value_end;
|
| - parsed_.push_back(header);
|
| -}
|
| -
|
| -void HttpResponseHeaders::AddNonCacheableHeaders(HeaderSet* result) const {
|
| - // Add server specified transients. Any 'cache-control: no-cache="foo,bar"'
|
| - // headers present in the response specify additional headers that we should
|
| - // not store in the cache.
|
| - const char kCacheControl[] = "cache-control";
|
| - const char kPrefix[] = "no-cache=\"";
|
| - const size_t kPrefixLen = sizeof(kPrefix) - 1;
|
| -
|
| - std::string value;
|
| - void* iter = NULL;
|
| - while (EnumerateHeader(&iter, kCacheControl, &value)) {
|
| - // If the value is smaller than the prefix and a terminal quote, skip
|
| - // it.
|
| - if (value.size() <= kPrefixLen ||
|
| - value.compare(0, kPrefixLen, kPrefix) != 0) {
|
| - continue;
|
| - }
|
| - // if it doesn't end with a quote, then treat as malformed
|
| - if (value[value.size()-1] != '\"')
|
| - continue;
|
| -
|
| - // process the value as a comma-separated list of items. Each
|
| - // item can be wrapped by linear white space.
|
| - std::string::const_iterator item = value.begin() + kPrefixLen;
|
| - std::string::const_iterator end = value.end() - 1;
|
| - while (item != end) {
|
| - // Find the comma to compute the length of the current item,
|
| - // and the position of the next one.
|
| - std::string::const_iterator item_next = std::find(item, end, ',');
|
| - std::string::const_iterator item_end = end;
|
| - if (item_next != end) {
|
| - // Skip over comma for next position.
|
| - item_end = item_next;
|
| - item_next++;
|
| - }
|
| - // trim off leading and trailing whitespace in this item.
|
| - HttpUtil::TrimLWS(&item, &item_end);
|
| -
|
| - // assuming the header is not empty, lowercase and insert into set
|
| - if (item_end > item) {
|
| - std::string name(&*item, item_end - item);
|
| - base::StringToLowerASCII(&name);
|
| - result->insert(name);
|
| - }
|
| -
|
| - // Continue to next item.
|
| - item = item_next;
|
| - }
|
| - }
|
| -}
|
| -
|
| -void HttpResponseHeaders::AddHopByHopHeaders(HeaderSet* result) {
|
| - for (size_t i = 0; i < arraysize(kHopByHopResponseHeaders); ++i)
|
| - result->insert(std::string(kHopByHopResponseHeaders[i]));
|
| -}
|
| -
|
| -void HttpResponseHeaders::AddCookieHeaders(HeaderSet* result) {
|
| - for (size_t i = 0; i < arraysize(kCookieResponseHeaders); ++i)
|
| - result->insert(std::string(kCookieResponseHeaders[i]));
|
| -}
|
| -
|
| -void HttpResponseHeaders::AddChallengeHeaders(HeaderSet* result) {
|
| - for (size_t i = 0; i < arraysize(kChallengeResponseHeaders); ++i)
|
| - result->insert(std::string(kChallengeResponseHeaders[i]));
|
| -}
|
| -
|
| -void HttpResponseHeaders::AddHopContentRangeHeaders(HeaderSet* result) {
|
| - result->insert(kContentRange);
|
| -}
|
| -
|
| -void HttpResponseHeaders::AddSecurityStateHeaders(HeaderSet* result) {
|
| - for (size_t i = 0; i < arraysize(kSecurityStateHeaders); ++i)
|
| - result->insert(std::string(kSecurityStateHeaders[i]));
|
| -}
|
| -
|
| -void HttpResponseHeaders::GetMimeTypeAndCharset(std::string* mime_type,
|
| - std::string* charset) const {
|
| - mime_type->clear();
|
| - charset->clear();
|
| -
|
| - std::string name = "content-type";
|
| - std::string value;
|
| -
|
| - bool had_charset = false;
|
| -
|
| - void* iter = NULL;
|
| - while (EnumerateHeader(&iter, name, &value))
|
| - HttpUtil::ParseContentType(value, mime_type, charset, &had_charset, NULL);
|
| -}
|
| -
|
| -bool HttpResponseHeaders::GetMimeType(std::string* mime_type) const {
|
| - std::string unused;
|
| - GetMimeTypeAndCharset(mime_type, &unused);
|
| - return !mime_type->empty();
|
| -}
|
| -
|
| -bool HttpResponseHeaders::GetCharset(std::string* charset) const {
|
| - std::string unused;
|
| - GetMimeTypeAndCharset(&unused, charset);
|
| - return !charset->empty();
|
| -}
|
| -
|
| -bool HttpResponseHeaders::IsRedirect(std::string* location) const {
|
| - if (!IsRedirectResponseCode(response_code_))
|
| - return false;
|
| -
|
| - // If we lack a Location header, then we can't treat this as a redirect.
|
| - // We assume that the first non-empty location value is the target URL that
|
| - // we want to follow. TODO(darin): Is this consistent with other browsers?
|
| - size_t i = std::string::npos;
|
| - do {
|
| - i = FindHeader(++i, "location");
|
| - if (i == std::string::npos)
|
| - return false;
|
| - // If the location value is empty, then it doesn't count.
|
| - } while (parsed_[i].value_begin == parsed_[i].value_end);
|
| -
|
| - if (location) {
|
| - // Escape any non-ASCII characters to preserve them. The server should
|
| - // only be returning ASCII here, but for compat we need to do this.
|
| - *location = EscapeNonASCII(
|
| - std::string(parsed_[i].value_begin, parsed_[i].value_end));
|
| - }
|
| -
|
| - return true;
|
| -}
|
| -
|
| -// static
|
| -bool HttpResponseHeaders::IsRedirectResponseCode(int response_code) {
|
| - // Users probably want to see 300 (multiple choice) pages, so we don't count
|
| - // them as redirects that need to be followed.
|
| - return (response_code == 301 ||
|
| - response_code == 302 ||
|
| - response_code == 303 ||
|
| - response_code == 307 ||
|
| - response_code == 308);
|
| -}
|
| -
|
| -// From RFC 2616 section 13.2.4:
|
| -//
|
| -// The calculation to determine if a response has expired is quite simple:
|
| -//
|
| -// response_is_fresh = (freshness_lifetime > current_age)
|
| -//
|
| -// Of course, there are other factors that can force a response to always be
|
| -// validated or re-fetched.
|
| -//
|
| -// From RFC 5861 section 3, a stale response may be used while revalidation is
|
| -// performed in the background if
|
| -//
|
| -// freshness_lifetime + stale_while_revalidate > current_age
|
| -//
|
| -ValidationType HttpResponseHeaders::RequiresValidation(
|
| - const Time& request_time,
|
| - const Time& response_time,
|
| - const Time& current_time) const {
|
| - FreshnessLifetimes lifetimes = GetFreshnessLifetimes(response_time);
|
| - if (lifetimes.freshness == TimeDelta() && lifetimes.staleness == TimeDelta())
|
| - return VALIDATION_SYNCHRONOUS;
|
| -
|
| - TimeDelta age = GetCurrentAge(request_time, response_time, current_time);
|
| -
|
| - if (lifetimes.freshness > age)
|
| - return VALIDATION_NONE;
|
| -
|
| - if (lifetimes.freshness + lifetimes.staleness > age)
|
| - return VALIDATION_ASYNCHRONOUS;
|
| -
|
| - return VALIDATION_SYNCHRONOUS;
|
| -}
|
| -
|
| -// From RFC 2616 section 13.2.4:
|
| -//
|
| -// The max-age directive takes priority over Expires, so if max-age is present
|
| -// in a response, the calculation is simply:
|
| -//
|
| -// freshness_lifetime = max_age_value
|
| -//
|
| -// Otherwise, if Expires is present in the response, the calculation is:
|
| -//
|
| -// freshness_lifetime = expires_value - date_value
|
| -//
|
| -// Note that neither of these calculations is vulnerable to clock skew, since
|
| -// all of the information comes from the origin server.
|
| -//
|
| -// Also, if the response does have a Last-Modified time, the heuristic
|
| -// expiration value SHOULD be no more than some fraction of the interval since
|
| -// that time. A typical setting of this fraction might be 10%:
|
| -//
|
| -// freshness_lifetime = (date_value - last_modified_value) * 0.10
|
| -//
|
| -// If the stale-while-revalidate directive is present, then it is used to set
|
| -// the |staleness| time, unless it overridden by another directive.
|
| -//
|
| -HttpResponseHeaders::FreshnessLifetimes
|
| -HttpResponseHeaders::GetFreshnessLifetimes(const Time& response_time) const {
|
| - FreshnessLifetimes lifetimes;
|
| - // Check for headers that force a response to never be fresh. For backwards
|
| - // compat, we treat "Pragma: no-cache" as a synonym for "Cache-Control:
|
| - // no-cache" even though RFC 2616 does not specify it.
|
| - if (HasHeaderValue("cache-control", "no-cache") ||
|
| - HasHeaderValue("cache-control", "no-store") ||
|
| - HasHeaderValue("pragma", "no-cache") ||
|
| - // Vary: * is never usable: see RFC 2616 section 13.6.
|
| - HasHeaderValue("vary", "*")) {
|
| - return lifetimes;
|
| - }
|
| -
|
| - // Cache-Control directive must_revalidate overrides stale-while-revalidate.
|
| - bool must_revalidate = HasHeaderValue("cache-control", "must-revalidate");
|
| -
|
| - if (must_revalidate || !GetStaleWhileRevalidateValue(&lifetimes.staleness)) {
|
| - DCHECK_EQ(TimeDelta(), lifetimes.staleness);
|
| - }
|
| -
|
| - // NOTE: "Cache-Control: max-age" overrides Expires, so we only check the
|
| - // Expires header after checking for max-age in GetFreshnessLifetimes. This
|
| - // is important since "Expires: <date in the past>" means not fresh, but
|
| - // it should not trump a max-age value.
|
| - if (GetMaxAgeValue(&lifetimes.freshness))
|
| - return lifetimes;
|
| -
|
| - // If there is no Date header, then assume that the server response was
|
| - // generated at the time when we received the response.
|
| - Time date_value;
|
| - if (!GetDateValue(&date_value))
|
| - date_value = response_time;
|
| -
|
| - Time expires_value;
|
| - if (GetExpiresValue(&expires_value)) {
|
| - // The expires value can be a date in the past!
|
| - if (expires_value > date_value) {
|
| - lifetimes.freshness = expires_value - date_value;
|
| - return lifetimes;
|
| - }
|
| -
|
| - DCHECK_EQ(TimeDelta(), lifetimes.freshness);
|
| - return lifetimes;
|
| - }
|
| -
|
| - // From RFC 2616 section 13.4:
|
| - //
|
| - // A response received with a status code of 200, 203, 206, 300, 301 or 410
|
| - // MAY be stored by a cache and used in reply to a subsequent request,
|
| - // subject to the expiration mechanism, unless a cache-control directive
|
| - // prohibits caching.
|
| - // ...
|
| - // A response received with any other status code (e.g. status codes 302
|
| - // and 307) MUST NOT be returned in a reply to a subsequent request unless
|
| - // there are cache-control directives or another header(s) that explicitly
|
| - // allow it.
|
| - //
|
| - // From RFC 2616 section 14.9.4:
|
| - //
|
| - // When the must-revalidate directive is present in a response received by
|
| - // a cache, that cache MUST NOT use the entry after it becomes stale to
|
| - // respond to a subsequent request without first revalidating it with the
|
| - // origin server. (I.e., the cache MUST do an end-to-end revalidation every
|
| - // time, if, based solely on the origin server's Expires or max-age value,
|
| - // the cached response is stale.)
|
| - //
|
| - // https://datatracker.ietf.org/doc/draft-reschke-http-status-308/ is an
|
| - // experimental RFC that adds 308 permanent redirect as well, for which "any
|
| - // future references ... SHOULD use one of the returned URIs."
|
| - if ((response_code_ == 200 || response_code_ == 203 ||
|
| - response_code_ == 206) && !must_revalidate) {
|
| - // TODO(darin): Implement a smarter heuristic.
|
| - Time last_modified_value;
|
| - if (GetLastModifiedValue(&last_modified_value)) {
|
| - // The last-modified value can be a date in the future!
|
| - if (last_modified_value <= date_value) {
|
| - lifetimes.freshness = (date_value - last_modified_value) / 10;
|
| - return lifetimes;
|
| - }
|
| - }
|
| - }
|
| -
|
| - // These responses are implicitly fresh (unless otherwise overruled):
|
| - if (response_code_ == 300 || response_code_ == 301 || response_code_ == 308 ||
|
| - response_code_ == 410) {
|
| - lifetimes.freshness = TimeDelta::Max();
|
| - lifetimes.staleness = TimeDelta(); // It should never be stale.
|
| - return lifetimes;
|
| - }
|
| -
|
| - // Our heuristic freshness estimate for this resource is 0 seconds, in
|
| - // accordance with common browser behaviour. However, stale-while-revalidate
|
| - // may still apply.
|
| - DCHECK_EQ(TimeDelta(), lifetimes.freshness);
|
| - return lifetimes;
|
| -}
|
| -
|
| -// From RFC 2616 section 13.2.3:
|
| -//
|
| -// Summary of age calculation algorithm, when a cache receives a response:
|
| -//
|
| -// /*
|
| -// * age_value
|
| -// * is the value of Age: header received by the cache with
|
| -// * this response.
|
| -// * date_value
|
| -// * is the value of the origin server's Date: header
|
| -// * request_time
|
| -// * is the (local) time when the cache made the request
|
| -// * that resulted in this cached response
|
| -// * response_time
|
| -// * is the (local) time when the cache received the
|
| -// * response
|
| -// * now
|
| -// * is the current (local) time
|
| -// */
|
| -// apparent_age = max(0, response_time - date_value);
|
| -// corrected_received_age = max(apparent_age, age_value);
|
| -// response_delay = response_time - request_time;
|
| -// corrected_initial_age = corrected_received_age + response_delay;
|
| -// resident_time = now - response_time;
|
| -// current_age = corrected_initial_age + resident_time;
|
| -//
|
| -TimeDelta HttpResponseHeaders::GetCurrentAge(const Time& request_time,
|
| - const Time& response_time,
|
| - const Time& current_time) const {
|
| - // If there is no Date header, then assume that the server response was
|
| - // generated at the time when we received the response.
|
| - Time date_value;
|
| - if (!GetDateValue(&date_value))
|
| - date_value = response_time;
|
| -
|
| - // If there is no Age header, then assume age is zero. GetAgeValue does not
|
| - // modify its out param if the value does not exist.
|
| - TimeDelta age_value;
|
| - GetAgeValue(&age_value);
|
| -
|
| - TimeDelta apparent_age = std::max(TimeDelta(), response_time - date_value);
|
| - TimeDelta corrected_received_age = std::max(apparent_age, age_value);
|
| - TimeDelta response_delay = response_time - request_time;
|
| - TimeDelta corrected_initial_age = corrected_received_age + response_delay;
|
| - TimeDelta resident_time = current_time - response_time;
|
| - TimeDelta current_age = corrected_initial_age + resident_time;
|
| -
|
| - return current_age;
|
| -}
|
| -
|
| -bool HttpResponseHeaders::GetMaxAgeValue(TimeDelta* result) const {
|
| - return GetCacheControlDirective("max-age", result);
|
| -}
|
| -
|
| -bool HttpResponseHeaders::GetAgeValue(TimeDelta* result) const {
|
| - std::string value;
|
| - if (!EnumerateHeader(NULL, "Age", &value))
|
| - return false;
|
| -
|
| - int64 seconds;
|
| - base::StringToInt64(value, &seconds);
|
| - *result = TimeDelta::FromSeconds(seconds);
|
| - return true;
|
| -}
|
| -
|
| -bool HttpResponseHeaders::GetDateValue(Time* result) const {
|
| - return GetTimeValuedHeader("Date", result);
|
| -}
|
| -
|
| -bool HttpResponseHeaders::GetLastModifiedValue(Time* result) const {
|
| - return GetTimeValuedHeader("Last-Modified", result);
|
| -}
|
| -
|
| -bool HttpResponseHeaders::GetExpiresValue(Time* result) const {
|
| - return GetTimeValuedHeader("Expires", result);
|
| -}
|
| -
|
| -bool HttpResponseHeaders::GetStaleWhileRevalidateValue(
|
| - TimeDelta* result) const {
|
| - return GetCacheControlDirective("stale-while-revalidate", result);
|
| -}
|
| -
|
| -bool HttpResponseHeaders::GetTimeValuedHeader(const std::string& name,
|
| - Time* result) const {
|
| - std::string value;
|
| - if (!EnumerateHeader(NULL, name, &value))
|
| - return false;
|
| -
|
| - // When parsing HTTP dates it's beneficial to default to GMT because:
|
| - // 1. RFC2616 3.3.1 says times should always be specified in GMT
|
| - // 2. Only counter-example incorrectly appended "UTC" (crbug.com/153759)
|
| - // 3. When adjusting cookie expiration times for clock skew
|
| - // (crbug.com/135131) this better matches our cookie expiration
|
| - // time parser which ignores timezone specifiers and assumes GMT.
|
| - // 4. This is exactly what Firefox does.
|
| - // TODO(pauljensen): The ideal solution would be to return false if the
|
| - // timezone could not be understood so as to avoid makeing other calculations
|
| - // based on an incorrect time. This would require modifying the time
|
| - // library or duplicating the code. (http://crbug.com/158327)
|
| - return Time::FromUTCString(value.c_str(), result);
|
| -}
|
| -
|
| -// We accept the first value of "close" or "keep-alive" in a Connection or
|
| -// Proxy-Connection header, in that order. Obeying "keep-alive" in HTTP/1.1 or
|
| -// "close" in 1.0 is not strictly standards-compliant, but we'd like to
|
| -// avoid looking at the Proxy-Connection header whenever it is reasonable to do
|
| -// so.
|
| -// TODO(ricea): Measure real-world usage of the "Proxy-Connection" header,
|
| -// with a view to reducing support for it in order to make our Connection header
|
| -// handling more RFC 7230 compliant.
|
| -bool HttpResponseHeaders::IsKeepAlive() const {
|
| - // NOTE: It is perhaps risky to assume that a Proxy-Connection header is
|
| - // meaningful when we don't know that this response was from a proxy, but
|
| - // Mozilla also does this, so we'll do the same.
|
| - static const char* const kConnectionHeaders[] = {
|
| - "connection", "proxy-connection"};
|
| - struct KeepAliveToken {
|
| - const char* const token;
|
| - bool keep_alive;
|
| - };
|
| - static const KeepAliveToken kKeepAliveTokens[] = {{"keep-alive", true},
|
| - {"close", false}};
|
| -
|
| - if (http_version_ < HttpVersion(1, 0))
|
| - return false;
|
| -
|
| - for (const char* header : kConnectionHeaders) {
|
| - void* iterator = nullptr;
|
| - std::string token;
|
| - while (EnumerateHeader(&iterator, header, &token)) {
|
| - for (const KeepAliveToken& keep_alive_token : kKeepAliveTokens) {
|
| - if (LowerCaseEqualsASCII(token, keep_alive_token.token))
|
| - return keep_alive_token.keep_alive;
|
| - }
|
| - }
|
| - }
|
| - return http_version_ != HttpVersion(1, 0);
|
| -}
|
| -
|
| -bool HttpResponseHeaders::HasStrongValidators() const {
|
| - std::string etag_header;
|
| - EnumerateHeader(NULL, "etag", &etag_header);
|
| - std::string last_modified_header;
|
| - EnumerateHeader(NULL, "Last-Modified", &last_modified_header);
|
| - std::string date_header;
|
| - EnumerateHeader(NULL, "Date", &date_header);
|
| - return HttpUtil::HasStrongValidators(GetHttpVersion(),
|
| - etag_header,
|
| - last_modified_header,
|
| - date_header);
|
| -}
|
| -
|
| -// From RFC 2616:
|
| -// Content-Length = "Content-Length" ":" 1*DIGIT
|
| -int64 HttpResponseHeaders::GetContentLength() const {
|
| - return GetInt64HeaderValue("content-length");
|
| -}
|
| -
|
| -int64 HttpResponseHeaders::GetInt64HeaderValue(
|
| - const std::string& header) const {
|
| - void* iter = NULL;
|
| - std::string content_length_val;
|
| - if (!EnumerateHeader(&iter, header, &content_length_val))
|
| - return -1;
|
| -
|
| - if (content_length_val.empty())
|
| - return -1;
|
| -
|
| - if (content_length_val[0] == '+')
|
| - return -1;
|
| -
|
| - int64 result;
|
| - bool ok = base::StringToInt64(content_length_val, &result);
|
| - if (!ok || result < 0)
|
| - return -1;
|
| -
|
| - return result;
|
| -}
|
| -
|
| -// From RFC 2616 14.16:
|
| -// content-range-spec =
|
| -// bytes-unit SP byte-range-resp-spec "/" ( instance-length | "*" )
|
| -// byte-range-resp-spec = (first-byte-pos "-" last-byte-pos) | "*"
|
| -// instance-length = 1*DIGIT
|
| -// bytes-unit = "bytes"
|
| -bool HttpResponseHeaders::GetContentRange(int64* first_byte_position,
|
| - int64* last_byte_position,
|
| - int64* instance_length) const {
|
| - void* iter = NULL;
|
| - std::string content_range_spec;
|
| - *first_byte_position = *last_byte_position = *instance_length = -1;
|
| - if (!EnumerateHeader(&iter, kContentRange, &content_range_spec))
|
| - return false;
|
| -
|
| - // If the header value is empty, we have an invalid header.
|
| - if (content_range_spec.empty())
|
| - return false;
|
| -
|
| - size_t space_position = content_range_spec.find(' ');
|
| - if (space_position == std::string::npos)
|
| - return false;
|
| -
|
| - // Invalid header if it doesn't contain "bytes-unit".
|
| - std::string::const_iterator content_range_spec_begin =
|
| - content_range_spec.begin();
|
| - std::string::const_iterator content_range_spec_end =
|
| - content_range_spec.begin() + space_position;
|
| - HttpUtil::TrimLWS(&content_range_spec_begin, &content_range_spec_end);
|
| - if (!LowerCaseEqualsASCII(content_range_spec_begin,
|
| - content_range_spec_end,
|
| - "bytes")) {
|
| - return false;
|
| - }
|
| -
|
| - size_t slash_position = content_range_spec.find('/', space_position + 1);
|
| - if (slash_position == std::string::npos)
|
| - return false;
|
| -
|
| - // Obtain the part behind the space and before slash.
|
| - std::string::const_iterator byte_range_resp_spec_begin =
|
| - content_range_spec.begin() + space_position + 1;
|
| - std::string::const_iterator byte_range_resp_spec_end =
|
| - content_range_spec.begin() + slash_position;
|
| - HttpUtil::TrimLWS(&byte_range_resp_spec_begin, &byte_range_resp_spec_end);
|
| -
|
| - // Parse the byte-range-resp-spec part.
|
| - std::string byte_range_resp_spec(byte_range_resp_spec_begin,
|
| - byte_range_resp_spec_end);
|
| - // If byte-range-resp-spec != "*".
|
| - if (!LowerCaseEqualsASCII(byte_range_resp_spec, "*")) {
|
| - size_t minus_position = byte_range_resp_spec.find('-');
|
| - if (minus_position != std::string::npos) {
|
| - // Obtain first-byte-pos.
|
| - std::string::const_iterator first_byte_pos_begin =
|
| - byte_range_resp_spec.begin();
|
| - std::string::const_iterator first_byte_pos_end =
|
| - byte_range_resp_spec.begin() + minus_position;
|
| - HttpUtil::TrimLWS(&first_byte_pos_begin, &first_byte_pos_end);
|
| -
|
| - bool ok = base::StringToInt64(StringPiece(first_byte_pos_begin,
|
| - first_byte_pos_end),
|
| - first_byte_position);
|
| -
|
| - // Obtain last-byte-pos.
|
| - std::string::const_iterator last_byte_pos_begin =
|
| - byte_range_resp_spec.begin() + minus_position + 1;
|
| - std::string::const_iterator last_byte_pos_end =
|
| - byte_range_resp_spec.end();
|
| - HttpUtil::TrimLWS(&last_byte_pos_begin, &last_byte_pos_end);
|
| -
|
| - ok &= base::StringToInt64(StringPiece(last_byte_pos_begin,
|
| - last_byte_pos_end),
|
| - last_byte_position);
|
| - if (!ok) {
|
| - *first_byte_position = *last_byte_position = -1;
|
| - return false;
|
| - }
|
| - if (*first_byte_position < 0 || *last_byte_position < 0 ||
|
| - *first_byte_position > *last_byte_position)
|
| - return false;
|
| - } else {
|
| - return false;
|
| - }
|
| - }
|
| -
|
| - // Parse the instance-length part.
|
| - // If instance-length == "*".
|
| - std::string::const_iterator instance_length_begin =
|
| - content_range_spec.begin() + slash_position + 1;
|
| - std::string::const_iterator instance_length_end =
|
| - content_range_spec.end();
|
| - HttpUtil::TrimLWS(&instance_length_begin, &instance_length_end);
|
| -
|
| - if (LowerCaseEqualsASCII(instance_length_begin, instance_length_end, "*")) {
|
| - return false;
|
| - } else if (!base::StringToInt64(StringPiece(instance_length_begin,
|
| - instance_length_end),
|
| - instance_length)) {
|
| - *instance_length = -1;
|
| - return false;
|
| - }
|
| -
|
| - // We have all the values; let's verify that they make sense for a 206
|
| - // response.
|
| - if (*first_byte_position < 0 || *last_byte_position < 0 ||
|
| - *instance_length < 0 || *instance_length - 1 < *last_byte_position)
|
| - return false;
|
| -
|
| - return true;
|
| -}
|
| -
|
| -base::Value* HttpResponseHeaders::NetLogCallback(
|
| - NetLog::LogLevel log_level) const {
|
| - base::DictionaryValue* dict = new base::DictionaryValue();
|
| - base::ListValue* headers = new base::ListValue();
|
| - headers->Append(new base::StringValue(GetStatusLine()));
|
| - void* iterator = NULL;
|
| - std::string name;
|
| - std::string value;
|
| - while (EnumerateHeaderLines(&iterator, &name, &value)) {
|
| - std::string log_value = ElideHeaderValueForNetLog(log_level, name, value);
|
| - std::string escaped_name = EscapeNonASCII(name);
|
| - std::string escaped_value = EscapeNonASCII(log_value);
|
| - headers->Append(
|
| - new base::StringValue(
|
| - base::StringPrintf("%s: %s", escaped_name.c_str(),
|
| - escaped_value.c_str())));
|
| - }
|
| - dict->Set("headers", headers);
|
| - return dict;
|
| -}
|
| -
|
| -// static
|
| -bool HttpResponseHeaders::FromNetLogParam(
|
| - const base::Value* event_param,
|
| - scoped_refptr<HttpResponseHeaders>* http_response_headers) {
|
| - *http_response_headers = NULL;
|
| -
|
| - const base::DictionaryValue* dict = NULL;
|
| - const base::ListValue* header_list = NULL;
|
| -
|
| - if (!event_param ||
|
| - !event_param->GetAsDictionary(&dict) ||
|
| - !dict->GetList("headers", &header_list)) {
|
| - return false;
|
| - }
|
| -
|
| - std::string raw_headers;
|
| - for (base::ListValue::const_iterator it = header_list->begin();
|
| - it != header_list->end();
|
| - ++it) {
|
| - std::string header_line;
|
| - if (!(*it)->GetAsString(&header_line))
|
| - return false;
|
| -
|
| - raw_headers.append(header_line);
|
| - raw_headers.push_back('\0');
|
| - }
|
| - raw_headers.push_back('\0');
|
| - *http_response_headers = new HttpResponseHeaders(raw_headers);
|
| - return true;
|
| -}
|
| -
|
| -bool HttpResponseHeaders::IsChunkEncoded() const {
|
| - // Ignore spurious chunked responses from HTTP/1.0 servers and proxies.
|
| - return GetHttpVersion() >= HttpVersion(1, 1) &&
|
| - HasHeaderValue("Transfer-Encoding", "chunked");
|
| -}
|
| -
|
| -} // namespace net
|
|
|