Disallow multiple HEADERS frames on pushed streams.

net/spdy/bidirectional_stream_spdy_impl.cc

 // 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.
 
 #include "net/spdy/bidirectional_stream_spdy_impl.h"
 
 #include <utility>
 
 #include "base/bind.h"
 #include "base/location.h"
@@ skipping 192 matching lines @@
   }
 
   // If |stream_| isn't created or has ID 0, return false. This is to match
   // the implementation in SpdyHttpStream.
   if (!stream_ || stream_->stream_id() == 0)
     return false;
 
   return stream_->GetLoadTimingInfo(load_timing_info);
 }
 
-void BidirectionalStreamSpdyImpl::OnRequestHeadersSent() {
+void BidirectionalStreamSpdyImpl::OnHeadersSent() {
   DCHECK(stream_);
 
   negotiated_protocol_ = kProtoHTTP2;
   if (delegate_)
     delegate_->OnStreamReady(/*request_headers_sent=*/true);
 }
 
-SpdyResponseHeadersStatus BidirectionalStreamSpdyImpl::OnResponseHeadersUpdated(
+void BidirectionalStreamSpdyImpl::OnHeadersReceived(
     const SpdyHeaderBlock& response_headers) {
   DCHECK(stream_);
 
   if (delegate_)
     delegate_->OnHeadersReceived(response_headers);
-
-  return RESPONSE_HEADERS_ARE_COMPLETE;
 }
 
 void BidirectionalStreamSpdyImpl::OnDataReceived(
     std::unique_ptr<SpdyBuffer> buffer) {
   DCHECK(stream_);
   DCHECK(!stream_closed_);
 
   // If |buffer| is null, BidirectionalStreamSpdyImpl::OnClose will be invoked
   // by SpdyStream to indicate the end of stream.
   if (!buffer)
@@ skipping 71 matching lines @@
                                          : MORE_DATA_TO_SEND);
 }
 
 void BidirectionalStreamSpdyImpl::OnStreamInitialized(int rv) {
   DCHECK_NE(ERR_IO_PENDING, rv);
   if (rv == OK) {
     stream_ = stream_request_.ReleaseStream();
     stream_->SetDelegate(this);
     rv = SendRequestHeadersHelper();
     if (rv == OK) {
-      OnRequestHeadersSent();
+      OnHeadersSent();
       return;
     } else if (rv == ERR_IO_PENDING) {
       return;
     }
   }
   NotifyError(rv);
 }
 
 void BidirectionalStreamSpdyImpl::NotifyError(int rv) {
   ResetStream();
@@ skipping 79 matching lines @@
     return true;
   }
   LOG(ERROR) << "Trying to send data after stream has been destroyed.";
   base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE, base::Bind(&BidirectionalStreamSpdyImpl::NotifyError,
                             weak_factory_.GetWeakPtr(), ERR_UNEXPECTED));
   return true;
 }
 
 }  // namespace net