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

Side by Side Diff: net/http/http_network_transaction.cc

Issue 1326503003: Added a net::BidirectionalStream to expose a bidirectional streaming interface (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Pass through priority and netlog Created 5 years, 2 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
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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/http_network_transaction.h" 5 #include "net/http/http_network_transaction.h"
6 6
7 #include <set> 7 #include <set>
8 #include <vector> 8 #include <vector>
9 9
10 #include "base/bind.h" 10 #include "base/bind.h"
(...skipping 492 matching lines...) Expand 10 before | Expand all | Expand 10 after
503 response_.was_npn_negotiated = stream_request_->was_npn_negotiated(); 503 response_.was_npn_negotiated = stream_request_->was_npn_negotiated();
504 response_.npn_negotiated_protocol = SSLClientSocket::NextProtoToString( 504 response_.npn_negotiated_protocol = SSLClientSocket::NextProtoToString(
505 stream_request_->protocol_negotiated()); 505 stream_request_->protocol_negotiated());
506 response_.was_fetched_via_spdy = stream_request_->using_spdy(); 506 response_.was_fetched_via_spdy = stream_request_->using_spdy();
507 response_.was_fetched_via_proxy = !proxy_info_.is_direct(); 507 response_.was_fetched_via_proxy = !proxy_info_.is_direct();
508 if (response_.was_fetched_via_proxy && !proxy_info_.is_empty()) 508 if (response_.was_fetched_via_proxy && !proxy_info_.is_empty())
509 response_.proxy_server = proxy_info_.proxy_server().host_port_pair(); 509 response_.proxy_server = proxy_info_.proxy_server().host_port_pair();
510 OnIOComplete(OK); 510 OnIOComplete(OK);
511 } 511 }
512 512
513 void HttpNetworkTransaction::OnBidirectionalStreamReady(
514 const SSLConfig& used_ssl_config,
515 const ProxyInfo& used_proxy_info,
516 BidirectionalStream* stream) {
517 NOTREACHED();
518 }
519
513 void HttpNetworkTransaction::OnWebSocketHandshakeStreamReady( 520 void HttpNetworkTransaction::OnWebSocketHandshakeStreamReady(
514 const SSLConfig& used_ssl_config, 521 const SSLConfig& used_ssl_config,
515 const ProxyInfo& used_proxy_info, 522 const ProxyInfo& used_proxy_info,
516 WebSocketHandshakeStreamBase* stream) { 523 WebSocketHandshakeStreamBase* stream) {
517 OnStreamReady(used_ssl_config, used_proxy_info, stream); 524 OnStreamReady(used_ssl_config, used_proxy_info, stream);
518 } 525 }
519 526
520 void HttpNetworkTransaction::OnStreamFailed(int result, 527 void HttpNetworkTransaction::OnStreamFailed(int result,
521 const SSLConfig& used_ssl_config, 528 const SSLConfig& used_ssl_config,
522 SSLFailureState ssl_failure_state) { 529 SSLFailureState ssl_failure_state) {
(...skipping 1149 matching lines...) Expand 10 before | Expand all | Expand 10 after
1672 DCHECK(stream_request_); 1679 DCHECK(stream_request_);
1673 1680
1674 // Since the transaction can restart with auth credentials, it may create a 1681 // Since the transaction can restart with auth credentials, it may create a
1675 // stream more than once. Accumulate all of the connection attempts across 1682 // stream more than once. Accumulate all of the connection attempts across
1676 // those streams by appending them to the vector: 1683 // those streams by appending them to the vector:
1677 for (const auto& attempt : stream_request_->connection_attempts()) 1684 for (const auto& attempt : stream_request_->connection_attempts())
1678 connection_attempts_.push_back(attempt); 1685 connection_attempts_.push_back(attempt);
1679 } 1686 }
1680 1687
1681 } // namespace net 1688 } // namespace net
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698