[Domain Reliabiliy: net stack] Plumb received go away from server due to connection migration.

net/quic/quic_chromium_client_session.h

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 //
 // A client specific QuicSession subclass.  This class owns the underlying
 // QuicConnection and QuicConnectionHelper objects.  The connection stores
 // a non-owning pointer to the helper so this session needs to ensure that
 // the helper outlives the connection.
 
 #ifndef NET_QUIC_QUIC_CHROMIUM_CLIENT_SESSION_H_
 #define NET_QUIC_QUIC_CHROMIUM_CLIENT_SESSION_H_
 
 #include <stddef.h>
 
 #include <string>
 
 #include "base/containers/hash_tables.h"
 #include "base/containers/mru_cache.h"
 #include "base/macros.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/time/time.h"
 #include "net/base/completion_callback.h"
+#include "net/base/net_error_details.h"
 #include "net/base/socket_performance_watcher.h"
 #include "net/cert/ct_verify_result.h"
 #include "net/proxy/proxy_server.h"
 #include "net/quic/quic_chromium_client_stream.h"
 #include "net/quic/quic_chromium_packet_reader.h"
 #include "net/quic/quic_client_session_base.h"
 #include "net/quic/quic_connection_logger.h"
 #include "net/quic/quic_crypto_client_stream.h"
 #include "net/quic/quic_protocol.h"
 #include "net/quic/quic_time.h"
@@ skipping 31 matching lines @@
     QUIC_DISABLED_TIMEOUT_WITH_OPEN_STREAMS = 2,
     QUIC_DISABLED_BAD_PACKET_LOSS_RATE = 3,
     QUIC_DISABLED_MAX = 4,
   };
 
   // An interface for observing events on a session.
   class NET_EXPORT_PRIVATE Observer {
    public:
     virtual ~Observer() {}
     virtual void OnCryptoHandshakeConfirmed() = 0;
-    virtual void OnSessionClosed(int error) = 0;
+    virtual void OnSessionClosed(int error, bool port_migration_detected) = 0;
   };
 
   // A helper class used to manage a request to create a stream.
   class NET_EXPORT_PRIVATE StreamRequest {
    public:
     StreamRequest();
     ~StreamRequest();
 
     // Starts a request to create a stream.  If OK is returned, then
     // |stream| will be updated with the newly created stream.  If
@@ skipping 156 matching lines @@
   // Migrates session onto new socket, i.e., starts reading from |socket|
   // in addition to any previous sockets, and sets |writer| to be the new
   // default writer. Returns true if socket was successfully added to the
   // session and the session was successfully migrated to using the new socket.
   // Returns false if number of migrations exceeds kMaxReadersPerQuicSession.
   // Takes ownership of |socket|, |reader|, and |writer|.
   bool MigrateToSocket(scoped_ptr<DatagramClientSocket> socket,
                        scoped_ptr<QuicChromiumPacketReader> reader,
                        scoped_ptr<QuicPacketWriter> writer);
 
+  // Populates network error details for this session.
+  void PopulateNetErrorDetails(NetErrorDetails* details);
+
   // Returns current default socket. This is the socket over which all
   // QUIC packets are sent. This default socket can change, so do not store the
   // returned socket.
   const DatagramClientSocket* GetDefaultSocket() const;
 
   bool IsAuthorized(const std::string& hostname) override;
 
   // Returns true if session has one ore more streams marked as non-migratable.
   bool HasNonMigratableStreams() const;
 
@@ skipping 60 matching lines @@
   size_t num_total_streams_;
   base::TaskRunner* task_runner_;
   BoundNetLog net_log_;
   std::vector<scoped_ptr<QuicChromiumPacketReader>> packet_readers_;
   base::TimeTicks dns_resolution_end_time_;
   base::TimeTicks handshake_start_;  // Time the handshake was started.
   scoped_ptr<QuicConnectionLogger> logger_;
   // True when the session is going away, and streams may no longer be created
   // on this session. Existing stream will continue to be processed.
   bool going_away_;
+  // True when the session receives a go away from server due to port migration.
+  bool port_migration_detected_;
   QuicDisabledReason disabled_reason_;
   TokenBindingSignatureMap token_binding_signatures_;
   base::WeakPtrFactory<QuicChromiumClientSession> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(QuicChromiumClientSession);
 };
 
 }  // namespace net
 
 #endif  // NET_QUIC_QUIC_CHROMIUM_CLIENT_SESSION_H_