Index: net/http/http_basic_stream.cc |
=================================================================== |
--- net/http/http_basic_stream.cc (revision 90388) |
+++ net/http/http_basic_stream.cc (working copy) |
@@ -4,8 +4,6 @@ |
#include "net/http/http_basic_stream.h" |
-#include "base/format_macros.h" |
-#include "base/metrics/histogram.h" |
#include "base/stringprintf.h" |
#include "net/base/io_buffer.h" |
#include "net/base/net_errors.h" |
@@ -14,7 +12,6 @@ |
#include "net/http/http_stream_parser.h" |
#include "net/http/http_util.h" |
#include "net/socket/client_socket_handle.h" |
-#include "net/socket/client_socket_pool_base.h" |
namespace net { |
@@ -37,7 +34,6 @@ |
request_info_ = request_info; |
parser_.reset(new HttpStreamParser(connection_.get(), request_info, |
read_buf_, net_log)); |
- bytes_read_offset_ = connection_->socket()->NumBytesRead(); |
return OK; |
} |
@@ -54,7 +50,6 @@ |
request_line_ = base::StringPrintf("%s %s HTTP/1.1\r\n", |
request_info_->method.c_str(), |
path.c_str()); |
- response_ = response; |
return parser_->SendRequest(request_line_, headers, request_body, response, |
callback); |
} |
@@ -124,45 +119,4 @@ |
return false; |
} |
-void HttpBasicStream::LogNumRttVsBytesMetrics() const { |
- int socket_reuse_policy = GetSocketReusePolicy(); |
- if (socket_reuse_policy > 2 || socket_reuse_policy < 0) { |
- LOG(ERROR) << "Invalid socket reuse policy"; |
- return; |
- } |
- |
- int64 total_bytes_read = connection_->socket()->NumBytesRead(); |
- int64 bytes_received = total_bytes_read - bytes_read_offset_; |
- int64 num_kb = bytes_received / 1024; |
- double rtt = connection_->socket()->GetConnectTimeMicros().ToInternalValue(); |
- rtt /= 1000.0; |
- |
- if (num_kb < 1024 && rtt > 0) { // Ignore responses > 1MB |
- base::TimeDelta duration = base::Time::Now() - |
- response_->request_time; |
- double num_rtt = static_cast<double>(duration.InMilliseconds()) / rtt; |
- int64 num_rtt_scaled = (4 * num_rtt); |
- |
- static const char* const kGroups[] = { |
- "warmest_socket", "warm_socket", "last_accessed_socket" |
- }; |
- int bucket = (num_kb / 5) * 5; |
- const std::string histogram(StringPrintf("Net.Num_RTT_vs_KB_%s_%dKB", |
- kGroups[socket_reuse_policy], |
- bucket)); |
- base::Histogram* counter = base::Histogram::FactoryGet( |
- histogram, 0, 1000, 2, base::Histogram::kUmaTargetedHistogramFlag); |
- DCHECK_EQ(histogram, counter->histogram_name()); |
- counter->Add(num_rtt_scaled); |
- |
- VLOG(2) << StringPrintf("%s\nrtt = %f\tnum_rtt = %f\t" |
- "num_kb = %" PRId64 "\t" |
- "total bytes = %" PRId64 "\t" |
- "histogram = %s", |
- request_line_.data(), |
- rtt, num_rtt, num_kb, total_bytes_read, |
- histogram.data()); |
- } |
-} |
- |
} // namespace net |
Property changes on: net/http/http_basic_stream.cc |
___________________________________________________________________ |
Added: svn:mergeinfo |