diff options
| author | joth@chromium.org <joth@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2010-02-12 12:52:04 +0000 |
|---|---|---|
| committer | joth@chromium.org <joth@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2010-02-12 12:52:04 +0000 |
| commit | 58e2782bb1b636d958e4cabf75c18c69a78ff451 (patch) | |
| tree | d31706c33748f21f4c254af611658e62177f1468 /chrome/browser/geolocation/wifi_data_provider_common.cc | |
| parent | bb6d7ccf8f1eb2ecff12918de3dd724a520b1440 (diff) | |
| download | chromium_src-58e2782bb1b636d958e4cabf75c18c69a78ff451.zip chromium_src-58e2782bb1b636d958e4cabf75c18c69a78ff451.tar.gz chromium_src-58e2782bb1b636d958e4cabf75c18c69a78ff451.tar.bz2 | |
Refactor the state-machine & threading out of the windows wifi provider into a cross platform base class
This will make the linux & mac impementations much simpler
BUG=11246
TEST=Aded wifi_data_provider_common_unittest.cc. Run: unit_tests.exe --gtest_filer=Geoloc*
Review URL: http://codereview.chromium.org/604019
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@38890 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'chrome/browser/geolocation/wifi_data_provider_common.cc')
| -rw-r--r-- | chrome/browser/geolocation/wifi_data_provider_common.cc | 77 |
1 files changed, 77 insertions, 0 deletions
diff --git a/chrome/browser/geolocation/wifi_data_provider_common.cc b/chrome/browser/geolocation/wifi_data_provider_common.cc index 07724d5..2091e38 100644 --- a/chrome/browser/geolocation/wifi_data_provider_common.cc +++ b/chrome/browser/geolocation/wifi_data_provider_common.cc @@ -15,3 +15,80 @@ string16 MacAddressAsString16(const uint8 mac_as_int[6]) { mac_as_int[0], mac_as_int[1], mac_as_int[2], mac_as_int[3], mac_as_int[4], mac_as_int[5])); } + +WifiDataProviderCommon::WifiDataProviderCommon() + : Thread(__FILE__), + is_first_scan_complete_(false), + ALLOW_THIS_IN_INITIALIZER_LIST(task_factory_(this)) { +} + +WifiDataProviderCommon::~WifiDataProviderCommon() { + // Thread must be stopped before entering destructor chain to avoid race + // conditions; see comment in DeviceDataProvider::Unregister. + DCHECK(!IsRunning()) << "Must call StopDataProvider before destroying me"; +} + +bool WifiDataProviderCommon::StartDataProvider() { + DCHECK(CalledOnClientThread()); + return Start(); +} + +void WifiDataProviderCommon::StopDataProvider() { + DCHECK(CalledOnClientThread()); + Stop(); +} + +bool WifiDataProviderCommon::GetData(WifiData *data) { + DCHECK(CalledOnClientThread()); + DCHECK(data); + AutoLock lock(data_mutex_); + *data = wifi_data_; + // If we've successfully completed a scan, indicate that we have all of the + // data we can get. + return is_first_scan_complete_; +} + +// Thread implementation +void WifiDataProviderCommon::Init() { + DCHECK(wlan_api_ == NULL); + wlan_api_.reset(NewWlanApi()); + if (wlan_api_ == NULL) { + // Error! Can't do scans, so don't try and schedule one. + is_first_scan_complete_ = true; + return; + } + + DCHECK(polling_policy_ == NULL); + polling_policy_.reset(NewPolicyPolicy()); + DCHECK(polling_policy_ != NULL); + + ScheduleNextScan(); +} + +void WifiDataProviderCommon::CleanUp() { + // Destroy these instances in the thread on which they were created. + wlan_api_.reset(); + polling_policy_.reset(); +} + +void WifiDataProviderCommon::DoWifiScanTask() { + WifiData new_data; + if (wlan_api_->GetAccessPointData(&new_data.access_point_data)) { + data_mutex_.Acquire(); + bool update_available = wifi_data_.DiffersSignificantly(new_data); + wifi_data_ = new_data; + data_mutex_.Release(); + polling_policy_->UpdatePollingInterval(update_available); + if (update_available || !is_first_scan_complete_) { + is_first_scan_complete_ = true; + NotifyListeners(); + } + } + ScheduleNextScan(); +} + +void WifiDataProviderCommon::ScheduleNextScan() { + message_loop()->PostDelayedTask(FROM_HERE, + task_factory_.NewRunnableMethod(&WifiDataProviderCommon::DoWifiScanTask), + polling_policy_->PollingInterval()); +} |