Moving gRPC support interfaces out of cronet and into a new component.

components/grpc_support/cronet_bidirectional_stream.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_bidirectional_stream.h"
+#include "components/grpc_support/cronet_bidirectional_stream.h"
 
 #include <memory>
 #include <string>
 #include <vector>
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/memory/ref_counted.h"
 #include "base/strings/string_number_conversions.h"
-#include "components/cronet/ios/cronet_environment.h"
+#include "components/grpc_support/environment.h"
 #include "net/base/io_buffer.h"
 #include "net/base/net_errors.h"
 #include "net/base/request_priority.h"
 #include "net/http/bidirectional_stream.h"
 #include "net/http/bidirectional_stream_request_info.h"
 #include "net/http/http_network_session.h"
 #include "net/http/http_response_headers.h"
 #include "net/http/http_status_code.h"
 #include "net/http/http_transaction_factory.h"
 #include "net/http/http_util.h"
 #include "net/spdy/spdy_header_block.h"
 #include "net/ssl/ssl_info.h"
 #include "net/url_request/http_user_agent_settings.h"
 #include "net/url_request/url_request_context.h"
 #include "url/gurl.h"
 
-namespace cronet {
+namespace grpc_support {
 
 CronetBidirectionalStream::WriteBuffers::WriteBuffers() {}
 
 CronetBidirectionalStream::WriteBuffers::~WriteBuffers() {}
 
 void CronetBidirectionalStream::WriteBuffers::Clear() {
   write_buffer_list.clear();
   write_buffer_len_list.clear();
 }
 
@@ skipping 10 matching lines @@
   std::move(write_buffer_len_list.begin(), write_buffer_len_list.end(),
             std::back_inserter(target->write_buffer_len_list));
   Clear();
 }
 
 bool CronetBidirectionalStream::WriteBuffers::Empty() const {
   return write_buffer_list.empty();
 }
 
 CronetBidirectionalStream::CronetBidirectionalStream(
-    CronetEnvironment* environment,
+    Environment* environment,
     Delegate* delegate)
     : read_state_(NOT_STARTED),
       write_state_(NOT_STARTED),
       write_end_of_stream_(false),
       request_headers_sent_(false),
       disable_auto_flush_(false),
       delay_headers_until_flush_(false),
       environment_(environment),
       pending_write_data_(new WriteBuffers()),
       flushing_write_data_(new WriteBuffers()),
@@ skipping 163 matching lines @@
   read_state_ = write_state_ = ERROR;
   delegate_->OnFailed(error);
 }
 
 void CronetBidirectionalStream::StartOnNetworkThread(
     std::unique_ptr<net::BidirectionalStreamRequestInfo> request_info) {
   DCHECK(environment_->IsOnNetworkThread());
   DCHECK(!bidi_stream_);
   DCHECK(environment_->GetURLRequestContext());
   request_info->extra_headers.SetHeaderIfMissing(
-      net::HttpRequestHeaders::kUserAgent, environment_->user_agent());
+      net::HttpRequestHeaders::kUserAgent, environment_->UserAgent());
   bidi_stream_.reset(new net::BidirectionalStream(
       std::move(request_info), environment_->GetURLRequestContext()
                                    ->http_transaction_factory()
                                    ->GetSession(),
       !delay_headers_until_flush_, this));
   DCHECK(read_state_ == NOT_STARTED && write_state_ == NOT_STARTED);
   read_state_ = write_state_ = STARTED;
 }
 
 void CronetBidirectionalStream::ReadDataOnNetworkThread(
@@ skipping 96 matching lines @@
 void CronetBidirectionalStream::MaybeOnSucceded() {
   DCHECK(environment_->IsOnNetworkThread());
   if (read_state_ == READING_DONE && write_state_ == WRITING_DONE) {
     read_state_ = write_state_ = SUCCESS;
     bidi_stream_.reset();
     delegate_->OnSucceeded();
   }
 }
 
 }  // namespace cronet