[Sync] Move //sync to //components/sync.

components/sync/core/http_bridge.cc

 // Copyright 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 "sync/internal_api/public/http_bridge.h"
+#include "components/sync/core/http_bridge.h"
 
 #include <stddef.h>
 #include <stdint.h>
 
 #include <vector>
 
 #include "base/bit_cast.h"
 #include "base/location.h"
 #include "base/metrics/histogram_macros.h"
 #include "base/metrics/sparse_histogram.h"
 #include "base/single_thread_task_runner.h"
 #include "base/strings/string_number_conversions.h"
 #include "base/strings/stringprintf.h"
 #include "base/threading/thread_task_runner_handle.h"
+#include "components/sync/base/cancelation_signal.h"
 #include "net/base/load_flags.h"
 #include "net/base/net_errors.h"
 #include "net/http/http_cache.h"
 #include "net/http/http_network_layer.h"
 #include "net/http/http_request_headers.h"
 #include "net/http/http_response_headers.h"
 #include "net/url_request/static_http_user_agent_settings.h"
 #include "net/url_request/url_fetcher.h"
 #include "net/url_request/url_request_context.h"
 #include "net/url_request/url_request_job_factory_impl.h"
 #include "net/url_request/url_request_status.h"
-#include "sync/internal_api/public/base/cancelation_signal.h"
 
 namespace syncer {
 
 namespace {
 
 // It's possible for an http request to be silently stalled. We set a time
 // limit for all http requests, beyond which the request is cancelled and
 // treated as a transient failure.
 const int kMaxHttpRequestTimeSeconds = 60 * 5;  // 5 minutes.
 
@@ skipping 72 matching lines @@
   // is destroyed in the right order on its network task runner.
   request_context_getter_ = NULL;
 }
 
 HttpBridge::URLFetchState::URLFetchState()
     : url_poster(NULL),
       aborted(false),
       request_completed(false),
       request_succeeded(false),
       http_response_code(-1),
-      error_code(-1) {
-}
+      error_code(-1) {}
 HttpBridge::URLFetchState::~URLFetchState() {}
 
 HttpBridge::HttpBridge(
     const std::string& user_agent,
     const scoped_refptr<net::URLRequestContextGetter>& context_getter,
     const NetworkTimeUpdateCallback& network_time_update_callback,
     const BindToTrackerCallback& bind_to_tracker_callback)
     : user_agent_(user_agent),
       http_post_completed_(base::WaitableEvent::ResetPolicy::AUTOMATIC,
                            base::WaitableEvent::InitialState::NOT_SIGNALED),
       request_context_getter_(context_getter),
       network_task_runner_(request_context_getter_->GetNetworkTaskRunner()),
       network_time_update_callback_(network_time_update_callback),
       bind_to_tracker_callback_(bind_to_tracker_callback) {}
 
-HttpBridge::~HttpBridge() {
-}
+HttpBridge::~HttpBridge() {}
 
-void HttpBridge::SetExtraRequestHeaders(const char * headers) {
+void HttpBridge::SetExtraRequestHeaders(const char* headers) {
   DCHECK(extra_headers_.empty())
       << "HttpBridge::SetExtraRequestHeaders called twice.";
   extra_headers_.assign(headers);
 }
 
 void HttpBridge::SetURL(const char* url, int port) {
 #if DCHECK_IS_ON()
   DCHECK(thread_checker_.CalledOnValidThread());
   {
     base::AutoLock lock(fetch_state_lock_);
@@ skipping 37 matching lines @@
   DCHECK(thread_checker_.CalledOnValidThread());
   {
     base::AutoLock lock(fetch_state_lock_);
     DCHECK(!fetch_state_.request_completed);
   }
   DCHECK(url_for_request_.is_valid()) << "Invalid URL for request";
   DCHECK(!content_type_.empty()) << "Payload not set";
 #endif
 
   if (!network_task_runner_->PostTask(
-          FROM_HERE,
-          base::Bind(&HttpBridge::CallMakeAsynchronousPost, this))) {
+          FROM_HERE, base::Bind(&HttpBridge::CallMakeAsynchronousPost, this))) {
     // This usually happens when we're in a unit test.
     LOG(WARNING) << "Could not post CallMakeAsynchronousPost task";
     return false;
   }
 
   // Block until network request completes or is aborted. See
   // OnURLFetchComplete and Abort.
   http_post_completed_.Wait();
 
   base::AutoLock lock(fetch_state_lock_);
@@ skipping 28 matching lines @@
     bind_to_tracker_callback_.Run(fetch_state_.url_poster);
   fetch_state_.url_poster->SetRequestContext(request_context_getter_.get());
   fetch_state_.url_poster->SetExtraRequestHeaders(extra_headers_);
 
   fetch_state_.url_poster->SetUploadData(content_type_, request_content_);
   RecordSyncRequestContentLengthHistograms(request_content_.size(),
                                            request_content_.size());
 
   fetch_state_.url_poster->AddExtraRequestHeader(base::StringPrintf(
       "%s: %s", net::HttpRequestHeaders::kUserAgent, user_agent_.c_str()));
-  fetch_state_.url_poster->SetLoadFlags(net::LOAD_BYPASS_CACHE |
-                                        net::LOAD_DISABLE_CACHE |
-                                        net::LOAD_DO_NOT_SAVE_COOKIES |
-                                        net::LOAD_DO_NOT_SEND_COOKIES);
+  fetch_state_.url_poster->SetLoadFlags(
+      net::LOAD_BYPASS_CACHE | net::LOAD_DISABLE_CACHE |
+      net::LOAD_DO_NOT_SAVE_COOKIES | net::LOAD_DO_NOT_SEND_COOKIES);
 
   fetch_state_.url_poster->Start();
 }
 
 int HttpBridge::GetResponseContentLength() const {
   DCHECK(thread_checker_.CalledOnValidThread());
   base::AutoLock lock(fetch_state_lock_);
   DCHECK(fetch_state_.request_completed);
   return fetch_state_.response_content.size();
 }
@@ skipping 35 matching lines @@
                      fetch_state_.http_request_timeout_timer.release()))) {
     // Madness ensues.
     NOTREACHED() << "Could not post task to delete URLFetcher";
   }
 
   fetch_state_.url_poster = NULL;
   fetch_state_.error_code = net::ERR_ABORTED;
   http_post_completed_.Signal();
 }
 
-void HttpBridge::DestroyURLFetcherOnIOThread(
-    net::URLFetcher* fetcher,
-    base::Timer* fetch_timer) {
+void HttpBridge::DestroyURLFetcherOnIOThread(net::URLFetcher* fetcher,
+                                             base::Timer* fetch_timer) {
   DCHECK(network_task_runner_->BelongsToCurrentThread());
   if (fetch_timer)
     delete fetch_timer;
   delete fetcher;
 }
 
 void HttpBridge::OnURLFetchComplete(const net::URLFetcher* source) {
   DCHECK(network_task_runner_->BelongsToCurrentThread());
 
   base::AutoLock lock(fetch_state_lock_);
@@ skipping 117 matching lines @@
   int64_t sane_time_ms = 0;
   if (base::StringToInt64(sane_time_str, &sane_time_ms)) {
     network_time_update_callback_.Run(
         base::Time::FromJsTime(sane_time_ms),
         base::TimeDelta::FromMilliseconds(1),
         fetch_state_.end_time - fetch_state_.start_time);
   }
 }
 
 }  // namespace syncer