Correctly handle SPDY GOAWAY frames.

net/spdy/spdy_write_queue.h

 // Copyright (c) 2013 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_SPDY_WRITE_QUEUE_H_
 #define NET_SPDY_SPDY_WRITE_QUEUE_H_
 
 #include <deque>
 
 #include "base/basictypes.h"
@@ skipping 30 matching lines @@
   // fills in |frame_type|, |frame_producer|, and |stream| if
   // successful -- otherwise, just returns false.
   bool Dequeue(SpdyFrameType* frame_type,
                scoped_ptr<SpdyBufferProducer>* frame_producer,
                scoped_refptr<SpdyStream>* stream);
 
   // Removes all pending writes for the given stream, which must be
   // non-NULL.
   void RemovePendingWritesForStream(const scoped_refptr<SpdyStream>& stream);
 
+  // Removes all pending writes for streams after |last_good_stream_id|.
+  void RemovePendingWritesForStreamsAfter(SpdyStreamId last_good_stream_id);

[akalin, 2013/04/18 02:23:11]

before i forget, can you also add a unit test for this?

[Ryan Hamilton, 2013/04/18 17:18:29]

Done.

+
   // Removes all pending writes.
   void Clear();
 
  private:
   // A struct holding a frame producer and its associated stream.
   struct PendingWrite {
     SpdyFrameType frame_type;
     // This has to be a raw pointer since we store this in an STL
     // container.
     SpdyBufferProducer* frame_producer;
     scoped_refptr<SpdyStream> stream;
 
     PendingWrite();
     PendingWrite(SpdyFrameType frame_type,
                  SpdyBufferProducer* frame_producer,
                  const scoped_refptr<SpdyStream>& stream);
     ~PendingWrite();
   };
 
   // The actual write queue, binned by priority.
   std::deque<PendingWrite> queue_[NUM_PRIORITIES];
 
   DISALLOW_COPY_AND_ASSIGN(SpdyWriteQueue);
 };
 
 }  // namespace net
 
 #endif  // NET_SPDY_SPDY_WRITE_QUEUE_H_