Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(10)

Unified Diff: components/sync_driver/sync_stopped_reporter.cc

Issue 2203673002: [Sync] Move //components/sync_driver to //components/sync/driver. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@sd-a
Patch Set: Full change rebased on static lib. Created 4 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: components/sync_driver/sync_stopped_reporter.cc
diff --git a/components/sync_driver/sync_stopped_reporter.cc b/components/sync_driver/sync_stopped_reporter.cc
deleted file mode 100644
index 37b8fccb762ae8b6aa9ace9274e0da111d966a3f..0000000000000000000000000000000000000000
--- a/components/sync_driver/sync_stopped_reporter.cc
+++ /dev/null
@@ -1,120 +0,0 @@
-// Copyright 2015 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/sync_driver/sync_stopped_reporter.h"
-
-#include "base/location.h"
-#include "base/logging.h"
-#include "base/single_thread_task_runner.h"
-#include "base/strings/stringprintf.h"
-#include "base/threading/thread_task_runner_handle.h"
-#include "base/timer/timer.h"
-#include "components/sync/protocol/sync.pb.h"
-#include "net/base/load_flags.h"
-#include "net/http/http_status_code.h"
-#include "net/url_request/url_fetcher.h"
-#include "net/url_request/url_request_context_getter.h"
-
-namespace {
-
-const char kEventEndpoint[] = "event";
-
-// The request is tiny, so even on poor connections 10 seconds should be
-// plenty of time. Since sync is off when this request is started, we don't
-// want anything sync-related hanging around for very long from a human
-// perspective either. This seems like a good compromise.
-const int kRequestTimeoutSeconds = 10;
-
-} // namespace
-
-namespace browser_sync {
-
-SyncStoppedReporter::SyncStoppedReporter(
- const GURL& sync_service_url,
- const std::string& user_agent,
- const scoped_refptr<net::URLRequestContextGetter>& request_context,
- const ResultCallback& callback)
- : sync_event_url_(GetSyncEventURL(sync_service_url)),
- user_agent_(user_agent),
- request_context_(request_context),
- callback_(callback) {
- DCHECK(!sync_service_url.is_empty());
- DCHECK(!user_agent_.empty());
- DCHECK(request_context);
-}
-
-SyncStoppedReporter::~SyncStoppedReporter() {}
-
-void SyncStoppedReporter::ReportSyncStopped(const std::string& access_token,
- const std::string& cache_guid,
- const std::string& birthday) {
- DCHECK(!access_token.empty());
- DCHECK(!cache_guid.empty());
- DCHECK(!birthday.empty());
-
- // Make the request proto with the GUID identifying this client.
- sync_pb::EventRequest event_request;
- sync_pb::SyncDisabledEvent* sync_disabled_event =
- event_request.mutable_sync_disabled();
- sync_disabled_event->set_cache_guid(cache_guid);
- sync_disabled_event->set_store_birthday(birthday);
-
- std::string msg;
- event_request.SerializeToString(&msg);
-
- fetcher_ =
- net::URLFetcher::Create(sync_event_url_, net::URLFetcher::POST, this);
- fetcher_->AddExtraRequestHeader(base::StringPrintf(
- "%s: Bearer %s", net::HttpRequestHeaders::kAuthorization,
- access_token.c_str()));
- fetcher_->AddExtraRequestHeader(base::StringPrintf(
- "%s: %s", net::HttpRequestHeaders::kUserAgent, user_agent_.c_str()));
- fetcher_->SetRequestContext(request_context_.get());
- fetcher_->SetUploadData("application/octet-stream", msg);
- fetcher_->SetLoadFlags(net::LOAD_BYPASS_CACHE |
- net::LOAD_DISABLE_CACHE |
- net::LOAD_DO_NOT_SAVE_COOKIES |
- net::LOAD_DO_NOT_SEND_COOKIES);
- fetcher_->Start();
- timer_.Start(FROM_HERE, base::TimeDelta::FromSeconds(kRequestTimeoutSeconds),
- this, &SyncStoppedReporter::OnTimeout);
-}
-
-void SyncStoppedReporter::OnURLFetchComplete(const net::URLFetcher* source) {
- Result result = source->GetResponseCode() == net::HTTP_OK
- ? RESULT_SUCCESS : RESULT_ERROR;
- fetcher_.reset();
- timer_.Stop();
- if (!callback_.is_null()) {
- base::ThreadTaskRunnerHandle::Get()->PostTask(
- FROM_HERE, base::Bind(callback_, result));
- }
-}
-
-void SyncStoppedReporter::OnTimeout() {
- fetcher_.reset();
- if (!callback_.is_null()) {
- base::ThreadTaskRunnerHandle::Get()->PostTask(
- FROM_HERE, base::Bind(callback_, RESULT_TIMEOUT));
- }
-}
-
-// Static.
-GURL SyncStoppedReporter::GetSyncEventURL(const GURL& sync_service_url) {
- std::string path = sync_service_url.path();
- if (path.empty() || *path.rbegin() != '/') {
- path += '/';
- }
- path += kEventEndpoint;
- GURL::Replacements replacements;
- replacements.SetPathStr(path);
- return sync_service_url.ReplaceComponents(replacements);
-}
-
-void SyncStoppedReporter::SetTimerTaskRunnerForTest(
- const scoped_refptr<base::SingleThreadTaskRunner>& task_runner) {
- timer_.SetTaskRunner(task_runner);
-}
-
-} // namespace browser_sync
« no previous file with comments | « components/sync_driver/sync_stopped_reporter.h ('k') | components/sync_driver/sync_stopped_reporter_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698