| 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_chromium_client_session.h" | 5 #include "net/quic/chromium/quic_chromium_client_session.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/callback_helpers.h" | 9 #include "base/callback_helpers.h" |
| 10 #include "base/location.h" | 10 #include "base/location.h" |
| (...skipping 930 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 941 CloseAllObservers(ERR_UNEXPECTED); | 941 CloseAllObservers(ERR_UNEXPECTED); |
| 942 NotifyFactoryOfSessionClosedLater(); | 942 NotifyFactoryOfSessionClosedLater(); |
| 943 } | 943 } |
| 944 | 944 |
| 945 void QuicChromiumClientSession::OnSuccessfulVersionNegotiation( | 945 void QuicChromiumClientSession::OnSuccessfulVersionNegotiation( |
| 946 const QuicVersion& version) { | 946 const QuicVersion& version) { |
| 947 logger_->OnSuccessfulVersionNegotiation(version); | 947 logger_->OnSuccessfulVersionNegotiation(version); |
| 948 QuicSpdySession::OnSuccessfulVersionNegotiation(version); | 948 QuicSpdySession::OnSuccessfulVersionNegotiation(version); |
| 949 } | 949 } |
| 950 | 950 |
| 951 int QuicChromiumClientSession::OnWriteError( | 951 int QuicChromiumClientSession::HandleWriteError( |
| 952 int error_code, | 952 int error_code, |
| 953 scoped_refptr<StringIOBuffer> packet) { | 953 scoped_refptr<StringIOBuffer> packet) { |
| 954 DCHECK(packet != nullptr); | 954 DCHECK(packet != nullptr); |
| 955 use_error_code_from_rewrite_ = false; | 955 use_error_code_from_rewrite_ = false; |
| 956 if (stream_factory_) { | 956 if (stream_factory_) { |
| 957 stream_factory_->MaybeMigrateSingleSession(this, WRITE_ERROR, packet); | 957 stream_factory_->MaybeMigrateSingleSession(this, WRITE_ERROR, packet); |
| 958 } | 958 } |
| 959 return use_error_code_from_rewrite_ ? error_code_from_rewrite_ : error_code; | 959 return use_error_code_from_rewrite_ ? error_code_from_rewrite_ : error_code; |
| 960 } | 960 } |
| 961 | 961 |
| 962 void QuicChromiumClientSession::OnWriteError(int error_code) { |
| 963 DCHECK_NE(ERR_IO_PENDING, error_code); |
| 964 DCHECK_GT(0, error_code); |
| 965 connection()->OnWriteError(error_code); |
| 966 } |
| 967 |
| 968 void QuicChromiumClientSession::OnWriteUnblocked() { |
| 969 connection()->OnCanWrite(); |
| 970 } |
| 971 |
| 962 void QuicChromiumClientSession::OnPathDegrading() { | 972 void QuicChromiumClientSession::OnPathDegrading() { |
| 963 if (stream_factory_) { | 973 if (stream_factory_) { |
| 964 stream_factory_->MaybeMigrateSingleSession(this, EARLY_MIGRATION, nullptr); | 974 stream_factory_->MaybeMigrateSingleSession(this, EARLY_MIGRATION, nullptr); |
| 965 } | 975 } |
| 966 } | 976 } |
| 967 | 977 |
| 968 bool QuicChromiumClientSession::HasOpenDynamicStreams() const { | 978 bool QuicChromiumClientSession::HasOpenDynamicStreams() const { |
| 969 return QuicSession::HasOpenDynamicStreams() || | 979 return QuicSession::HasOpenDynamicStreams() || |
| 970 GetNumDrainingOutgoingStreams() > 0; | 980 GetNumDrainingOutgoingStreams() > 0; |
| 971 } | 981 } |
| (...skipping 255 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1227 } | 1237 } |
| 1228 | 1238 |
| 1229 void QuicChromiumClientSession::DeletePromised( | 1239 void QuicChromiumClientSession::DeletePromised( |
| 1230 QuicClientPromisedInfo* promised) { | 1240 QuicClientPromisedInfo* promised) { |
| 1231 if (IsOpenStream(promised->id())) | 1241 if (IsOpenStream(promised->id())) |
| 1232 streams_pushed_and_claimed_count_++; | 1242 streams_pushed_and_claimed_count_++; |
| 1233 QuicClientSessionBase::DeletePromised(promised); | 1243 QuicClientSessionBase::DeletePromised(promised); |
| 1234 } | 1244 } |
| 1235 | 1245 |
| 1236 } // namespace net | 1246 } // namespace net |
| OLD | NEW |