Added a net::BidirectionalStream to expose a bidirectional streaming interface

net/spdy/spdy_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_stream.h"
 
 #include "base/bind.h"
 #include "base/compiler_specific.h"
 #include "base/location.h"
 #include "base/logging.h"
@@ skipping 435 matching lines @@
     if (response_headers_status_ != RESPONSE_HEADERS_ARE_COMPLETE) {
       session_->ResetStream(
           stream_id_, RST_STREAM_PROTOCOL_ERROR,
           "Additional headers received for request/response stream");
       return ERR_SPDY_PROTOCOL_ERROR;
     }
     response_headers_status_ = TRAILERS_RECEIVED;
     delegate_->OnTrailers(additional_response_headers);
     return OK;
   }
+  if (type_ == SPDY_BIDIRECTIONAL_STREAM) {
+    DCHECK_EQ(RESPONSE_HEADERS_ARE_COMPLETE, response_headers_status_);
+    response_headers_status_ = TRAILERS_RECEIVED;
+    delegate_->OnTrailers(additional_response_headers);
+    return OK;
+  }
   if (type_ == SPDY_PUSH_STREAM &&
       response_headers_status_ == RESPONSE_HEADERS_ARE_COMPLETE) {
     session_->ResetStream(
         stream_id_, RST_STREAM_PROTOCOL_ERROR,
         "Additional headers received for push stream");
     return ERR_SPDY_PROTOCOL_ERROR;
   }
   return MergeWithResponseHeaders(additional_response_headers);
 }
 
@@ skipping 21 matching lines @@
       pending_recv_data_.push_back(std::move(buffer));
     } else {
       pending_recv_data_.push_back(NULL);
       // Note: we leave the stream open in the session until the stream
       //       is claimed.
     }
     return;
   }
 
   if (response_headers_status_ == TRAILERS_RECEIVED && buffer) {
-    // TRAILERS_RECEIVED is only used in SPDY_REQUEST_RESPONSE_STREAM.
-    DCHECK_EQ(type_, SPDY_REQUEST_RESPONSE_STREAM);
+    // TRAILERS_RECEIVED is only used in SPDY_REQUEST_RESPONSE_STREAM and
+    // SPDY_BIDIRECTIONAL_STREAM.
+    DCHECK(type_ == SPDY_REQUEST_RESPONSE_STREAM ||
+           type_ == SPDY_BIDIRECTIONAL_STREAM);
     session_->ResetStream(stream_id_, RST_STREAM_PROTOCOL_ERROR,
                           "Data received after trailers");
     return;
   }
 
   // If we have response headers but the delegate has indicated that
   // it's still incomplete, then that's a protocol error.
   if (response_headers_status_ == RESPONSE_HEADERS_ARE_INCOMPLETE) {
     LogStreamError(ERR_SPDY_PROTOCOL_ERROR,
                    "Data received with incomplete headers.");
@@ skipping 437 matching lines @@
       description = base::StringPrintf("Unknown state 0x%08X (%u)", state,
                                        state);
       break;
   }
   return description;
 }
 
 #undef STATE_CASE
 
 }  // namespace net