Coalesce small buffers in net::BidirectionalStream

components/cronet/ios/cronet_c_for_grpc.cc

 // Copyright 2016 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 "components/cronet/ios/cronet_c_for_grpc.h"
 
 #include <stdbool.h>
 #include <string>
 #include <vector>
 
@@ skipping 59 matching lines @@
 class CronetBidirectionalStreamAdapter
     : public cronet::CronetBidirectionalStream::Delegate {
  public:
   CronetBidirectionalStreamAdapter(
       cronet_engine* engine,
       cronet_bidirectional_stream* stream,
       cronet_bidirectional_stream_callback* callback);
 
   virtual ~CronetBidirectionalStreamAdapter();
 
-  void OnHeadersSent() override;
+  void OnStreamReady() override;
 
   void OnHeadersReceived(const net::SpdyHeaderBlock& headers_block,
                          const char* negotiated_protocol) override;
 
   void OnDataRead(char* data, int size) override;
 
   void OnDataSent(const char* data) override;
 
   void OnTrailersReceived(const net::SpdyHeaderBlock& trailers_block) override;
 
@@ skipping 27 matching lines @@
           reinterpret_cast<cronet::CronetEnvironment*>(engine->obj)),
       stream_(stream),
       callback_(callback) {
   DCHECK(cronet_environment_);
   cronet_bidirectional_stream_ =
       new cronet::CronetBidirectionalStream(cronet_environment_, this);
 }
 
 CronetBidirectionalStreamAdapter::~CronetBidirectionalStreamAdapter() {}
 
-void CronetBidirectionalStreamAdapter::OnHeadersSent() {
+void CronetBidirectionalStreamAdapter::OnStreamReady() {
   DCHECK(callback_->on_response_headers_received);
-  callback_->on_request_headers_sent(stream_);
+  callback_->on_stream_ready(stream_);
 }
 
 void CronetBidirectionalStreamAdapter::OnHeadersReceived(
     const net::SpdyHeaderBlock& headers_block,
     const char* negotiated_protocol) {
   DCHECK(callback_->on_response_headers_received);
   HeadersArray response_headers(headers_block);
   callback_->on_response_headers_received(stream_, &response_headers,
                                           negotiated_protocol);
 }
@@ skipping 120 matching lines @@
 int cronet_bidirectional_stream_cancel(cronet_bidirectional_stream* stream) {
   CronetBidirectionalStreamAdapter::GetCronetStream(stream)->Cancel();
   return 1;
 }
 
 int cronet_bidirectional_stream_destroy(cronet_bidirectional_stream* stream) {
   CronetBidirectionalStreamAdapter::DestroyAdapterForStream(stream);
   delete stream;
   return 1;
 }