Groundwork for cancelling quartc streams after a deadline is exceeded.

net/quic/quartc/quartc_session.h

 // Copyright (c) 2017 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.
 
 #ifndef NET_QUIC_QUARTC_QUARTC_SESSION_H_
 #define NET_QUIC_QUARTC_QUARTC_SESSION_H_
 
 #include "net/quic/core/quic_crypto_client_stream.h"
 #include "net/quic/core/quic_crypto_server_stream.h"
 #include "net/quic/core/quic_crypto_stream.h"
+#include "net/quic/core/quic_error_codes.h"
 #include "net/quic/core/quic_session.h"
 #include "net/quic/quartc/quartc_clock_interface.h"
 #include "net/quic/quartc/quartc_session_interface.h"
 #include "net/quic/quartc/quartc_stream.h"
 
 namespace net {
 
 // A helper class is used by the QuicCryptoServerStream.
 class QuartcCryptoServerStreamHelper : public QuicCryptoServerStream::Helper {
  public:
@@ skipping 39 matching lines @@
   bool ExportKeyingMaterial(const std::string& label,
                             const uint8_t* context,
                             size_t context_len,
                             bool used_context,
                             uint8_t* result,
                             size_t result_len) override;
 
   QuartcStreamInterface* CreateOutgoingStream(
       const OutgoingStreamParameters& param) override;
 
+  void CancelStream(QuicStreamId stream_id) override;
+
   void SetDelegate(QuartcSessionInterface::Delegate* session_delegate) override;
 
   void OnTransportCanWrite() override;
 
   // Decrypts an incoming QUIC packet to a data stream.
   bool OnTransportReceived(const char* data, size_t data_len) override;
 
   // ProofHandler overrides.
   void OnProofValid(const QuicCryptoClientConfig::CachedState& cached) override;
 
@@ skipping 13 matching lines @@
   // QuicSession override.
   QuicStream* CreateIncomingDynamicStream(QuicStreamId id) override;
   std::unique_ptr<QuicStream> CreateStream(QuicStreamId id) override;
 
   std::unique_ptr<QuartcStream> CreateDataStream(QuicStreamId id,
                                                  SpdyPriority priority);
   // Activates a QuartcStream.  The session takes ownership of the stream, but
   // returns an unowned pointer to the stream for convenience.
   QuartcStream* ActivateDataStream(std::unique_ptr<QuartcStream> stream);
 
+  void ResetStream(QuicStreamId stream_id, QuicRstStreamErrorCode error);
+
  private:
   // For crypto handshake.
   std::unique_ptr<QuicCryptoStream> crypto_stream_;
   const std::string unique_remote_server_id_;
   Perspective perspective_;
   // Take the ownership of the QuicConnection.
   std::unique_ptr<QuicConnection> connection_;
   // Not owned by QuartcSession. From the QuartcFactory.
   QuicConnectionHelperInterface* helper_;
   // For recording packet receipt time
   QuicClock* clock_;
   // Not owned by QuartcSession.
   QuartcSessionInterface::Delegate* session_delegate_ = nullptr;
   // Used by QUIC crypto server stream to track most recently compressed certs.
   std::unique_ptr<QuicCompressedCertsCache> quic_compressed_certs_cache_;
   // This helper is needed when create QuicCryptoServerStream.
   QuartcCryptoServerStreamHelper stream_helper_;
   // Config for QUIC crypto client stream, used by the client.
   std::unique_ptr<QuicCryptoClientConfig> quic_crypto_client_config_;
   // Config for QUIC crypto server stream, used by the server.
   std::unique_ptr<QuicCryptoServerConfig> quic_crypto_server_config_;
 
   DISALLOW_COPY_AND_ASSIGN(QuartcSession);
 };
 
 }  // namespace net
 
 #endif  // NET_QUIC_QUARTC_QUARTC_SESSION_H_