| OLD | NEW | 
|---|
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be | 
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. | 
| 4 | 4 | 
| 5 #include "content/browser/geolocation/gps_location_provider_linux.h" | 5 #include "content/browser/geolocation/gps_location_provider_linux.h" | 
| 6 | 6 | 
| 7 #include <algorithm> | 7 #include <algorithm> | 
| 8 #include <cmath> | 8 #include <cmath> | 
| 9 | 9 | 
| 10 #include "base/bind.h" | 10 #include "base/bind.h" | 
| 11 #include "base/compiler_specific.h" | 11 #include "base/compiler_specific.h" | 
| 12 #include "base/logging.h" | 12 #include "base/logging.h" | 
| 13 #include "base/message_loop.h" | 13 #include "base/message_loop.h" | 
| 14 #include "content/browser/geolocation/libgps_wrapper_linux.h" | 14 #include "content/browser/geolocation/libgps_wrapper_linux.h" | 
| 15 | 15 | 
| 16 namespace { | 16 namespace { | 
| 17 const int kGpsdReconnectRetryIntervalMillis = 10 * 1000; | 17 const int kGpsdReconnectRetryIntervalMillis = 10 * 1000; | 
| 18 // As per http://gpsd.berlios.de/performance.html#id374524, poll twice per sec. | 18 // As per http://gpsd.berlios.de/performance.html#id374524, poll twice per sec. | 
| 19 const int kPollPeriodMovingMillis = 500; | 19 const int kPollPeriodMovingMillis = 500; | 
| 20 // Poll less frequently whilst stationary. | 20 // Poll less frequently whilst stationary. | 
| 21 const int kPollPeriodStationaryMillis = kPollPeriodMovingMillis * 3; | 21 const int kPollPeriodStationaryMillis = kPollPeriodMovingMillis * 3; | 
| 22 // GPS reading must differ by more than this amount to be considered movement. | 22 // GPS reading must differ by more than this amount to be considered movement. | 
| 23 const int kMovementThresholdMeters = 20; | 23 const int kMovementThresholdMeters = 20; | 
| 24 | 24 | 
| 25 // This algorithm is reused from the corresponding code in the Gears project. | 25 // This algorithm is reused from the corresponding code in the Gears project. | 
| 26 // The arbitrary delta is decreased (Gears used 100 meters); if we need to | 26 // The arbitrary delta is decreased (Gears used 100 meters); if we need to | 
| 27 // decrease it any further we'll likely want to do some smarter filtering to | 27 // decrease it any further we'll likely want to do some smarter filtering to | 
| 28 // remove GPS location jitter noise. | 28 // remove GPS location jitter noise. | 
| 29 bool PositionsDifferSiginificantly(const Geoposition& position_1, | 29 bool PositionsDifferSiginificantly(const content::Geoposition& position_1, | 
| 30                                    const Geoposition& position_2) { | 30                                    const content::Geoposition& position_2) { | 
| 31   const bool pos_1_valid = position_1.IsValidFix(); | 31   const bool pos_1_valid = position_1.Validate(); | 
| 32   if (pos_1_valid != position_2.IsValidFix()) | 32   if (pos_1_valid != position_2.Validate()) | 
| 33     return true; | 33     return true; | 
| 34   if (!pos_1_valid) { | 34   if (!pos_1_valid) { | 
| 35     DCHECK(!position_2.IsValidFix()); | 35     DCHECK(!position_2.Validate()); | 
| 36     return false; | 36     return false; | 
| 37   } | 37   } | 
| 38   double delta = std::sqrt( | 38   double delta = std::sqrt( | 
| 39       std::pow(std::fabs(position_1.latitude - position_2.latitude), 2) + | 39       std::pow(std::fabs(position_1.latitude - position_2.latitude), 2) + | 
| 40       std::pow(std::fabs(position_1.longitude - position_2.longitude), 2)); | 40       std::pow(std::fabs(position_1.longitude - position_2.longitude), 2)); | 
| 41   // Convert to meters. 1 minute of arc of latitude (or longitude at the | 41   // Convert to meters. 1 minute of arc of latitude (or longitude at the | 
| 42   // equator) is 1 nautical mile or 1852m. | 42   // equator) is 1 nautical mile or 1852m. | 
| 43   delta *= 60 * 1852; | 43   delta *= 60 * 1852; | 
| 44   return delta > kMovementThresholdMeters; | 44   return delta > kMovementThresholdMeters; | 
| 45 } | 45 } | 
| (...skipping 13 matching lines...) Expand all  Loading... | 
| 59 | 59 | 
| 60 bool GpsLocationProviderLinux::StartProvider(bool high_accuracy) { | 60 bool GpsLocationProviderLinux::StartProvider(bool high_accuracy) { | 
| 61   if (!high_accuracy) { | 61   if (!high_accuracy) { | 
| 62     StopProvider(); | 62     StopProvider(); | 
| 63     return true;  // Not an error condition, so still return true. | 63     return true;  // Not an error condition, so still return true. | 
| 64   } | 64   } | 
| 65   if (gps_ != NULL) { | 65   if (gps_ != NULL) { | 
| 66     DCHECK(weak_factory_.HasWeakPtrs()); | 66     DCHECK(weak_factory_.HasWeakPtrs()); | 
| 67     return true; | 67     return true; | 
| 68   } | 68   } | 
| 69   position_.error_code = Geoposition::ERROR_CODE_POSITION_UNAVAILABLE; | 69   position_.error_code = content::Geoposition::ERROR_CODE_POSITION_UNAVAILABLE; | 
| 70   gps_.reset(libgps_factory_()); | 70   gps_.reset(libgps_factory_()); | 
| 71   if (gps_ == NULL) { | 71   if (gps_ == NULL) { | 
| 72     DLOG(WARNING) << "libgps could not be loaded"; | 72     DLOG(WARNING) << "libgps could not be loaded"; | 
| 73     return false; | 73     return false; | 
| 74   } | 74   } | 
| 75   ScheduleNextGpsPoll(0); | 75   ScheduleNextGpsPoll(0); | 
| 76   return true; | 76   return true; | 
| 77 } | 77 } | 
| 78 | 78 | 
| 79 void GpsLocationProviderLinux::StopProvider() { | 79 void GpsLocationProviderLinux::StopProvider() { | 
| 80   weak_factory_.InvalidateWeakPtrs(); | 80   weak_factory_.InvalidateWeakPtrs(); | 
| 81   gps_.reset(); | 81   gps_.reset(); | 
| 82 } | 82 } | 
| 83 | 83 | 
| 84 void GpsLocationProviderLinux::GetPosition(Geoposition* position) { | 84 void GpsLocationProviderLinux::GetPosition(content::Geoposition* position) { | 
| 85   DCHECK(position); | 85   DCHECK(position); | 
| 86   *position = position_; | 86   *position = position_; | 
| 87   DCHECK(position->IsInitialized()); | 87   DCHECK(position->Validate() || | 
|  | 88          position->error_code != content::Geoposition::ERROR_CODE_NONE); | 
| 88 } | 89 } | 
| 89 | 90 | 
| 90 void GpsLocationProviderLinux::UpdatePosition() { | 91 void GpsLocationProviderLinux::UpdatePosition() { | 
| 91   ScheduleNextGpsPoll(0); | 92   ScheduleNextGpsPoll(0); | 
| 92 } | 93 } | 
| 93 | 94 | 
| 94 void GpsLocationProviderLinux::DoGpsPollTask() { | 95 void GpsLocationProviderLinux::DoGpsPollTask() { | 
| 95   if (!gps_->Start()) { | 96   if (!gps_->Start()) { | 
| 96     DLOG(WARNING) << "Couldn't start GPS provider."; | 97     DLOG(WARNING) << "Couldn't start GPS provider."; | 
| 97     ScheduleNextGpsPoll(gpsd_reconnect_interval_millis_); | 98     ScheduleNextGpsPoll(gpsd_reconnect_interval_millis_); | 
| 98     return; | 99     return; | 
| 99   } | 100   } | 
| 100 | 101 | 
| 101   Geoposition new_position; | 102   content::Geoposition new_position; | 
| 102   if (!gps_->Read(&new_position)) { | 103   if (!gps_->Read(&new_position)) { | 
| 103     ScheduleNextGpsPoll(poll_period_stationary_millis_); | 104     ScheduleNextGpsPoll(poll_period_stationary_millis_); | 
| 104     return; | 105     return; | 
| 105   } | 106   } | 
| 106 | 107 | 
| 107   DCHECK(new_position.IsInitialized()); | 108   DCHECK(new_position.Validate() || | 
|  | 109          new_position.error_code != content::Geoposition::ERROR_CODE_NONE); | 
| 108   const bool differ = PositionsDifferSiginificantly(position_, new_position); | 110   const bool differ = PositionsDifferSiginificantly(position_, new_position); | 
| 109   ScheduleNextGpsPoll(differ ? poll_period_moving_millis_ : | 111   ScheduleNextGpsPoll(differ ? poll_period_moving_millis_ : | 
| 110                                poll_period_stationary_millis_); | 112                                poll_period_stationary_millis_); | 
| 111   if (differ || new_position.error_code != Geoposition::ERROR_CODE_NONE) { | 113   if (differ || | 
|  | 114       new_position.error_code != content::Geoposition::ERROR_CODE_NONE) { | 
| 112     // Update if the new location is interesting or we have an error to report. | 115     // Update if the new location is interesting or we have an error to report. | 
| 113     position_ = new_position; | 116     position_ = new_position; | 
| 114     UpdateListeners(); | 117     UpdateListeners(); | 
| 115   } | 118   } | 
| 116 } | 119 } | 
| 117 | 120 | 
| 118 void GpsLocationProviderLinux::ScheduleNextGpsPoll(int interval) { | 121 void GpsLocationProviderLinux::ScheduleNextGpsPoll(int interval) { | 
| 119   weak_factory_.InvalidateWeakPtrs(); | 122   weak_factory_.InvalidateWeakPtrs(); | 
| 120   MessageLoop::current()->PostDelayedTask( | 123   MessageLoop::current()->PostDelayedTask( | 
| 121       FROM_HERE, | 124       FROM_HERE, | 
| 122       base::Bind(&GpsLocationProviderLinux::DoGpsPollTask, | 125       base::Bind(&GpsLocationProviderLinux::DoGpsPollTask, | 
| 123                  weak_factory_.GetWeakPtr()), | 126                  weak_factory_.GetWeakPtr()), | 
| 124       base::TimeDelta::FromMilliseconds(interval)); | 127       base::TimeDelta::FromMilliseconds(interval)); | 
| 125 } | 128 } | 
| 126 | 129 | 
| 127 LocationProviderBase* NewSystemLocationProvider() { | 130 LocationProviderBase* NewSystemLocationProvider() { | 
| 128   return new GpsLocationProviderLinux(LibGps::New); | 131   return new GpsLocationProviderLinux(LibGps::New); | 
| 129 } | 132 } | 
| OLD | NEW | 
|---|