| OLD | NEW |
| 1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 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 #ifndef CHROMEOS_COMPONENTS_TETHER_BLE_CONNECTION_MANAGER_H_ | 5 #ifndef CHROMEOS_COMPONENTS_TETHER_BLE_CONNECTION_MANAGER_H_ |
| 6 #define CHROMEOS_COMPONENTS_TETHER_BLE_CONNECTION_MANAGER_H_ | 6 #define CHROMEOS_COMPONENTS_TETHER_BLE_CONNECTION_MANAGER_H_ |
| 7 | 7 |
| 8 #include <map> | 8 #include <map> |
| 9 #include <set> | 9 #include <set> |
| 10 #include <string> | 10 #include <string> |
| (...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 102 | 102 |
| 103 void AddObserver(Observer* observer); | 103 void AddObserver(Observer* observer); |
| 104 void RemoveObserver(Observer* observer); | 104 void RemoveObserver(Observer* observer); |
| 105 | 105 |
| 106 // BleScanner::Observer: | 106 // BleScanner::Observer: |
| 107 void OnReceivedAdvertisementFromDevice( | 107 void OnReceivedAdvertisementFromDevice( |
| 108 const std::string& device_address, | 108 const std::string& device_address, |
| 109 cryptauth::RemoteDevice remote_device) override; | 109 cryptauth::RemoteDevice remote_device) override; |
| 110 | 110 |
| 111 protected: | 111 protected: |
| 112 class TimerFactory { |
| 113 public: |
| 114 virtual std::unique_ptr<base::Timer> CreateTimer(); |
| 115 }; |
| 116 |
| 117 BleConnectionManager( |
| 118 cryptauth::CryptAuthService* cryptauth_service, |
| 119 scoped_refptr<device::BluetoothAdapter> adapter, |
| 120 std::unique_ptr<BleScanner> ble_scanner, |
| 121 std::unique_ptr<BleAdvertiser> ble_advertiser, |
| 122 std::unique_ptr<BleAdvertisementDeviceQueue> device_queue, |
| 123 std::unique_ptr<TimerFactory> timer_factory, |
| 124 cryptauth::BluetoothThrottler* bluetooth_throttler); |
| 125 |
| 112 void SendMessageReceivedEvent(const cryptauth::RemoteDevice& remote_device, | 126 void SendMessageReceivedEvent(const cryptauth::RemoteDevice& remote_device, |
| 113 const std::string& payload); | 127 const std::string& payload); |
| 114 void SendSecureChannelStatusChangeEvent( | 128 void SendSecureChannelStatusChangeEvent( |
| 115 const cryptauth::RemoteDevice& remote_device, | 129 const cryptauth::RemoteDevice& remote_device, |
| 116 const cryptauth::SecureChannel::Status& old_status, | 130 const cryptauth::SecureChannel::Status& old_status, |
| 117 const cryptauth::SecureChannel::Status& new_status); | 131 const cryptauth::SecureChannel::Status& new_status); |
| 118 | 132 |
| 119 private: | 133 private: |
| 120 friend class BleConnectionManagerTest; | 134 friend class BleConnectionManagerTest; |
| 121 | 135 |
| (...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 163 | 177 |
| 164 cryptauth::RemoteDevice remote_device_; | 178 cryptauth::RemoteDevice remote_device_; |
| 165 std::set<MessageType> active_connection_reasons_; | 179 std::set<MessageType> active_connection_reasons_; |
| 166 std::shared_ptr<cryptauth::SecureChannel> secure_channel_; | 180 std::shared_ptr<cryptauth::SecureChannel> secure_channel_; |
| 167 std::shared_ptr<base::Timer> connection_attempt_timeout_timer_; | 181 std::shared_ptr<base::Timer> connection_attempt_timeout_timer_; |
| 168 base::WeakPtr<BleConnectionManager> manager_; | 182 base::WeakPtr<BleConnectionManager> manager_; |
| 169 | 183 |
| 170 base::WeakPtrFactory<ConnectionMetadata> weak_ptr_factory_; | 184 base::WeakPtrFactory<ConnectionMetadata> weak_ptr_factory_; |
| 171 }; | 185 }; |
| 172 | 186 |
| 173 class TimerFactory { | |
| 174 public: | |
| 175 virtual std::unique_ptr<base::Timer> CreateTimer(); | |
| 176 }; | |
| 177 | |
| 178 BleConnectionManager( | |
| 179 cryptauth::CryptAuthService* cryptauth_service, | |
| 180 scoped_refptr<device::BluetoothAdapter> adapter, | |
| 181 std::unique_ptr<BleScanner> ble_scanner, | |
| 182 std::unique_ptr<BleAdvertiser> ble_advertiser, | |
| 183 std::unique_ptr<BleAdvertisementDeviceQueue> device_queue, | |
| 184 std::unique_ptr<TimerFactory> timer_factory, | |
| 185 cryptauth::BluetoothThrottler* bluetooth_throttler); | |
| 186 | 187 |
| 187 std::shared_ptr<ConnectionMetadata> GetConnectionMetadata( | 188 std::shared_ptr<ConnectionMetadata> GetConnectionMetadata( |
| 188 const cryptauth::RemoteDevice& remote_device) const; | 189 const cryptauth::RemoteDevice& remote_device) const; |
| 189 std::shared_ptr<ConnectionMetadata> AddMetadataForDevice( | 190 std::shared_ptr<ConnectionMetadata> AddMetadataForDevice( |
| 190 const cryptauth::RemoteDevice& remote_device); | 191 const cryptauth::RemoteDevice& remote_device); |
| 191 | 192 |
| 192 void UpdateConnectionAttempts(); | 193 void UpdateConnectionAttempts(); |
| 193 void UpdateAdvertisementQueue(); | 194 void UpdateAdvertisementQueue(); |
| 194 | 195 |
| 195 void StartConnectionAttempt(const cryptauth::RemoteDevice& remote_device); | 196 void StartConnectionAttempt(const cryptauth::RemoteDevice& remote_device); |
| (...skipping 22 matching lines...) Expand all Loading... |
| 218 base::WeakPtrFactory<BleConnectionManager> weak_ptr_factory_; | 219 base::WeakPtrFactory<BleConnectionManager> weak_ptr_factory_; |
| 219 | 220 |
| 220 DISALLOW_COPY_AND_ASSIGN(BleConnectionManager); | 221 DISALLOW_COPY_AND_ASSIGN(BleConnectionManager); |
| 221 }; | 222 }; |
| 222 | 223 |
| 223 } // namespace tether | 224 } // namespace tether |
| 224 | 225 |
| 225 } // namespace chromeos | 226 } // namespace chromeos |
| 226 | 227 |
| 227 #endif // CHROMEOS_COMPONENTS_TETHER_BLE_CONNECTION_MANAGER_H_ | 228 #endif // CHROMEOS_COMPONENTS_TETHER_BLE_CONNECTION_MANAGER_H_ |
| OLD | NEW |