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 496 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
507 session_error_ = error; | 507 session_error_ = error; |
508 SaveResponseStatus(); | 508 SaveResponseStatus(); |
509 if (in_loop_) { | 509 if (in_loop_) { |
510 // If already in DoLoop(), |callback_| will be handled when DoLoop() exits. | 510 // If already in DoLoop(), |callback_| will be handled when DoLoop() exits. |
511 return; | 511 return; |
512 } | 512 } |
513 if (!callback_.is_null()) | 513 if (!callback_.is_null()) |
514 DoCallback(GetResponseStatus()); | 514 DoCallback(GetResponseStatus()); |
515 } | 515 } |
516 | 516 |
517 bool QuicHttpStream::HasSendHeadersComplete() { | |
518 return next_state_ > STATE_SEND_HEADERS_COMPLETE; | |
519 } | |
520 | |
521 void QuicHttpStream::OnCryptoHandshakeConfirmed() { | 517 void QuicHttpStream::OnCryptoHandshakeConfirmed() { |
522 was_handshake_confirmed_ = true; | 518 was_handshake_confirmed_ = true; |
523 } | 519 } |
524 | 520 |
525 void QuicHttpStream::OnSuccessfulVersionNegotiation( | 521 void QuicHttpStream::OnSuccessfulVersionNegotiation( |
526 const QuicVersion& version) { | 522 const QuicVersion& version) { |
527 quic_version_ = version; | 523 quic_version_ = version; |
528 } | 524 } |
529 | 525 |
530 void QuicHttpStream::OnSessionClosed(int error, bool port_migration_detected) { | 526 void QuicHttpStream::OnSessionClosed(int error, bool port_migration_detected) { |
(...skipping 330 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
861 quic_stream_error_ != QUIC_STREAM_CONNECTION_ERROR) { | 857 quic_stream_error_ != QUIC_STREAM_CONNECTION_ERROR) { |
862 return ERR_QUIC_PROTOCOL_ERROR; | 858 return ERR_QUIC_PROTOCOL_ERROR; |
863 } | 859 } |
864 | 860 |
865 DCHECK_NE(QUIC_HANDSHAKE_TIMEOUT, quic_connection_error_); | 861 DCHECK_NE(QUIC_HANDSHAKE_TIMEOUT, quic_connection_error_); |
866 | 862 |
867 return ERR_QUIC_PROTOCOL_ERROR; | 863 return ERR_QUIC_PROTOCOL_ERROR; |
868 } | 864 } |
869 | 865 |
870 } // namespace net | 866 } // namespace net |
OLD | NEW |