| Index: net/quic/chromium/quic_chromium_client_session.cc
|
| diff --git a/net/quic/chromium/quic_chromium_client_session.cc b/net/quic/chromium/quic_chromium_client_session.cc
|
| index 9d586835a06a7642bc602cc248e29754485ceb92..8cdbf2b5703f49ea27d6575380c67f3434fc2d26 100644
|
| --- a/net/quic/chromium/quic_chromium_client_session.cc
|
| +++ b/net/quic/chromium/quic_chromium_client_session.cc
|
| @@ -250,6 +250,12 @@ QuicChromiumClientSession::QuicChromiumClientSession(
|
| std::unique_ptr<SocketPerformanceWatcher> socket_performance_watcher,
|
| NetLog* net_log)
|
| : QuicClientSessionBase(connection, push_promise_index, config),
|
| + received_go_away_(false),
|
| + received_read_error_(false),
|
| + connection_closed_(false),
|
| + notified_session_going_away_(false),
|
| + notified_session_closed_later_(false),
|
| + notified_session_closed_(false),
|
| server_id_(server_id),
|
| require_confirmation_(require_confirmation),
|
| stream_factory_(stream_factory),
|
| @@ -926,6 +932,7 @@ void QuicChromiumClientSession::OnCryptoHandshakeMessageReceived(
|
| }
|
|
|
| void QuicChromiumClientSession::OnGoAway(const QuicGoAwayFrame& frame) {
|
| + received_go_away_ = true;
|
| QuicSession::OnGoAway(frame);
|
| NotifyFactoryOfSessionGoingAway();
|
| port_migration_detected_ = frame.error_code == QUIC_ERROR_MIGRATING_PORT;
|
| @@ -940,6 +947,7 @@ void QuicChromiumClientSession::OnConnectionClosed(
|
| QuicErrorCode error,
|
| const std::string& error_details,
|
| ConnectionCloseSource source) {
|
| + connection_closed_ = true;
|
| DCHECK(!connection()->connected());
|
| logger_->OnConnectionClosed(error, error_details, source);
|
| if (source == ConnectionCloseSource::FROM_PEER) {
|
| @@ -1336,6 +1344,7 @@ QuicChromiumClientSession::GetWeakPtr() {
|
| void QuicChromiumClientSession::OnReadError(
|
| int result,
|
| const DatagramClientSocket* socket) {
|
| + received_read_error_ = true;
|
| DCHECK(socket != nullptr);
|
| if (socket != GetDefaultSocket()) {
|
| // Ignore read errors from old sockets that are no longer active.
|
| @@ -1363,12 +1372,14 @@ bool QuicChromiumClientSession::OnPacket(const QuicReceivedPacket& packet,
|
| }
|
|
|
| void QuicChromiumClientSession::NotifyFactoryOfSessionGoingAway() {
|
| + notified_session_going_away_ = true;
|
| going_away_ = true;
|
| if (stream_factory_)
|
| stream_factory_->OnSessionGoingAway(this);
|
| }
|
|
|
| void QuicChromiumClientSession::NotifyFactoryOfSessionClosedLater() {
|
| + notified_session_closed_later_ = true;
|
| if (!dynamic_streams().empty())
|
| RecordUnexpectedOpenStreams(NOTIFY_FACTORY_OF_SESSION_CLOSED_LATER);
|
|
|
| @@ -1385,6 +1396,7 @@ void QuicChromiumClientSession::NotifyFactoryOfSessionClosedLater() {
|
| }
|
|
|
| void QuicChromiumClientSession::NotifyFactoryOfSessionClosed() {
|
| + notified_session_closed_ = true;
|
| if (!dynamic_streams().empty())
|
| RecordUnexpectedOpenStreams(NOTIFY_FACTORY_OF_SESSION_CLOSED);
|
|
|
|
|