Bring Geolocation to life!...

chrome/browser/geolocation/geolocation_dispatcher_host.cc

 // Copyright (c) 2010 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 "chrome/browser/geolocation/geolocation_dispatcher_host.h"
 
 #include "chrome/common/geoposition.h"
 #include "chrome/browser/geolocation/geolocation_permission_context.h"
 #include "chrome/browser/renderer_host/render_process_host.h"
 #include "chrome/browser/renderer_host/render_view_host.h"
 #include "chrome/browser/renderer_host/render_view_host_notification_task.h"
 #include "chrome/browser/renderer_host/resource_message_filter.h"
 #include "chrome/common/render_messages.h"
 
 GeolocationDispatcherHost::GeolocationDispatcherHost(
     int resource_message_filter_process_id,
     GeolocationPermissionContext* geolocation_permission_context)
     : resource_message_filter_process_id_(resource_message_filter_process_id),
       geolocation_permission_context_(geolocation_permission_context) {
   // This is initialized by ResourceMessageFilter. Do not add any non-trivial
   // initialization here, defer to OnRegisterBridge which is triggered whenever
   // a javascript geolocation object is actually initialized.
 }
 
 GeolocationDispatcherHost::~GeolocationDispatcherHost() {
+  if (location_arbitrator_)
+    location_arbitrator_->RemoveObserver(this);
 }
 
 bool GeolocationDispatcherHost::OnMessageReceived(
     const IPC::Message& msg, bool* msg_was_ok) {
   *msg_was_ok = true;
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP_EX(GeolocationDispatcherHost, msg, *msg_was_ok)
     IPC_MESSAGE_HANDLER(ViewHostMsg_Geolocation_RegisterDispatcher,
                         OnRegisterDispatcher)
     IPC_MESSAGE_HANDLER(ViewHostMsg_Geolocation_UnregisterDispatcher,
                         OnUnregisterDispatcher)
     IPC_MESSAGE_HANDLER(ViewHostMsg_Geolocation_RequestPermission,
                         OnRequestPermission)
     IPC_MESSAGE_HANDLER(ViewHostMsg_Geolocation_StartUpdating,
                         OnStartUpdating)
     IPC_MESSAGE_HANDLER(ViewHostMsg_Geolocation_StopUpdating,
                         OnStopUpdating)
     IPC_MESSAGE_HANDLER(ViewHostMsg_Geolocation_Suspend,
                         OnSuspend)
     IPC_MESSAGE_HANDLER(ViewHostMsg_Geolocation_Resume,
                         OnResume)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
   return handled;
 }
 
-void GeolocationDispatcherHost::NotifyPositionUpdated(
+void GeolocationDispatcherHost::OnLocationUpdate(
     const Geoposition& geoposition) {
-  if (!ChromeThread::CurrentlyOn(ChromeThread::IO)) {
-    ChromeThread::PostTask(
-        ChromeThread::UI, FROM_HERE,
-        NewRunnableMethod(
-            this, &GeolocationDispatcherHost::NotifyPositionUpdated,
-            geoposition));
-    return;
-  }
   DCHECK(ChromeThread::CurrentlyOn(ChromeThread::IO));
 
   for (std::set<GeolocationServiceRenderId>::iterator geo =
        geolocation_renderers_.begin();
        geo != geolocation_renderers_.end();
        ++geo) {
     IPC::Message* message;
     if (geoposition.error_code == Geoposition::ERROR_CODE_NONE) {
       message = new ViewMsg_Geolocation_PositionUpdated(
           geo->route_id, geoposition);
@@ skipping 20 matching lines @@
 void GeolocationDispatcherHost::OnRequestPermission(
     int route_id, int bridge_id, const GURL& origin) {
   LOG(INFO) << "permission request";
   geolocation_permission_context_->RequestGeolocationPermission(
       resource_message_filter_process_id_, route_id, bridge_id, origin);
 }
 
 void GeolocationDispatcherHost::OnStartUpdating(
     int route_id, int bridge_id, bool high_accuracy) {
   LOG(INFO) << "start updating" << route_id;
-  // TODO(bulach): connect this with GeolocationServiceProvider.
+  if (!location_arbitrator_)
+    location_arbitrator_ = GeolocationArbitrator::GetInstance();
+  location_arbitrator_->AddObserver(
+      this, GeolocationArbitrator::UpdateOptions(high_accuracy));
 }
 
 void GeolocationDispatcherHost::OnStopUpdating(int route_id, int bridge_id) {
   LOG(INFO) << "stop updating" << route_id;
-  // TODO(bulach): connect this with GeolocationServiceProvider.
+  if (location_arbitrator_)
+    location_arbitrator_->RemoveObserver(this);
+  location_arbitrator_ = NULL;
 }
 
 void GeolocationDispatcherHost::OnSuspend(int route_id, int bridge_id) {
   LOG(INFO) << "suspend" << route_id;
   // TODO(bulach): connect this with GeolocationServiceProvider.
 }
 
 void GeolocationDispatcherHost::OnResume(int route_id, int bridge_id) {
   LOG(INFO) << "resume" << route_id;
   // TODO(bulach): connect this with GeolocationServiceProvider.
@@ skipping 27 matching lines @@
             this, &GeolocationDispatcherHost::UnregisterDispatcher, process_id,
             route_id));
     return;
   }
   GeolocationServiceRenderId geolocation_render_id(process_id, route_id);
   std::set<GeolocationServiceRenderId>::iterator existing =
       geolocation_renderers_.find(geolocation_render_id);
   DCHECK(existing != geolocation_renderers_.end());
   geolocation_renderers_.erase(existing);
 }