| OLD | NEW |
| 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/quic/chromium/quic_http_stream.h" | 5 #include "net/quic/chromium/quic_http_stream.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/auto_reset.h" | 9 #include "base/auto_reset.h" |
| 10 #include "base/callback_helpers.h" | 10 #include "base/callback_helpers.h" |
| (...skipping 579 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 590 base::Bind(&QuicHttpStream::OnIOComplete, weak_factory_.GetWeakPtr())); | 590 base::Bind(&QuicHttpStream::OnIOComplete, weak_factory_.GetWeakPtr())); |
| 591 } | 591 } |
| 592 | 592 |
| 593 int QuicHttpStream::DoRequestStreamComplete(int rv) { | 593 int QuicHttpStream::DoRequestStreamComplete(int rv) { |
| 594 DCHECK(rv == OK || !stream_); | 594 DCHECK(rv == OK || !stream_); |
| 595 if (rv != OK) { | 595 if (rv != OK) { |
| 596 session_error_ = rv; | 596 session_error_ = rv; |
| 597 return GetResponseStatus(); | 597 return GetResponseStatus(); |
| 598 } | 598 } |
| 599 | 599 |
| 600 stream_ = quic_session()->ReleaseStream(); | 600 stream_ = quic_session()->ReleaseStream(this); |
| 601 stream_->SetDelegate(this); | |
| 602 if (request_info_->load_flags & LOAD_DISABLE_CONNECTION_MIGRATION) { | 601 if (request_info_->load_flags & LOAD_DISABLE_CONNECTION_MIGRATION) { |
| 603 stream_->DisableConnectionMigration(); | 602 stream_->DisableConnectionMigration(); |
| 604 } | 603 } |
| 605 | 604 |
| 606 if (response_info_) { | 605 if (response_info_) { |
| 607 // This happens in the case of a asynchronous push rendezvous | 606 // This happens in the case of a asynchronous push rendezvous |
| 608 // that ultimately fails (e.g. vary failure). |response_info_| | 607 // that ultimately fails (e.g. vary failure). |response_info_| |
| 609 // non-null implies that |DoRequestStream()| was called via | 608 // non-null implies that |DoRequestStream()| was called via |
| 610 // |SendRequest()|. | 609 // |SendRequest()|. |
| 611 next_state_ = STATE_SET_REQUEST_PRIORITY; | 610 next_state_ = STATE_SET_REQUEST_PRIORITY; |
| (...skipping 220 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 832 quic_stream_error_ != QUIC_STREAM_CONNECTION_ERROR) { | 831 quic_stream_error_ != QUIC_STREAM_CONNECTION_ERROR) { |
| 833 return ERR_QUIC_PROTOCOL_ERROR; | 832 return ERR_QUIC_PROTOCOL_ERROR; |
| 834 } | 833 } |
| 835 | 834 |
| 836 DCHECK_NE(QUIC_HANDSHAKE_TIMEOUT, quic_connection_error_); | 835 DCHECK_NE(QUIC_HANDSHAKE_TIMEOUT, quic_connection_error_); |
| 837 | 836 |
| 838 return ERR_QUIC_PROTOCOL_ERROR; | 837 return ERR_QUIC_PROTOCOL_ERROR; |
| 839 } | 838 } |
| 840 | 839 |
| 841 } // namespace net | 840 } // namespace net |
| OLD | NEW |