| // 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. |
| |
| #ifndef QUICHE_QUIC_CORE_HTTP_QUIC_SPDY_CLIENT_SESSION_H_ |
| #define QUICHE_QUIC_CORE_HTTP_QUIC_SPDY_CLIENT_SESSION_H_ |
| |
| #include <memory> |
| #include <string> |
| |
| #include "quiche/quic/core/http/quic_spdy_client_session_base.h" |
| #include "quiche/quic/core/http/quic_spdy_client_stream.h" |
| #include "quiche/quic/core/quic_crypto_client_stream.h" |
| #include "quiche/quic/core/quic_packets.h" |
| |
| namespace quic { |
| |
| class QuicConnection; |
| class QuicServerId; |
| |
| class QUICHE_EXPORT QuicSpdyClientSession : public QuicSpdyClientSessionBase { |
| public: |
| // Takes ownership of |connection|. |
| QuicSpdyClientSession(const QuicConfig& config, |
| const ParsedQuicVersionVector& supported_versions, |
| QuicConnection* connection, |
| const QuicServerId& server_id, |
| QuicCryptoClientConfig* crypto_config); |
| |
| QuicSpdyClientSession(const QuicConfig& config, |
| const ParsedQuicVersionVector& supported_versions, |
| QuicConnection* connection, |
| QuicSession::Visitor* visitor, |
| const QuicServerId& server_id, |
| QuicCryptoClientConfig* crypto_config); |
| |
| QuicSpdyClientSession(const QuicSpdyClientSession&) = delete; |
| QuicSpdyClientSession& operator=(const QuicSpdyClientSession&) = delete; |
| ~QuicSpdyClientSession() override; |
| // Set up the QuicSpdyClientSession. Must be called prior to use. |
| void Initialize() override; |
| |
| // QuicSession methods: |
| QuicSpdyClientStream* CreateOutgoingBidirectionalStream() override; |
| QuicSpdyClientStream* CreateOutgoingUnidirectionalStream() override; |
| QuicCryptoClientStreamBase* GetMutableCryptoStream() override; |
| const QuicCryptoClientStreamBase* GetCryptoStream() const override; |
| |
| // QuicSpdyClientSessionBase methods: |
| void OnProofValid(const QuicCryptoClientConfig::CachedState& cached) override; |
| void OnProofVerifyDetailsAvailable( |
| const ProofVerifyDetails& verify_details) override; |
| |
| // Performs a crypto handshake with the server. |
| virtual void CryptoConnect(); |
| |
| // Returns the number of client hello messages that have been sent on the |
| // crypto stream. If the handshake has completed then this is one greater |
| // than the number of round-trips needed for the handshake. |
| int GetNumSentClientHellos() const; |
| |
| // Return true if the client attempted a TLS resumption. |
| // Always return false for QUIC Crypto. |
| bool ResumptionAttempted() const; |
| |
| // Return true if the handshake performed is a TLS resumption. |
| // Always return false for QUIC Crypto. |
| bool IsResumption() const; |
| |
| // Returns true if early data (0-RTT data) was sent and the server accepted |
| // it. |
| bool EarlyDataAccepted() const; |
| |
| // Returns true if the handshake was delayed one round trip by the server |
| // because the server wanted proof the client controls its source address |
| // before progressing further. In Google QUIC, this would be due to an |
| // inchoate REJ in the QUIC Crypto handshake; in IETF QUIC this would be due |
| // to a Retry packet. |
| // TODO(nharper): Consider a better name for this method. |
| bool ReceivedInchoateReject() const; |
| |
| int GetNumReceivedServerConfigUpdates() const; |
| |
| using QuicSession::CanOpenNextOutgoingBidirectionalStream; |
| |
| void set_respect_goaway(bool respect_goaway) { |
| respect_goaway_ = respect_goaway; |
| } |
| |
| QuicSSLConfig GetSSLConfig() const override { |
| return crypto_config_->ssl_config(); |
| } |
| |
| protected: |
| // QuicSession methods: |
| QuicSpdyStream* CreateIncomingStream(QuicStreamId id) override; |
| QuicSpdyStream* CreateIncomingStream(PendingStream* pending) override; |
| // If an outgoing stream can be created, return true. |
| bool ShouldCreateOutgoingBidirectionalStream() override; |
| bool ShouldCreateOutgoingUnidirectionalStream() override; |
| |
| // If an incoming stream can be created, return true. |
| // TODO(fayang): move this up to QuicSpdyClientSessionBase. |
| bool ShouldCreateIncomingStream(QuicStreamId id) override; |
| |
| // Create the crypto stream. Called by Initialize(). |
| virtual std::unique_ptr<QuicCryptoClientStreamBase> CreateQuicCryptoStream(); |
| |
| // Unlike CreateOutgoingBidirectionalStream, which applies a bunch of |
| // sanity checks, this simply returns a new QuicSpdyClientStream. This may be |
| // used by subclasses which want to use a subclass of QuicSpdyClientStream for |
| // streams but wish to use the sanity checks in |
| // CreateOutgoingBidirectionalStream. |
| virtual std::unique_ptr<QuicSpdyClientStream> CreateClientStream(); |
| |
| const QuicServerId& server_id() const { return server_id_; } |
| QuicCryptoClientConfig* crypto_config() { return crypto_config_; } |
| |
| private: |
| std::unique_ptr<QuicCryptoClientStreamBase> crypto_stream_; |
| QuicServerId server_id_; |
| QuicCryptoClientConfig* crypto_config_; |
| |
| // If this is set to false, the client will ignore server GOAWAYs and allow |
| // the creation of streams regardless of the high chance they will fail. |
| bool respect_goaway_; |
| }; |
| |
| } // namespace quic |
| |
| #endif // QUICHE_QUIC_CORE_HTTP_QUIC_SPDY_CLIENT_SESSION_H_ |