Add an async ReadTrailers method to QuicChromiumClientStream::Handle

net/quic/chromium/quic_http_stream.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.
 
 #ifndef NET_QUIC_CHROMIUM_QUIC_HTTP_STREAM_H_
 #define NET_QUIC_CHROMIUM_QUIC_HTTP_STREAM_H_
 
 #include <stddef.h>
 #include <stdint.h>
 
@@ skipping 51 matching lines @@
   bool IsConnectionReused() const override;
   int64_t GetTotalReceivedBytes() const override;
   int64_t GetTotalSentBytes() const override;
   bool GetLoadTimingInfo(LoadTimingInfo* load_timing_info) const override;
   bool GetAlternativeService(
       AlternativeService* alternative_service) const override;
   void PopulateNetErrorDetails(NetErrorDetails* details) override;
   void SetPriority(RequestPriority priority) override;
 
   // QuicChromiumClientStream::Delegate implementation
-  void OnTrailingHeadersAvailable(const SpdyHeaderBlock& headers,
-                                  size_t frame_len) override;
   void OnClose() override;
   void OnError(int error) override;
 
   // QuicClientPushPromiseIndex::Delegate implementation
   bool CheckVary(const SpdyHeaderBlock& client_request,
                  const SpdyHeaderBlock& promise_request,
                  const SpdyHeaderBlock& promise_response) override;
   // TODO(rch): QuicClientPushPromiseIndex::Delegate is part of shared code.
   // Figure out how to make the QuicHttpStream receive a Handle in this
   // case instead of a QuicSpdyStream.
@@ skipping 32 matching lines @@
   int DoSetRequestPriority();
   int DoSendHeaders();
   int DoSendHeadersComplete(int rv);
   int DoReadRequestBody();
   int DoReadRequestBodyComplete(int rv);
   int DoSendBody();
   int DoSendBodyComplete(int rv);
 
   void OnReadResponseHeadersComplete(int rv);
   int ProcessResponseHeaders(const SpdyHeaderBlock& headers);
+  void ReadTrailingHeaders();
+  void OnReadTrailingHeadersComplete(int rv);
 
   void OnReadBodyComplete(int rv);
   int HandleReadComplete(int rv);
 
   void EnterStateSendHeaders();
 
   void ResetStream();
 
   // If |has_response_status_| is false, sets |response_status| to the result
   // of ComputeResponseStatus(). Returns |response_status_|.
@@ skipping 41 matching lines @@
   // Once all buffered data has been returned, this will be used as the final
   // response.
   int response_status_;
 
   // Serialized request headers.
   SpdyHeaderBlock request_headers_;
 
   SpdyHeaderBlock response_header_block_;
   bool response_headers_received_;
 
+  SpdyHeaderBlock trailing_header_block_;
+  bool trailing_headers_received_;

[xunjieli, 2017/05/26 15:53:06]

nit: we need to default initialize this boolean.

[Ryan Hamilton, 2017/05/26 22:35:50]

Done.

+
   // Number of bytes received by the headers stream on behalf of this stream.
   int64_t headers_bytes_received_;
   // Number of bytes sent by the headers stream on behalf of this stream.
   int64_t headers_bytes_sent_;
 
   // Number of bytes received when the stream was closed.
   int64_t closed_stream_received_bytes_;
   // Number of bytes sent when the stream was closed.
   int64_t closed_stream_sent_bytes_;
   // True if the stream is the first stream negotiated on the session. Set when
@@ skipping 33 matching lines @@
   LoadTimingInfo::ConnectTiming connect_timing_;
 
   base::WeakPtrFactory<QuicHttpStream> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(QuicHttpStream);
 };
 
 }  // namespace net
 
 #endif  // NET_QUIC_CHROMIUM_QUIC_HTTP_STREAM_H_