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/quic_client_session.h" | 5 #include "net/quic/quic_client_session.h" |
6 | 6 |
7 #include "base/callback_helpers.h" | 7 #include "base/callback_helpers.h" |
8 #include "base/message_loop/message_loop.h" | 8 #include "base/message_loop/message_loop.h" |
9 #include "base/metrics/histogram.h" | 9 #include "base/metrics/histogram.h" |
10 #include "base/metrics/sparse_histogram.h" | 10 #include "base/metrics/sparse_histogram.h" |
(...skipping 545 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
556 request->OnRequestCompleteSuccess(CreateOutgoingReliableStreamImpl()); | 556 request->OnRequestCompleteSuccess(CreateOutgoingReliableStreamImpl()); |
557 } | 557 } |
558 | 558 |
559 if (GetNumOpenStreams() == 0) { | 559 if (GetNumOpenStreams() == 0) { |
560 stream_factory_->OnIdleSession(this); | 560 stream_factory_->OnIdleSession(this); |
561 } | 561 } |
562 } | 562 } |
563 | 563 |
564 void QuicClientSession::OnCryptoHandshakeEvent(CryptoHandshakeEvent event) { | 564 void QuicClientSession::OnCryptoHandshakeEvent(CryptoHandshakeEvent event) { |
565 if (!callback_.is_null() && | 565 if (!callback_.is_null() && |
566 (!require_confirmation_ || event == HANDSHAKE_CONFIRMED)) { | 566 (!require_confirmation_ || |
| 567 event == HANDSHAKE_CONFIRMED || event == ENCRYPTION_REESTABLISHED)) { |
567 // TODO(rtenneti): Currently for all CryptoHandshakeEvent events, callback_ | 568 // TODO(rtenneti): Currently for all CryptoHandshakeEvent events, callback_ |
568 // could be called because there are no error events in CryptoHandshakeEvent | 569 // could be called because there are no error events in CryptoHandshakeEvent |
569 // enum. If error events are added to CryptoHandshakeEvent, then the | 570 // enum. If error events are added to CryptoHandshakeEvent, then the |
570 // following code needs to changed. | 571 // following code needs to changed. |
571 base::ResetAndReturn(&callback_).Run(OK); | 572 base::ResetAndReturn(&callback_).Run(OK); |
572 } | 573 } |
573 if (event == HANDSHAKE_CONFIRMED) { | 574 if (event == HANDSHAKE_CONFIRMED) { |
574 UMA_HISTOGRAM_TIMES("Net.QuicSession.HandshakeConfirmedTime", | 575 UMA_HISTOGRAM_TIMES("Net.QuicSession.HandshakeConfirmedTime", |
575 base::TimeTicks::Now() - handshake_start_); | 576 base::TimeTicks::Now() - handshake_start_); |
576 ObserverSet::iterator it = observers_.begin(); | 577 ObserverSet::iterator it = observers_.begin(); |
(...skipping 299 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
876 return; | 877 return; |
877 | 878 |
878 // TODO(rch): re-enable this code once beta is cut. | 879 // TODO(rch): re-enable this code once beta is cut. |
879 // if (stream_factory_) | 880 // if (stream_factory_) |
880 // stream_factory_->OnSessionConnectTimeout(this); | 881 // stream_factory_->OnSessionConnectTimeout(this); |
881 // CloseAllStreams(ERR_QUIC_HANDSHAKE_FAILED); | 882 // CloseAllStreams(ERR_QUIC_HANDSHAKE_FAILED); |
882 // DCHECK_EQ(0u, GetNumOpenStreams()); | 883 // DCHECK_EQ(0u, GetNumOpenStreams()); |
883 } | 884 } |
884 | 885 |
885 } // namespace net | 886 } // namespace net |
OLD | NEW |