Revert of Reland 2:Geolocation: move from content/browser to device/

content/browser/geolocation/geolocation_provider_impl.cc

Index: content/browser/geolocation/geolocation_provider_impl.cc
diff --git a/content/browser/geolocation/geolocation_provider_impl.cc b/content/browser/geolocation/geolocation_provider_impl.cc
new file mode 100644
index 0000000000000000000000000000000000000000..1f263976a914460ccb26e73750177388c0b7f05e
--- /dev/null
+++ b/content/browser/geolocation/geolocation_provider_impl.cc
@@ -0,0 +1,202 @@
+// 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 "content/browser/geolocation/geolocation_provider_impl.h"
+
+#include "base/bind.h"
+#include "base/bind_helpers.h"
+#include "base/callback.h"
+#include "base/lazy_instance.h"
+#include "base/location.h"
+#include "base/logging.h"
+#include "base/memory/ptr_util.h"
+#include "base/memory/singleton.h"
+#include "base/single_thread_task_runner.h"
+#include "content/browser/geolocation/location_arbitrator_impl.h"
+#include "content/public/browser/browser_thread.h"
+#include "content/public/browser/content_browser_client.h"
+#include "content/public/browser/geolocation_delegate.h"
+
+namespace content {
+
+namespace {
+base::LazyInstance<std::unique_ptr<GeolocationDelegate>>::Leaky g_delegate =
+    LAZY_INSTANCE_INITIALIZER;
+}  // anonymous namespace
+
+// static
+GeolocationProvider* GeolocationProvider::GetInstance() {
+  return GeolocationProviderImpl::GetInstance();
+}
+
+// static
+void GeolocationProvider::SetGeolocationDelegate(
+    GeolocationDelegate* delegate) {
+  DCHECK(!g_delegate.Get());
+  g_delegate.Get().reset(delegate);
+}
+
+std::unique_ptr<GeolocationProvider::Subscription>
+GeolocationProviderImpl::AddLocationUpdateCallback(
+    const LocationUpdateCallback& callback,
+    bool enable_high_accuracy) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+  std::unique_ptr<GeolocationProvider::Subscription> subscription;
+  if (enable_high_accuracy) {
+    subscription = high_accuracy_callbacks_.Add(callback);
+  } else {
+    subscription = low_accuracy_callbacks_.Add(callback);
+  }
+
+  OnClientsChanged();
+  if (position_.Validate() ||
+      position_.error_code != Geoposition::ERROR_CODE_NONE) {
+    callback.Run(position_);
+  }
+
+  return subscription;
+}
+
+void GeolocationProviderImpl::UserDidOptIntoLocationServices() {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+  bool was_permission_granted = user_did_opt_into_location_services_;
+  user_did_opt_into_location_services_ = true;
+  if (IsRunning() && !was_permission_granted)
+    InformProvidersPermissionGranted();
+}
+
+void GeolocationProviderImpl::OverrideLocationForTesting(
+    const Geoposition& position) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+  ignore_location_updates_ = true;
+  NotifyClients(position);
+}
+
+void GeolocationProviderImpl::OnLocationUpdate(const Geoposition& position) {
+  DCHECK(OnGeolocationThread());
+  // Will be true only in testing.
+  if (ignore_location_updates_)
+    return;
+  BrowserThread::PostTask(BrowserThread::UI,
+                          FROM_HERE,
+                          base::Bind(&GeolocationProviderImpl::NotifyClients,
+                                     base::Unretained(this), position));
+}
+
+// static
+GeolocationProviderImpl* GeolocationProviderImpl::GetInstance() {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+  return base::Singleton<GeolocationProviderImpl>::get();
+}
+
+GeolocationProviderImpl::GeolocationProviderImpl()
+    : base::Thread("Geolocation"),
+      user_did_opt_into_location_services_(false),
+      ignore_location_updates_(false) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+  high_accuracy_callbacks_.set_removal_callback(
+      base::Bind(&GeolocationProviderImpl::OnClientsChanged,
+                 base::Unretained(this)));
+  low_accuracy_callbacks_.set_removal_callback(
+      base::Bind(&GeolocationProviderImpl::OnClientsChanged,
+                 base::Unretained(this)));
+}
+
+GeolocationProviderImpl::~GeolocationProviderImpl() {
+  Stop();
+  DCHECK(!arbitrator_);
+}
+
+bool GeolocationProviderImpl::OnGeolocationThread() const {
+  return task_runner()->BelongsToCurrentThread();
+}
+
+void GeolocationProviderImpl::OnClientsChanged() {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+  base::Closure task;
+  if (high_accuracy_callbacks_.empty() && low_accuracy_callbacks_.empty()) {
+    DCHECK(IsRunning());
+    if (!ignore_location_updates_) {
+      // We have no more observers, so we clear the cached geoposition so that
+      // when the next observer is added we will not provide a stale position.
+      position_ = Geoposition();
+    }
+    task = base::Bind(&GeolocationProviderImpl::StopProviders,
+                      base::Unretained(this));
+  } else {
+    if (!IsRunning()) {
+      Start();
+      if (user_did_opt_into_location_services_)
+        InformProvidersPermissionGranted();
+    }
+    // Determine a set of options that satisfies all clients.
+    bool enable_high_accuracy = !high_accuracy_callbacks_.empty();
+
+    // Send the current options to the providers as they may have changed.
+    task = base::Bind(&GeolocationProviderImpl::StartProviders,
+                      base::Unretained(this), enable_high_accuracy);
+  }
+
+  task_runner()->PostTask(FROM_HERE, task);
+}
+
+void GeolocationProviderImpl::StopProviders() {
+  DCHECK(OnGeolocationThread());
+  DCHECK(arbitrator_);
+  arbitrator_->StopProviders();
+}
+
+void GeolocationProviderImpl::StartProviders(bool enable_high_accuracy) {
+  DCHECK(OnGeolocationThread());
+  DCHECK(arbitrator_);
+  arbitrator_->StartProviders(enable_high_accuracy);
+}
+
+void GeolocationProviderImpl::InformProvidersPermissionGranted() {
+  DCHECK(IsRunning());
+  if (!OnGeolocationThread()) {
+    task_runner()->PostTask(
+        FROM_HERE,
+        base::Bind(&GeolocationProviderImpl::InformProvidersPermissionGranted,
+                   base::Unretained(this)));
+    return;
+  }
+  DCHECK(OnGeolocationThread());
+  DCHECK(arbitrator_);
+  arbitrator_->OnPermissionGranted();
+}
+
+void GeolocationProviderImpl::NotifyClients(const Geoposition& position) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+  DCHECK(position.Validate() ||
+         position.error_code != Geoposition::ERROR_CODE_NONE);
+  position_ = position;
+  high_accuracy_callbacks_.Notify(position_);
+  low_accuracy_callbacks_.Notify(position_);
+}
+
+void GeolocationProviderImpl::Init() {
+  DCHECK(OnGeolocationThread());
+  DCHECK(!arbitrator_);
+  arbitrator_ = CreateArbitrator();
+}
+
+void GeolocationProviderImpl::CleanUp() {
+  DCHECK(OnGeolocationThread());
+  arbitrator_.reset();
+}
+
+std::unique_ptr<LocationArbitrator>
+GeolocationProviderImpl::CreateArbitrator() {
+  LocationArbitratorImpl::LocationUpdateCallback callback = base::Bind(
+      &GeolocationProviderImpl::OnLocationUpdate, base::Unretained(this));
+  // Use the embedder's |g_delegate| or fall back to the default one.
+  if (!g_delegate.Get())
+    g_delegate.Get().reset(new GeolocationDelegate);
+
+  return base::WrapUnique(
+      new LocationArbitratorImpl(callback, g_delegate.Get().get()));
+}
+
+}  // namespace content