15976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org/* 25976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * libjingle 35976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * Copyright 2004--2005, Google Inc. 45976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * 55976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * Redistribution and use in source and binary forms, with or without 65976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * modification, are permitted provided that the following conditions are met: 75976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * 85976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * 1. Redistributions of source code must retain the above copyright notice, 95976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * this list of conditions and the following disclaimer. 105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * 2. Redistributions in binary form must reproduce the above copyright notice, 115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * this list of conditions and the following disclaimer in the documentation 125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * and/or other materials provided with the distribution. 135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * 3. The name of the author may not be used to endorse or promote products 145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * derived from this software without specific prior written permission. 155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * 165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED 175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF 185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO 195976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 205976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; 225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 235976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR 245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF 255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org */ 275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include <time.h> 295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/httpcommon-inl.h" 315976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 325976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/asyncsocket.h" 335976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/common.h" 345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/diskcache.h" 355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/httpclient.h" 365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/logging.h" 375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/pathutils.h" 385976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/socketstream.h" 395976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/stringencode.h" 405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/stringutils.h" 415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/thread.h" 425976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 435976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgnamespace talk_base { 445976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 455976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org////////////////////////////////////////////////////////////////////// 465976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// Helpers 475976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org////////////////////////////////////////////////////////////////////// 485976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 495976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgnamespace { 505976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 515976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgconst size_t kCacheHeader = 0; 525976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgconst size_t kCacheBody = 1; 535976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 545976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// Convert decimal string to integer 555976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool HttpStringToUInt(const std::string& str, size_t* val) { 565976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ASSERT(NULL != val); 575976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org char* eos = NULL; 585976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org *val = strtoul(str.c_str(), &eos, 10); 595976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return (*eos == '\0'); 605976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 615976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 625976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool HttpShouldCache(const HttpTransaction& t) { 635976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org bool verb_allows_cache = (t.request.verb == HV_GET) 645976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org || (t.request.verb == HV_HEAD); 655976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org bool is_range_response = t.response.hasHeader(HH_CONTENT_RANGE, NULL); 665976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org bool has_expires = t.response.hasHeader(HH_EXPIRES, NULL); 675976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org bool request_allows_cache = 685976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org has_expires || (std::string::npos != t.request.path.find('?')); 695976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org bool response_allows_cache = 705976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org has_expires || HttpCodeIsCacheable(t.response.scode); 715976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 725976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org bool may_cache = verb_allows_cache 735976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && request_allows_cache 745976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && response_allows_cache 755976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && !is_range_response; 765976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 775976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string value; 785976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (t.response.hasHeader(HH_CACHE_CONTROL, &value)) { 795976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpAttributeList directives; 805976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpParseAttributes(value.data(), value.size(), directives); 815976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Response Directives Summary: 825976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // public - always cacheable 835976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // private - do not cache in a shared cache 845976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // no-cache - may cache, but must revalidate whether fresh or stale 855976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // no-store - sensitive information, do not cache or store in any way 865976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // max-age - supplants Expires for staleness 875976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // s-maxage - use as max-age for shared caches, ignore otherwise 885976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // must-revalidate - may cache, but must revalidate after stale 895976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // proxy-revalidate - shared cache must revalidate 905976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (HttpHasAttribute(directives, "no-store", NULL)) { 915976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org may_cache = false; 925976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else if (HttpHasAttribute(directives, "public", NULL)) { 935976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org may_cache = true; 945976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 955976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 965976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return may_cache; 975976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 985976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 995976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgenum HttpCacheState { 1005976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HCS_FRESH, // In cache, may use 1015976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HCS_STALE, // In cache, must revalidate 1025976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HCS_NONE // Not in cache 1035976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org}; 1045976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1055976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgHttpCacheState HttpGetCacheState(const HttpTransaction& t) { 1065976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Temporaries 1075976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string s_temp; 1085976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org time_t u_temp; 1095976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Current time 1115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t now = time(0); 1125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpAttributeList cache_control; 1145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (t.response.hasHeader(HH_CACHE_CONTROL, &s_temp)) { 1155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpParseAttributes(s_temp.data(), s_temp.size(), cache_control); 1165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Compute age of cache document 1195976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org time_t date; 1205976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!t.response.hasHeader(HH_DATE, &s_temp) 1215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org || !HttpDateToSeconds(s_temp, &date)) 1225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HCS_NONE; 1235976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // TODO: Timestamp when cache request sent and response received? 1255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org time_t request_time = date; 1265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org time_t response_time = date; 1275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org time_t apparent_age = 0; 1295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (response_time > date) { 1305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org apparent_age = response_time - date; 1315976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1325976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1335976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t corrected_received_age = apparent_age; 1345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t i_temp; 1355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (t.response.hasHeader(HH_AGE, &s_temp) 1365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && HttpStringToUInt(s_temp, (&i_temp))) { 1375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org u_temp = static_cast<time_t>(i_temp); 1385976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org corrected_received_age = stdmax(apparent_age, u_temp); 1395976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t response_delay = response_time - request_time; 1425976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t corrected_initial_age = corrected_received_age + response_delay; 1435976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t resident_time = now - response_time; 1445976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t current_age = corrected_initial_age + resident_time; 1455976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1465976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Compute lifetime of document 1475976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t lifetime; 1485976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (HttpHasAttribute(cache_control, "max-age", &s_temp)) { 1495976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org lifetime = atoi(s_temp.c_str()); 1505976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else if (t.response.hasHeader(HH_EXPIRES, &s_temp) 1515976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && HttpDateToSeconds(s_temp, &u_temp)) { 1525976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org lifetime = u_temp - date; 1535976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else if (t.response.hasHeader(HH_LAST_MODIFIED, &s_temp) 1545976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && HttpDateToSeconds(s_temp, &u_temp)) { 1555976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // TODO: Issue warning 113 if age > 24 hours 1565976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org lifetime = static_cast<size_t>(now - u_temp) / 10; 1575976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else { 1585976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HCS_STALE; 1595976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1605976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1615976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return (lifetime > current_age) ? HCS_FRESH : HCS_STALE; 1625976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 1635976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1645976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgenum HttpValidatorStrength { 1655976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HVS_NONE, 1665976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HVS_WEAK, 1675976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HVS_STRONG 1685976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org}; 1695976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1705976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgHttpValidatorStrength 1715976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgHttpRequestValidatorLevel(const HttpRequestData& request) { 1725976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (HV_GET != request.verb) 1735976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HVS_STRONG; 1745976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return request.hasHeader(HH_RANGE, NULL) ? HVS_STRONG : HVS_WEAK; 1755976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 1765976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1775976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgHttpValidatorStrength 1785976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgHttpResponseValidatorLevel(const HttpResponseData& response) { 1795976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string value; 1805976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (response.hasHeader(HH_ETAG, &value)) { 1815976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org bool is_weak = (strnicmp(value.c_str(), "W/", 2) == 0); 1825976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return is_weak ? HVS_WEAK : HVS_STRONG; 1835976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1845976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (response.hasHeader(HH_LAST_MODIFIED, &value)) { 1855976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org time_t last_modified, date; 1865976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (HttpDateToSeconds(value, &last_modified) 1875976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && response.hasHeader(HH_DATE, &value) 1885976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && HttpDateToSeconds(value, &date) 1895976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && (last_modified + 60 < date)) { 1905976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HVS_STRONG; 1915976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1925976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HVS_WEAK; 1935976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1945976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HVS_NONE; 1955976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 1965976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1975976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgstd::string GetCacheID(const HttpRequestData& request) { 1985976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string id, url; 1995976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org id.append(ToString(request.verb)); 2005976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org id.append("_"); 2015976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request.getAbsoluteUri(&url); 2025976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org id.append(url); 2035976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return id; 2045976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 2055976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2065976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} // anonymous namespace 2075976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2085976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org////////////////////////////////////////////////////////////////////// 2095976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// Public Helpers 2105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org////////////////////////////////////////////////////////////////////// 2115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool HttpWriteCacheHeaders(const HttpResponseData* response, 2135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org StreamInterface* output, size_t* size) { 2145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t length = 0; 2155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Write all unknown and end-to-end headers to a cache file 2165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org for (HttpData::const_iterator it = response->begin(); 2175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org it != response->end(); ++it) { 2185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpHeader header; 2195976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (FromString(header, it->first) && !HttpHeaderIsEndToEnd(header)) 2205976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org continue; 2215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org length += it->first.length() + 2 + it->second.length() + 2; 2225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!output) 2235976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org continue; 2245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string formatted_header(it->first); 2255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org formatted_header.append(": "); 2265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org formatted_header.append(it->second); 2275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org formatted_header.append("\r\n"); 2285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org StreamResult result = output->WriteAll(formatted_header.data(), 2295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org formatted_header.length(), 2305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org NULL, NULL); 2315976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (SR_SUCCESS != result) { 2325976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 2335976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (output && (SR_SUCCESS != output->WriteAll("\r\n", 2, NULL, NULL))) { 2365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 2375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2385976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org length += 2; 2395976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (size) 2405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org *size = length; 2415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return true; 2425976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 2435976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2445976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool HttpReadCacheHeaders(StreamInterface* input, HttpResponseData* response, 2455976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpData::HeaderCombine combine) { 2465976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org while (true) { 2475976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string formatted_header; 2485976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org StreamResult result = input->ReadLine(&formatted_header); 2495976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if ((SR_EOS == result) || (1 == formatted_header.size())) { 2505976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org break; 2515976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2525976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (SR_SUCCESS != result) { 2535976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 2545976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2555976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t end_of_name = formatted_header.find(':'); 2565976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (std::string::npos == end_of_name) { 2575976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG_F(LS_WARNING) << "Malformed cache header"; 2585976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org continue; 2595976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2605976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t start_of_value = end_of_name + 1; 2615976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t end_of_value = formatted_header.length(); 2625976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org while ((start_of_value < end_of_value) 2635976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && isspace(formatted_header[start_of_value])) 2645976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ++start_of_value; 2655976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org while ((start_of_value < end_of_value) 2665976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && isspace(formatted_header[end_of_value-1])) 2675976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org --end_of_value; 2685976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t value_length = end_of_value - start_of_value; 2695976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2705976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string name(formatted_header.substr(0, end_of_name)); 2715976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string value(formatted_header.substr(start_of_value, value_length)); 2725976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org response->changeHeader(name, value, combine); 2735976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2745976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return true; 2755976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 2765976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2775976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org////////////////////////////////////////////////////////////////////// 2785976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// HttpClient 2795976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org////////////////////////////////////////////////////////////////////// 2805976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2815976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgconst size_t kDefaultRetries = 1; 2825976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgconst size_t kMaxRedirects = 5; 2835976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2845976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgHttpClient::HttpClient(const std::string& agent, StreamPool* pool, 2855976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpTransaction* transaction) 2865976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org : agent_(agent), pool_(pool), 2875976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org transaction_(transaction), free_transaction_(false), 2885976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org retries_(kDefaultRetries), attempt_(0), redirects_(0), 2895976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org redirect_action_(REDIRECT_DEFAULT), 2905976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org uri_form_(URI_DEFAULT), cache_(NULL), cache_state_(CS_READY), 2915976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org resolver_(NULL) { 2925976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org base_.notify(this); 2935976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (NULL == transaction_) { 2945976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org free_transaction_ = true; 2955976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org transaction_ = new HttpTransaction; 2965976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2975976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 2985976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2995976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgHttpClient::~HttpClient() { 3005976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org base_.notify(NULL); 3015976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org base_.abort(HE_SHUTDOWN); 3025976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (resolver_) { 3035976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org resolver_->Destroy(false); 3045976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 3055976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org release(); 3065976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (free_transaction_) 3075976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org delete transaction_; 3085976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 3095976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid HttpClient::reset() { 3115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org server_.Clear(); 3125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().clear(true); 3135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org response().clear(true); 3145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org context_.reset(); 3155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org redirects_ = 0; 3165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org base_.abort(HE_OPERATION_CANCELLED); 3175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 3185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 319edac505d92ae2ab28b41f26f1a5b889d3e2a99f3sergeyu@chromium.orgvoid HttpClient::OnResolveResult(AsyncResolverInterface* resolver) { 320edac505d92ae2ab28b41f26f1a5b889d3e2a99f3sergeyu@chromium.org if (resolver != resolver_) { 3215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return; 3225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 323edac505d92ae2ab28b41f26f1a5b889d3e2a99f3sergeyu@chromium.org int error = resolver_->GetError(); 3245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org server_ = resolver_->address(); 3255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org resolver_->Destroy(false); 3265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org resolver_ = NULL; 3275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (error != 0) { 3285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG(LS_ERROR) << "Error " << error << " resolving name: " 3295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org << server_; 3305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org onHttpComplete(HM_CONNECT, HE_CONNECT_FAILED); 3315976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else { 3325976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org connect(); 3335976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 3345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 3355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid HttpClient::StartDNSLookup() { 3375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org resolver_ = new AsyncResolver(); 338edac505d92ae2ab28b41f26f1a5b889d3e2a99f3sergeyu@chromium.org resolver_->SignalDone.connect(this, &HttpClient::OnResolveResult); 339edac505d92ae2ab28b41f26f1a5b889d3e2a99f3sergeyu@chromium.org resolver_->Start(server_); 3405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 3415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3425976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid HttpClient::set_server(const SocketAddress& address) { 3435976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org server_ = address; 3445976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Setting 'Host' here allows it to be overridden before starting the request, 3455976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // if necessary. 3465976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().setHeader(HH_HOST, HttpAddress(server_, false), true); 3475976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 3485976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3495976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgStreamInterface* HttpClient::GetDocumentStream() { 3505976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return base_.GetDocumentStream(); 3515976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 3525976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3535976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid HttpClient::start() { 3545976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (base_.mode() != HM_NONE) { 3555976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // call reset() to abort an in-progress request 3565976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ASSERT(false); 3575976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return; 3585976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 3595976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3605976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ASSERT(!IsCacheActive()); 3615976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3625976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (request().hasHeader(HH_TRANSFER_ENCODING, NULL)) { 3635976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Exact size must be known on the client. Instead of using chunked 3645976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // encoding, wrap data with auto-caching file or memory stream. 3655976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ASSERT(false); 3665976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return; 3675976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 3685976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3695976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org attempt_ = 0; 3705976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3715976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // If no content has been specified, using length of 0. 3725976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().setHeader(HH_CONTENT_LENGTH, "0", false); 3735976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3745976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!agent_.empty()) { 3755976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().setHeader(HH_USER_AGENT, agent_, false); 3765976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 3775976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3785976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org UriForm uri_form = uri_form_; 3795976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (PROXY_HTTPS == proxy_.type) { 3805976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Proxies require absolute form 3815976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org uri_form = URI_ABSOLUTE; 3825976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().version = HVER_1_0; 3835976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().setHeader(HH_PROXY_CONNECTION, "Keep-Alive", false); 3845976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else { 3855976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().setHeader(HH_CONNECTION, "Keep-Alive", false); 3865976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 3875976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3885976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (URI_ABSOLUTE == uri_form) { 3895976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Convert to absolute uri form 3905976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string url; 3915976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (request().getAbsoluteUri(&url)) { 3925976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().path = url; 3935976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else { 3945976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG(LS_WARNING) << "Couldn't obtain absolute uri"; 3955976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 3965976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else if (URI_RELATIVE == uri_form) { 3975976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Convert to relative uri form 3985976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string host, path; 3995976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (request().getRelativeUri(&host, &path)) { 4005976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().setHeader(HH_HOST, host); 4015976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().path = path; 4025976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else { 4035976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG(LS_WARNING) << "Couldn't obtain relative uri"; 4045976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 4055976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 4065976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 4075976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if ((NULL != cache_) && CheckCache()) { 4085976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return; 4095976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 4105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 4115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org connect(); 4125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 4135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 4145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid HttpClient::connect() { 4155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org int stream_err; 4165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (server_.IsUnresolvedIP()) { 4175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org StartDNSLookup(); 4185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return; 4195976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 4205976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org StreamInterface* stream = pool_->RequestConnectedStream(server_, &stream_err); 4215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (stream == NULL) { 4225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ASSERT(0 != stream_err); 4235976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG(LS_ERROR) << "RequestConnectedStream error: " << stream_err; 4245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org onHttpComplete(HM_CONNECT, HE_CONNECT_FAILED); 4255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else { 4265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org base_.attach(stream); 4275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (stream->GetState() == SS_OPEN) { 4285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org base_.send(&transaction_->request); 4295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 4305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 4315976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 4325976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 4335976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid HttpClient::prepare_get(const std::string& url) { 4345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org reset(); 4355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org Url<char> purl(url); 4365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org set_server(SocketAddress(purl.host(), purl.port())); 4375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().verb = HV_GET; 4385976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().path = purl.full_path(); 4395976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 4405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 4415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid HttpClient::prepare_post(const std::string& url, 4425976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& content_type, 4435976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org StreamInterface* request_doc) { 4445976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org reset(); 4455976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org Url<char> purl(url); 4465976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org set_server(SocketAddress(purl.host(), purl.port())); 4475976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().verb = HV_POST; 4485976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().path = purl.full_path(); 4495976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().setContent(content_type, request_doc); 4505976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 4515976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 4525976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid HttpClient::release() { 4535976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (StreamInterface* stream = base_.detach()) { 4545976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org pool_->ReturnConnectedStream(stream); 4555976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 4565976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 4575976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 4585976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool HttpClient::ShouldRedirect(std::string* location) const { 4595976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // TODO: Unittest redirection. 4605976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if ((REDIRECT_NEVER == redirect_action_) 4615976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org || !HttpCodeIsRedirection(response().scode) 4625976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org || !response().hasHeader(HH_LOCATION, location) 4635976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org || (redirects_ >= kMaxRedirects)) 4645976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 4655976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return (REDIRECT_ALWAYS == redirect_action_) 4665976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org || (HC_SEE_OTHER == response().scode) 4675976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org || (HV_HEAD == request().verb) 4685976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org || (HV_GET == request().verb); 4695976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 4705976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 4715976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool HttpClient::BeginCacheFile() { 4725976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ASSERT(NULL != cache_); 4735976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ASSERT(CS_READY == cache_state_); 4745976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 4755976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string id = GetCacheID(request()); 4765976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org CacheLock lock(cache_, id, true); 4775976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!lock.IsLocked()) { 4785976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG_F(LS_WARNING) << "Couldn't lock cache"; 4795976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 4805976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 4815976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 4825976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (HE_NONE != WriteCacheHeaders(id)) { 4835976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 4845976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 4855976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 4865976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org scoped_ptr<StreamInterface> stream(cache_->WriteResource(id, kCacheBody)); 4875976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!stream) { 4885976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG_F(LS_ERROR) << "Couldn't open body cache"; 4895976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 4905976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 4915976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org lock.Commit(); 4925976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 4935976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Let's secretly replace the response document with Folgers Crystals, 4945976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // er, StreamTap, so that we can mirror the data to our cache. 4955976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org StreamInterface* output = response().document.release(); 4965976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!output) { 4975976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org output = new NullStream; 4985976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 4995976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org StreamTap* tap = new StreamTap(output, stream.release()); 5005976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org response().document.reset(tap); 5015976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return true; 5025976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 5035976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5045976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgHttpError HttpClient::WriteCacheHeaders(const std::string& id) { 5055976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org scoped_ptr<StreamInterface> stream(cache_->WriteResource(id, kCacheHeader)); 5065976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!stream) { 5075976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG_F(LS_ERROR) << "Couldn't open header cache"; 5085976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HE_CACHE; 5095976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 5105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!HttpWriteCacheHeaders(&transaction_->response, stream.get(), NULL)) { 5125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG_F(LS_ERROR) << "Couldn't write header cache"; 5135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HE_CACHE; 5145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 5155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HE_NONE; 5175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 5185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5195976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid HttpClient::CompleteCacheFile() { 5205976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Restore previous response document 5215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org StreamTap* tap = static_cast<StreamTap*>(response().document.release()); 5225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org response().document.reset(tap->Detach()); 5235976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org int error; 5255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org StreamResult result = tap->GetTapResult(&error); 5265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Delete the tap and cache stream (which completes cache unlock) 5285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org delete tap; 5295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (SR_SUCCESS != result) { 5315976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG(LS_ERROR) << "Cache file error: " << error; 5325976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org cache_->DeleteResource(GetCacheID(request())); 5335976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 5345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 5355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool HttpClient::CheckCache() { 5375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ASSERT(NULL != cache_); 5385976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ASSERT(CS_READY == cache_state_); 5395976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string id = GetCacheID(request()); 5415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!cache_->HasResource(id)) { 5425976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // No cache file available 5435976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 5445976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 5455976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5465976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpError error = ReadCacheHeaders(id, true); 5475976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5485976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (HE_NONE == error) { 5495976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org switch (HttpGetCacheState(*transaction_)) { 5505976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org case HCS_FRESH: 5515976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Cache content is good, read from cache 5525976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org break; 5535976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org case HCS_STALE: 5545976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Cache content may be acceptable. Issue a validation request. 5555976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (PrepareValidate()) { 5565976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 5575976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 5585976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Couldn't validate, fall through. 5595976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org case HCS_NONE: 5605976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Cache content is not useable. Issue a regular request. 5615976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org response().clear(false); 5625976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 5635976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 5645976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 5655976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5665976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (HE_NONE == error) { 5675976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org error = ReadCacheBody(id); 5685976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org cache_state_ = CS_READY; 5695976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 5705976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5715976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (HE_CACHE == error) { 5725976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG_F(LS_WARNING) << "Cache failure, continuing with normal request"; 5735976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org response().clear(false); 5745976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 5755976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 5765976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5775976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org SignalHttpClientComplete(this, error); 5785976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return true; 5795976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 5805976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5815976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgHttpError HttpClient::ReadCacheHeaders(const std::string& id, bool override) { 5825976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org scoped_ptr<StreamInterface> stream(cache_->ReadResource(id, kCacheHeader)); 5835976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!stream) { 5845976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HE_CACHE; 5855976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 5865976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5875976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpData::HeaderCombine combine = 5885976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org override ? HttpData::HC_REPLACE : HttpData::HC_AUTO; 5895976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5905976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!HttpReadCacheHeaders(stream.get(), &transaction_->response, combine)) { 5915976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG_F(LS_ERROR) << "Error reading cache headers"; 5925976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HE_CACHE; 5935976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 5945976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5955976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org response().scode = HC_OK; 5965976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HE_NONE; 5975976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 5985976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 5995976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgHttpError HttpClient::ReadCacheBody(const std::string& id) { 6005976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org cache_state_ = CS_READING; 6015976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 6025976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpError error = HE_NONE; 6035976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 6045976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t data_size; 6055976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org scoped_ptr<StreamInterface> stream(cache_->ReadResource(id, kCacheBody)); 6065976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!stream || !stream->GetAvailable(&data_size)) { 6075976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG_F(LS_ERROR) << "Unavailable cache body"; 6085976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org error = HE_CACHE; 6095976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else { 6105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org error = OnHeaderAvailable(false, false, data_size); 6115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 6125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 6135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if ((HE_NONE == error) 6145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && (HV_HEAD != request().verb) 6155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && response().document) { 6165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org char buffer[1024 * 64]; 6175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org StreamResult result = Flow(stream.get(), buffer, ARRAY_SIZE(buffer), 6185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org response().document.get()); 6195976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (SR_SUCCESS != result) { 6205976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org error = HE_STREAM; 6215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 6225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 6235976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 6245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return error; 6255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 6265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 6275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool HttpClient::PrepareValidate() { 6285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ASSERT(CS_READY == cache_state_); 6295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // At this point, request() contains the pending request, and response() 6305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // contains the cached response headers. Reformat the request to validate 6315976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // the cached content. 6325976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpValidatorStrength vs_required = HttpRequestValidatorLevel(request()); 6335976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpValidatorStrength vs_available = HttpResponseValidatorLevel(response()); 6345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (vs_available < vs_required) { 6355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 6365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 6375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string value; 6385976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (response().hasHeader(HH_ETAG, &value)) { 6395976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().addHeader(HH_IF_NONE_MATCH, value); 6405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 6415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (response().hasHeader(HH_LAST_MODIFIED, &value)) { 6425976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().addHeader(HH_IF_MODIFIED_SINCE, value); 6435976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 6445976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org response().clear(false); 6455976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org cache_state_ = CS_VALIDATING; 6465976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return true; 6475976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 6485976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 6495976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgHttpError HttpClient::CompleteValidate() { 6505976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ASSERT(CS_VALIDATING == cache_state_); 6515976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 6525976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string id = GetCacheID(request()); 6535976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 6545976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Merge cached headers with new headers 6555976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpError error = ReadCacheHeaders(id, false); 6565976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (HE_NONE != error) { 6575976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Rewrite merged headers to cache 6585976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org CacheLock lock(cache_, id); 6595976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org error = WriteCacheHeaders(id); 6605976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 6615976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (HE_NONE != error) { 6625976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org error = ReadCacheBody(id); 6635976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 6645976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return error; 6655976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 6665976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 6675976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgHttpError HttpClient::OnHeaderAvailable(bool ignore_data, bool chunked, 6685976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org size_t data_size) { 6695976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // If we are ignoring the data, this is an intermediate header. 6705976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // TODO: don't signal intermediate headers. Instead, do all header-dependent 6715976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // processing now, and either set up the next request, or fail outright. 6725976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // TODO: by default, only write response documents with a success code. 6735976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org SignalHeaderAvailable(this, !ignore_data, ignore_data ? 0 : data_size); 6745976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!ignore_data && !chunked && (data_size != SIZE_UNKNOWN) 6755976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && response().document) { 6765976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Attempt to pre-allocate space for the downloaded data. 6775976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!response().document->ReserveSize(data_size)) { 6785976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HE_OVERFLOW; 6795976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 6805976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 6815976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HE_NONE; 6825976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 6835976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 6845976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// 6855976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// HttpBase Implementation 6865976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// 6875976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 6885976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgHttpError HttpClient::onHttpHeaderComplete(bool chunked, size_t& data_size) { 6895976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (CS_VALIDATING == cache_state_) { 6905976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (HC_NOT_MODIFIED == response().scode) { 6915976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return CompleteValidate(); 6925976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 6935976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Should we remove conditional headers from request? 6945976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org cache_state_ = CS_READY; 6955976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org cache_->DeleteResource(GetCacheID(request())); 6965976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Continue processing response as normal 6975976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 6985976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 6995976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ASSERT(!IsCacheActive()); 7005976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if ((request().verb == HV_HEAD) || !HttpCodeHasBody(response().scode)) { 7015976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // HEAD requests and certain response codes contain no body 7025976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org data_size = 0; 7035976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 7045976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (ShouldRedirect(NULL) 7055976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org || ((HC_PROXY_AUTHENTICATION_REQUIRED == response().scode) 7065976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && (PROXY_HTTPS == proxy_.type))) { 7075976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // We're going to issue another request, so ignore the incoming data. 7085976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org base_.set_ignore_data(true); 7095976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 7105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 7115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpError error = OnHeaderAvailable(base_.ignore_data(), chunked, data_size); 7125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (HE_NONE != error) { 7135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return error; 7145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 7155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 7165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if ((NULL != cache_) 7175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && !base_.ignore_data() 7185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && HttpShouldCache(*transaction_)) { 7195976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (BeginCacheFile()) { 7205976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org cache_state_ = CS_WRITING; 7215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 7225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 7235976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return HE_NONE; 7245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 7255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 7265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid HttpClient::onHttpComplete(HttpMode mode, HttpError err) { 7275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (((HE_DISCONNECTED == err) || (HE_CONNECT_FAILED == err) 7285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org || (HE_SOCKET_ERROR == err)) 7295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && (HC_INTERNAL_SERVER_ERROR == response().scode) 7305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && (attempt_ < retries_)) { 7315976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // If the response code has not changed from the default, then we haven't 7325976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // received anything meaningful from the server, so we are eligible for a 7335976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // retry. 7345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ++attempt_; 7355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (request().document && !request().document->Rewind()) { 7365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Unable to replay the request document. 7375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org err = HE_STREAM; 7385976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else { 7395976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org release(); 7405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org connect(); 7415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return; 7425976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 7435976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else if (err != HE_NONE) { 7445976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // fall through 7455976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else if (mode == HM_CONNECT) { 7465976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org base_.send(&transaction_->request); 7475976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return; 7485976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else if ((mode == HM_SEND) || HttpCodeIsInformational(response().scode)) { 7495976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // If you're interested in informational headers, catch 7505976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // SignalHeaderAvailable. 7515976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org base_.recv(&transaction_->response); 7525976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return; 7535976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else { 7545976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!HttpShouldKeepAlive(response())) { 7555976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG(LS_VERBOSE) << "HttpClient: closing socket"; 7565976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org base_.stream()->Close(); 7575976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 7585976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string location; 7595976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (ShouldRedirect(&location)) { 7605976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org Url<char> purl(location); 7615976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org set_server(SocketAddress(purl.host(), purl.port())); 7625976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().path = purl.full_path(); 7635976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (response().scode == HC_SEE_OTHER) { 7645976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().verb = HV_GET; 7655976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().clearHeader(HH_CONTENT_TYPE); 7665976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().clearHeader(HH_CONTENT_LENGTH); 7675976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().document.reset(); 7685976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else if (request().document && !request().document->Rewind()) { 7695976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Unable to replay the request document. 7705976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ASSERT(REDIRECT_ALWAYS == redirect_action_); 7715976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org err = HE_STREAM; 7725976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 7735976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (err == HE_NONE) { 7745976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ++redirects_; 7755976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org context_.reset(); 7765976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org response().clear(false); 7775976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org release(); 7785976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org start(); 7795976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return; 7805976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 7815976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else if ((HC_PROXY_AUTHENTICATION_REQUIRED == response().scode) 7825976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org && (PROXY_HTTPS == proxy_.type)) { 7835976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string authorization, auth_method; 7845976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpData::const_iterator begin = response().begin(HH_PROXY_AUTHENTICATE); 7855976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpData::const_iterator end = response().end(HH_PROXY_AUTHENTICATE); 7865976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org for (HttpData::const_iterator it = begin; it != end; ++it) { 7875976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpAuthContext *context = context_.get(); 7885976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpAuthResult res = HttpAuthenticate( 7895976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org it->second.data(), it->second.size(), 7905976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org proxy_.address, 7915976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ToString(request().verb), request().path, 7925976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org proxy_.username, proxy_.password, 7935976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org context, authorization, auth_method); 7945976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org context_.reset(context); 7955976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (res == HAR_RESPONSE) { 7965976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org request().setHeader(HH_PROXY_AUTHORIZATION, authorization); 7975976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (request().document && !request().document->Rewind()) { 7985976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org err = HE_STREAM; 7995976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else { 8005976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Explicitly do not reset the HttpAuthContext 8015976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org response().clear(false); 8025976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // TODO: Reuse socket when authenticating? 8035976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org release(); 8045976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org start(); 8055976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return; 8065976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 8075976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else if (res == HAR_IGNORE) { 8085976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG(INFO) << "Ignoring Proxy-Authenticate: " << auth_method; 8095976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org continue; 8105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else { 8115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org break; 8125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 8135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 8145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 8155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 8165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (CS_WRITING == cache_state_) { 8175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org CompleteCacheFile(); 8185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org cache_state_ = CS_READY; 8195976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else if (CS_READING == cache_state_) { 8205976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org cache_state_ = CS_READY; 8215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 8225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org release(); 8235976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org SignalHttpClientComplete(this, err); 8245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 8255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 8265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid HttpClient::onHttpClosed(HttpError err) { 8275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // This shouldn't occur, since we return the stream to the pool upon command 8285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // completion. 8295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org ASSERT(false); 8305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 8315976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 8325976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org////////////////////////////////////////////////////////////////////// 8335976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// HttpClientDefault 8345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org////////////////////////////////////////////////////////////////////// 8355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 8365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgHttpClientDefault::HttpClientDefault(SocketFactory* factory, 8375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& agent, 8385976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpTransaction* transaction) 8395976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org : ReuseSocketPool(factory ? factory : Thread::Current()->socketserver()), 8405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpClient(agent, NULL, transaction) { 8415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org set_pool(this); 8425976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 8435976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 8445976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org////////////////////////////////////////////////////////////////////// 8455976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 8465976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} // namespace talk_base 847