Make net::BidirectionalStream handle RST_STREAM_NO_ERROR

net/spdy/bidirectional_stream_spdy_impl.h

 // Copyright 2015 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_SPDY_BIDIRECTIONAL_STREAM_SPDY_IMPL_H_
 #define NET_SPDY_BIDIRECTIONAL_STREAM_SPDY_IMPL_H_
 
 #include <stdint.h>
 
 #include <memory>
@@ skipping 56 matching lines @@
   void OnDataReceived(std::unique_ptr<SpdyBuffer> buffer) override;
   void OnDataSent() override;
   void OnTrailers(const SpdyHeaderBlock& trailers) override;
   void OnClose(int status) override;
 
  private:
   int SendRequestHeadersHelper();
   void OnStreamInitialized(int rv);
   // Notifies delegate of an error.
   void NotifyError(int rv);
+  void NotifyDataSent();
   void ResetStream();
   void ScheduleBufferedRead();
   void DoBufferedRead();
   bool ShouldWaitForMoreBufferedData() const;
+  // Handles the case where stream is closed when SendData()/SendvData() is
+  // called. Return true if stream is closed.
+  bool MaybeHandleStreamClosedInSendData();
 
   const base::WeakPtr<SpdySession> spdy_session_;
   const BidirectionalStreamRequestInfo* request_info_;
   BidirectionalStreamImpl::Delegate* delegate_;
   std::unique_ptr<base::Timer> timer_;
   SpdyStreamRequest stream_request_;
   base::WeakPtr<SpdyStream> stream_;
 
   NextProto negotiated_protocol_;
 
   // Buffers the data as it arrives asynchronously from the stream.
   SpdyReadQueue read_data_queue_;
   // Whether received more data has arrived since started waiting.
   bool more_read_data_pending_;
   // User provided read buffer for ReadData() response.
   scoped_refptr<IOBuffer> read_buffer_;
   int read_buffer_len_;
 
+  // Whether client has written the end of stream flag in request headers or
+  // in SendData()/SendvData().
+  bool written_end_of_stream_;
+  // Whether a SendData() or SendvData() is pending.
+  bool write_pending_;
+
   // Whether OnClose has been invoked.
   bool stream_closed_;
   // Status reported in OnClose.
   int closed_stream_status_;
   // After |stream_| has been closed, this keeps track of the total number of
   // bytes received over the network for |stream_| while it was open.
   int64_t closed_stream_received_bytes_;
   // After |stream_| has been closed, this keeps track of the total number of
   // bytes sent over the network for |stream_| while it was open.
   int64_t closed_stream_sent_bytes_;
   // True if |stream_| has LoadTimingInfo when it is closed.
   bool closed_has_load_timing_info_;
   // LoadTimingInfo populated when |stream_| is closed.
   LoadTimingInfo closed_load_timing_info_;
 
   // This is the combined buffer of buffers passed in through SendvData.
   // Keep a reference here so it is alive until OnDataSent is invoked.
   scoped_refptr<IOBuffer> pending_combined_buffer_;
 
   base::WeakPtrFactory<BidirectionalStreamSpdyImpl> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(BidirectionalStreamSpdyImpl);
 };
 
 }  // namespace net
 
 #endif  // NET_SPDY_BIDIRECTIONAL_STREAM_SPDY_IMPL_H_