| 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 <memory> | 7 #include <memory> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/location.h" | 10 #include "base/location.h" |
| (...skipping 136 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 147 const SpdyHeaderBlock& response_headers) { | 147 const SpdyHeaderBlock& response_headers) { |
| 148 HttpResponseInfo response_info; | 148 HttpResponseInfo response_info; |
| 149 if (!SpdyHeadersToHttpResponse(response_headers, HTTP2, &response_info)) { | 149 if (!SpdyHeadersToHttpResponse(response_headers, HTTP2, &response_info)) { |
| 150 DLOG(WARNING) << "Invalid headers"; | 150 DLOG(WARNING) << "Invalid headers"; |
| 151 delegate_->OnFailed(ERR_FAILED); | 151 delegate_->OnFailed(ERR_FAILED); |
| 152 return; | 152 return; |
| 153 } | 153 } |
| 154 | 154 |
| 155 session_->http_stream_factory()->ProcessAlternativeServices( | 155 session_->http_stream_factory()->ProcessAlternativeServices( |
| 156 session_, response_info.headers.get(), | 156 session_, response_info.headers.get(), |
| 157 HostPortPair::FromURL(request_info_->url)); | 157 url::SchemeHostPort(request_info_->url)); |
| 158 delegate_->OnHeadersReceived(response_headers); | 158 delegate_->OnHeadersReceived(response_headers); |
| 159 } | 159 } |
| 160 | 160 |
| 161 void BidirectionalStream::OnDataRead(int bytes_read) { | 161 void BidirectionalStream::OnDataRead(int bytes_read) { |
| 162 DCHECK(read_buffer_); | 162 DCHECK(read_buffer_); |
| 163 | 163 |
| 164 net_log_.AddByteTransferEvent( | 164 net_log_.AddByteTransferEvent( |
| 165 NetLog::TYPE_BIDIRECTIONAL_STREAM_BYTES_RECEIVED, bytes_read, | 165 NetLog::TYPE_BIDIRECTIONAL_STREAM_BYTES_RECEIVED, bytes_read, |
| 166 read_buffer_->data()); | 166 read_buffer_->data()); |
| 167 read_buffer_ = nullptr; | 167 read_buffer_ = nullptr; |
| (...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 253 const ProxyInfo& used_proxy_info, | 253 const ProxyInfo& used_proxy_info, |
| 254 HttpStream* stream) { | 254 HttpStream* stream) { |
| 255 DCHECK(stream_request_); | 255 DCHECK(stream_request_); |
| 256 | 256 |
| 257 delegate_->OnFailed(ERR_HTTPS_PROXY_TUNNEL_RESPONSE); | 257 delegate_->OnFailed(ERR_HTTPS_PROXY_TUNNEL_RESPONSE); |
| 258 } | 258 } |
| 259 | 259 |
| 260 void BidirectionalStream::OnQuicBroken() {} | 260 void BidirectionalStream::OnQuicBroken() {} |
| 261 | 261 |
| 262 } // namespace net | 262 } // namespace net |
| OLD | NEW |