blob: 4df4b8221cd3507f6390671eab19735ed3ae33d1 [file] [log] [blame]
// Copyright 2018 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef CHROMECAST_DEVICE_BLUETOOTH_LE_LE_SCAN_MANAGER_IMPL_H_
#define CHROMECAST_DEVICE_BLUETOOTH_LE_LE_SCAN_MANAGER_IMPL_H_
#include <deque>
#include <list>
#include <map>
#include <set>
#include <vector>
#include "base/functional/callback.h"
#include "base/observer_list_threadsafe.h"
#include "base/task/single_thread_task_runner.h"
#include "chromecast/device/bluetooth/le/le_scan_manager.h"
#include "chromecast/device/bluetooth/le/scan_filter.h"
#include "chromecast/device/bluetooth/shlib/le_scanner.h"
namespace chromecast {
namespace bluetooth {
class LeScanManagerImpl : public LeScanManager,
public bluetooth_v2_shlib::LeScanner::Delegate {
public:
explicit LeScanManagerImpl(bluetooth_v2_shlib::LeScannerImpl* le_scanner);
LeScanManagerImpl(const LeScanManagerImpl&) = delete;
LeScanManagerImpl& operator=(const LeScanManagerImpl&) = delete;
~LeScanManagerImpl() override;
static constexpr int kMaxScanResultEntries = 1024;
// LeScanManager implementation:
void Initialize(
scoped_refptr<base::SingleThreadTaskRunner> io_task_runner) override;
void Finalize() override;
void AddObserver(Observer* o) override;
void RemoveObserver(Observer* o) override;
void RequestScan(RequestScanCallback cb) override;
void GetScanResults(
GetScanResultsCallback cb,
std::optional<ScanFilter> service_uuid = std::nullopt) override;
void ClearScanResults() override;
void PauseScan() override;
void ResumeScan() override;
void SetScanParameters(int scan_interval_ms, int scan_window_ms) override;
private:
class ScanHandleImpl;
// bluetooth_v2_shlib::LeScanner::Delegate implementation:
void OnScanResult(const bluetooth_v2_shlib::LeScanner::ScanResult&
scan_result_shlib) override;
void InitializeOnIoThread();
// Returns a list of all BLE scan results. The results are sorted by RSSI.
// Must be called on |io_task_runner|.
std::vector<LeScanResult> GetScanResultsInternal(
std::optional<ScanFilter> service_uuid);
void NotifyScanHandleDestroyed(int32_t id);
bluetooth_v2_shlib::LeScannerImpl* const le_scanner_;
scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_;
scoped_refptr<base::ObserverListThreadSafe<Observer>> observers_;
std::map<bluetooth_v2_shlib::Addr, std::list<LeScanResult>>
addr_to_scan_results_;
// List of addresses in scan results. Addresses are sorted from most recently
// used to least recently used.
std::deque<bluetooth_v2_shlib::Addr> scan_result_addr_list_;
int32_t next_scan_handle_id_ = 0;
std::set<int32_t> scan_handle_ids_;
base::WeakPtrFactory<LeScanManagerImpl> weak_factory_;
};
} // namespace bluetooth
} // namespace chromecast
#endif // CHROMECAST_DEVICE_BLUETOOTH_LE_LE_SCAN_MANAGER_IMPL_H_