OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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/http/bidirectional_stream.h" | 5 #include "net/http/bidirectional_stream.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 #include <utility> | 8 #include <utility> |
9 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
(...skipping 102 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
113 FROM_HERE, | 113 FROM_HERE, |
114 base::Bind(&BidirectionalStream::NotifyFailed, | 114 base::Bind(&BidirectionalStream::NotifyFailed, |
115 weak_factory_.GetWeakPtr(), ERR_DISALLOWED_URL_SCHEME)); | 115 weak_factory_.GetWeakPtr(), ERR_DISALLOWED_URL_SCHEME)); |
116 return; | 116 return; |
117 } | 117 } |
118 | 118 |
119 HttpRequestInfo http_request_info; | 119 HttpRequestInfo http_request_info; |
120 http_request_info.url = request_info_->url; | 120 http_request_info.url = request_info_->url; |
121 http_request_info.method = request_info_->method; | 121 http_request_info.method = request_info_->method; |
122 http_request_info.extra_headers = request_info_->extra_headers; | 122 http_request_info.extra_headers = request_info_->extra_headers; |
123 stream_request_.reset( | 123 stream_request_ = |
124 session->http_stream_factory()->RequestBidirectionalStreamImpl( | 124 session->http_stream_factory()->RequestBidirectionalStreamImpl( |
125 http_request_info, request_info_->priority, server_ssl_config, | 125 http_request_info, request_info_->priority, server_ssl_config, |
126 server_ssl_config, this, | 126 server_ssl_config, this, |
127 /* enable_ip_based_pooling = */ true, | 127 /* enable_ip_based_pooling = */ true, |
128 /* enable_alternative_services = */ true, net_log_)); | 128 /* enable_alternative_services = */ true, net_log_); |
129 // Check that this call cannot fail to set a non-NULL |stream_request_|. | 129 // Check that this call cannot fail to set a non-NULL |stream_request_|. |
130 DCHECK(stream_request_); | 130 DCHECK(stream_request_); |
131 // Check that HttpStreamFactory does not invoke OnBidirectionalStreamImplReady | 131 // Check that HttpStreamFactory does not invoke OnBidirectionalStreamImplReady |
132 // synchronously. | 132 // synchronously. |
133 DCHECK(!stream_impl_); | 133 DCHECK(!stream_impl_); |
134 } | 134 } |
135 | 135 |
136 BidirectionalStream::~BidirectionalStream() { | 136 BidirectionalStream::~BidirectionalStream() { |
137 UpdateHistograms(); | 137 UpdateHistograms(); |
138 if (net_log_.IsCapturing()) { | 138 if (net_log_.IsCapturing()) { |
(...skipping 288 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
427 "Net.BidirectionalStream.TimeToSendEnd.QUIC", | 427 "Net.BidirectionalStream.TimeToSendEnd.QUIC", |
428 load_timing_info_.send_end - load_timing_info_.request_start); | 428 load_timing_info_.send_end - load_timing_info_.request_start); |
429 UMA_HISTOGRAM_COUNTS("Net.BidirectionalStream.ReceivedBytes.QUIC", | 429 UMA_HISTOGRAM_COUNTS("Net.BidirectionalStream.ReceivedBytes.QUIC", |
430 stream_impl_->GetTotalReceivedBytes()); | 430 stream_impl_->GetTotalReceivedBytes()); |
431 UMA_HISTOGRAM_COUNTS("Net.BidirectionalStream.SentBytes.QUIC", | 431 UMA_HISTOGRAM_COUNTS("Net.BidirectionalStream.SentBytes.QUIC", |
432 stream_impl_->GetTotalSentBytes()); | 432 stream_impl_->GetTotalSentBytes()); |
433 } | 433 } |
434 } | 434 } |
435 | 435 |
436 } // namespace net | 436 } // namespace net |
OLD | NEW |