| OLD | NEW |
| (Empty) |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "components/proximity_auth/bluetooth_throttler_impl.h" | |
| 6 | |
| 7 #include <utility> | |
| 8 | |
| 9 #include "base/stl_util.h" | |
| 10 #include "base/time/tick_clock.h" | |
| 11 #include "components/proximity_auth/connection.h" | |
| 12 | |
| 13 namespace proximity_auth { | |
| 14 namespace { | |
| 15 | |
| 16 // Time to wait after disconnect before reconnecting. | |
| 17 const int kCooldownTimeSecs = 7; | |
| 18 | |
| 19 } // namespace | |
| 20 | |
| 21 BluetoothThrottlerImpl::BluetoothThrottlerImpl( | |
| 22 std::unique_ptr<base::TickClock> clock) | |
| 23 : clock_(std::move(clock)) {} | |
| 24 | |
| 25 BluetoothThrottlerImpl::~BluetoothThrottlerImpl() { | |
| 26 for (Connection* connection : connections_) { | |
| 27 connection->RemoveObserver(this); | |
| 28 } | |
| 29 } | |
| 30 | |
| 31 base::TimeDelta BluetoothThrottlerImpl::GetDelay() const { | |
| 32 if (last_disconnect_time_.is_null()) | |
| 33 return base::TimeDelta(); | |
| 34 | |
| 35 base::TimeTicks now = clock_->NowTicks(); | |
| 36 base::TimeTicks throttled_start_time = | |
| 37 last_disconnect_time_ + GetCooldownTimeDelta(); | |
| 38 if (now >= throttled_start_time) | |
| 39 return base::TimeDelta(); | |
| 40 | |
| 41 return throttled_start_time - now; | |
| 42 } | |
| 43 | |
| 44 void BluetoothThrottlerImpl::OnConnection(Connection* connection) { | |
| 45 DCHECK(!base::ContainsKey(connections_, connection)); | |
| 46 connections_.insert(connection); | |
| 47 connection->AddObserver(this); | |
| 48 } | |
| 49 | |
| 50 base::TimeDelta BluetoothThrottlerImpl::GetCooldownTimeDelta() const { | |
| 51 return base::TimeDelta::FromSeconds(kCooldownTimeSecs); | |
| 52 } | |
| 53 | |
| 54 void BluetoothThrottlerImpl::OnConnectionStatusChanged( | |
| 55 Connection* connection, | |
| 56 Connection::Status old_status, | |
| 57 Connection::Status new_status) { | |
| 58 DCHECK(base::ContainsKey(connections_, connection)); | |
| 59 if (new_status == Connection::DISCONNECTED) { | |
| 60 last_disconnect_time_ = clock_->NowTicks(); | |
| 61 connection->RemoveObserver(this); | |
| 62 connections_.erase(connection); | |
| 63 } | |
| 64 } | |
| 65 | |
| 66 } // namespace proximity_auth | |
| OLD | NEW |