SPDY - Handle incomplete headers during server push.

net/spdy/spdy_websocket_stream.cc

 // 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.
 
 #include "net/spdy/spdy_websocket_stream.h"
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "googleurl/src/gurl.h"
 #include "net/base/net_errors.h"
@@ skipping 89 matching lines @@
   return ERR_UNEXPECTED;
 }
 
 int SpdyWebSocketStream::OnResponseReceived(
     const SpdyHeaderBlock& response,
     base::Time response_time, int status) {
   DCHECK(delegate_);
   return delegate_->OnReceivedSpdyResponseHeader(response, status);
 }
 
-void SpdyWebSocketStream::OnDataReceived(const char* data, int length) {
+int SpdyWebSocketStream::OnDataReceived(const char* data, int length) {
   DCHECK(delegate_);
   delegate_->OnReceivedSpdyData(data, length);
+  return OK;
 }
 
 void SpdyWebSocketStream::OnDataSent(int length) {
   DCHECK(delegate_);
   delegate_->OnSentSpdyData(length);
 }
 
 void SpdyWebSocketStream::OnClose(int status) {
   stream_ = NULL;
 
   // Destruction without Close() call OnClose() with delegate_ being NULL.
   if (!delegate_)
     return;
   Delegate* delegate = delegate_;
   delegate_ = NULL;
   delegate->OnCloseSpdyStream();
 }
 
 void SpdyWebSocketStream::OnSpdyStreamCreated(int result) {
   DCHECK_NE(ERR_IO_PENDING, result);
   if (result == OK) {
     DCHECK(stream_);
     stream_->SetDelegate(this);
   }
   DCHECK(delegate_);
   delegate_->OnCreatedSpdyStream(result);
 }
 
 }  // namespace net