Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(649)

Side by Side Diff: net/base/filter.cc

Issue 40319: Use filter context to track stats better in SDCH filtering (Closed) Base URL: svn://chrome-svn/chrome/trunk/src/
Patch Set: '' Created 11 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « net/base/filter.h ('k') | net/base/filter_unittest.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2006-2008 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2006-2008 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "net/base/filter.h" 5 #include "net/base/filter.h"
6 6
7 #include "base/string_util.h" 7 #include "base/string_util.h"
8 #include "net/base/gzip_filter.h" 8 #include "net/base/gzip_filter.h"
9 #include "net/base/bzip2_filter.h" 9 #include "net/base/bzip2_filter.h"
10 #include "net/base/sdch_filter.h" 10 #include "net/base/sdch_filter.h"
(...skipping 20 matching lines...) Expand all
31 const char kApplicationGzip[] = "application/gzip"; 31 const char kApplicationGzip[] = "application/gzip";
32 const char kApplicationXGunzip[] = "application/x-gunzip"; 32 const char kApplicationXGunzip[] = "application/x-gunzip";
33 const char kApplicationXCompress[] = "application/x-compress"; 33 const char kApplicationXCompress[] = "application/x-compress";
34 const char kApplicationCompress[] = "application/compress"; 34 const char kApplicationCompress[] = "application/compress";
35 const char kTextHtml[] = "text/html"; 35 const char kTextHtml[] = "text/html";
36 36
37 } // namespace 37 } // namespace
38 38
39 Filter* Filter::Factory(const std::vector<FilterType>& filter_types, 39 Filter* Filter::Factory(const std::vector<FilterType>& filter_types,
40 const FilterContext& filter_context) { 40 const FilterContext& filter_context) {
41 DCHECK(filter_context.GetInputStreambufferSize() > 0); 41 DCHECK(filter_context.GetInputStreamBufferSize() > 0);
42 if (filter_types.empty() || filter_context.GetInputStreambufferSize() <= 0) 42 if (filter_types.empty() || filter_context.GetInputStreamBufferSize() <= 0)
43 return NULL; 43 return NULL;
44 44
45 45
46 Filter* filter_list = NULL; // Linked list of filters. 46 Filter* filter_list = NULL; // Linked list of filters.
47 for (size_t i = 0; i < filter_types.size(); i++) { 47 for (size_t i = 0; i < filter_types.size(); i++) {
48 filter_list = PrependNewFilter(filter_types[i], filter_context, 48 filter_list = PrependNewFilter(filter_types[i], filter_context,
49 filter_list); 49 filter_list);
50 if (!filter_list) 50 if (!filter_list)
51 return NULL; 51 return NULL;
52 } 52 }
53
54 // TODO(jar): These settings should go into the derived classes, on an as-need ed basis.
55 std::string mime_type;
56 bool success = filter_context.GetMimeType(&mime_type);
57 DCHECK(success);
58 GURL gurl;
59 success = filter_context.GetURL(&gurl);
60 DCHECK(success);
61 base::Time request_time = filter_context.GetRequestTime();
62 bool is_cached_content = filter_context.IsCachedContent();
63
64 filter_list->SetMimeType(mime_type);
65 filter_list->SetURL(gurl);
66 // Approximate connect time with request_time. If it is not cached, then
67 // this is a good approximation for when the first bytes went on the
68 // wire.
69 filter_list->SetConnectTime(request_time, is_cached_content);
70
71 return filter_list; 53 return filter_list;
72 } 54 }
73 55
74 // static 56 // static
75 Filter::FilterType Filter::ConvertEncodingToType( 57 Filter::FilterType Filter::ConvertEncodingToType(
76 const std::string& filter_type) { 58 const std::string& filter_type) {
77 FilterType type_id; 59 FilterType type_id;
78 if (LowerCaseEqualsASCII(filter_type, kDeflate)) { 60 if (LowerCaseEqualsASCII(filter_type, kDeflate)) {
79 type_id = FILTER_TYPE_DEFLATE; 61 type_id = FILTER_TYPE_DEFLATE;
80 } else if (LowerCaseEqualsASCII(filter_type, kGZip) || 62 } else if (LowerCaseEqualsASCII(filter_type, kGZip) ||
81 LowerCaseEqualsASCII(filter_type, kXGZip)) { 63 LowerCaseEqualsASCII(filter_type, kXGZip)) {
82 type_id = FILTER_TYPE_GZIP; 64 type_id = FILTER_TYPE_GZIP;
83 } else if (LowerCaseEqualsASCII(filter_type, kBZip2) || 65 } else if (LowerCaseEqualsASCII(filter_type, kBZip2) ||
84 LowerCaseEqualsASCII(filter_type, kXBZip2)) { 66 LowerCaseEqualsASCII(filter_type, kXBZip2)) {
85 type_id = FILTER_TYPE_BZIP2; 67 type_id = FILTER_TYPE_BZIP2;
86 } else if (LowerCaseEqualsASCII(filter_type, kSdch)) { 68 } else if (LowerCaseEqualsASCII(filter_type, kSdch)) {
87 type_id = FILTER_TYPE_SDCH; 69 type_id = FILTER_TYPE_SDCH;
88 } else { 70 } else {
89 // Note we also consider "identity" and "uncompressed" UNSUPPORTED as 71 // Note we also consider "identity" and "uncompressed" UNSUPPORTED as
90 // filter should be disabled in such cases. 72 // filter should be disabled in such cases.
91 type_id = FILTER_TYPE_UNSUPPORTED; 73 type_id = FILTER_TYPE_UNSUPPORTED;
92 } 74 }
93 return type_id; 75 return type_id;
94 } 76 }
95 77
96 // static 78 // static
97 void Filter::FixupEncodingTypes( 79 void Filter::FixupEncodingTypes(
98 bool is_sdch_response, 80 const FilterContext& filter_context,
99 const std::string& mime_type,
100 std::vector<FilterType>* encoding_types) { 81 std::vector<FilterType>* encoding_types) {
82 std::string mime_type;
83 bool success = filter_context.GetMimeType(&mime_type);
84 DCHECK(success);
101 85
102 if ((1 == encoding_types->size()) && 86 if ((1 == encoding_types->size()) &&
103 (FILTER_TYPE_GZIP == encoding_types->front())) { 87 (FILTER_TYPE_GZIP == encoding_types->front())) {
104 if (LowerCaseEqualsASCII(mime_type, kApplicationXGzip) || 88 if (LowerCaseEqualsASCII(mime_type, kApplicationXGzip) ||
105 LowerCaseEqualsASCII(mime_type, kApplicationGzip) || 89 LowerCaseEqualsASCII(mime_type, kApplicationGzip) ||
106 LowerCaseEqualsASCII(mime_type, kApplicationXGunzip)) 90 LowerCaseEqualsASCII(mime_type, kApplicationXGunzip))
107 // The server has told us that it sent us gziped content with a gzip 91 // The server has told us that it sent us gziped content with a gzip
108 // content encoding. Sadly, Apache mistakenly sets these headers for all 92 // content encoding. Sadly, Apache mistakenly sets these headers for all
109 // .gz files. We match Firefox's nsHttpChannel::ProcessNormal and ignore 93 // .gz files. We match Firefox's nsHttpChannel::ProcessNormal and ignore
110 // the Content-Encoding here. 94 // the Content-Encoding here.
111 encoding_types->clear(); 95 encoding_types->clear();
112 } 96 }
113 97
114 if (!is_sdch_response) { 98 if (!filter_context.IsSdchResponse()) {
115 if (1 < encoding_types->size()) { 99 if (1 < encoding_types->size()) {
116 // Multiple filters were intended to only be used for SDCH (thus far!) 100 // Multiple filters were intended to only be used for SDCH (thus far!)
117 SdchManager::SdchErrorRecovery( 101 SdchManager::SdchErrorRecovery(
118 SdchManager::MULTIENCODING_FOR_NON_SDCH_REQUEST); 102 SdchManager::MULTIENCODING_FOR_NON_SDCH_REQUEST);
119 } 103 }
120 if ((1 == encoding_types->size()) && 104 if ((1 == encoding_types->size()) &&
121 (FILTER_TYPE_SDCH == encoding_types->front())) { 105 (FILTER_TYPE_SDCH == encoding_types->front())) {
122 SdchManager::SdchErrorRecovery( 106 SdchManager::SdchErrorRecovery(
123 SdchManager::SDCH_CONTENT_ENCODE_FOR_NON_SDCH_REQUEST); 107 SdchManager::SDCH_CONTENT_ENCODE_FOR_NON_SDCH_REQUEST);
124 } 108 }
(...skipping 117 matching lines...) Expand 10 before | Expand all | Expand 10 after
242 226
243 first_filter->next_filter_.reset(filter_list); 227 first_filter->next_filter_.reset(filter_list);
244 return first_filter; 228 return first_filter;
245 } 229 }
246 230
247 Filter::Filter(const FilterContext& filter_context) 231 Filter::Filter(const FilterContext& filter_context)
248 : stream_buffer_(NULL), 232 : stream_buffer_(NULL),
249 stream_buffer_size_(0), 233 stream_buffer_size_(0),
250 next_stream_data_(NULL), 234 next_stream_data_(NULL),
251 stream_data_len_(0), 235 stream_data_len_(0),
252 url_(),
253 connect_time_(),
254 was_cached_(false),
255 mime_type_(),
256 next_filter_(NULL), 236 next_filter_(NULL),
257 last_status_(FILTER_NEED_MORE_DATA), 237 last_status_(FILTER_NEED_MORE_DATA),
258 filter_context_(filter_context) { 238 filter_context_(filter_context) {
259 } 239 }
260 240
261 Filter::~Filter() {} 241 Filter::~Filter() {}
262 242
263 bool Filter::InitBuffer() { 243 bool Filter::InitBuffer() {
264 int buffer_size = filter_context_.GetInputStreambufferSize(); 244 int buffer_size = filter_context_.GetInputStreamBufferSize();
265 DCHECK(buffer_size > 0); 245 DCHECK(buffer_size > 0);
266 if (buffer_size <= 0 || stream_buffer()) 246 if (buffer_size <= 0 || stream_buffer())
267 return false; 247 return false;
268 248
269 stream_buffer_ = new net::IOBuffer(buffer_size); 249 stream_buffer_ = new net::IOBuffer(buffer_size);
270 250
271 if (stream_buffer()) { 251 if (stream_buffer()) {
272 stream_buffer_size_ = buffer_size; 252 stream_buffer_size_ = buffer_size;
273 return true; 253 return true;
274 } 254 }
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after
358 338
359 DCHECK(stream_buffer()); 339 DCHECK(stream_buffer());
360 // Bail out if there is more data in the stream buffer to be filtered. 340 // Bail out if there is more data in the stream buffer to be filtered.
361 if (!stream_buffer() || stream_data_len_) 341 if (!stream_buffer() || stream_data_len_)
362 return false; 342 return false;
363 343
364 next_stream_data_ = stream_buffer()->data(); 344 next_stream_data_ = stream_buffer()->data();
365 stream_data_len_ = stream_data_len; 345 stream_data_len_ = stream_data_len;
366 return true; 346 return true;
367 } 347 }
368
369 void Filter::SetURL(const GURL& url) {
370 url_ = url;
371 if (next_filter_.get())
372 next_filter_->SetURL(url);
373 }
374
375 void Filter::SetMimeType(const std::string& mime_type) {
376 mime_type_ = mime_type;
377 if (next_filter_.get())
378 next_filter_->SetMimeType(mime_type);
379 }
380
381 void Filter::SetConnectTime(const base::Time& time, bool was_cached) {
382 connect_time_ = time;
383 was_cached_ = was_cached;
384 if (next_filter_.get())
385 next_filter_->SetConnectTime(time, was_cached_);
386 }
OLDNEW
« no previous file with comments | « net/base/filter.h ('k') | net/base/filter_unittest.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698