Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(137)

Side by Side Diff: device/bluetooth/bluetooth_adapter_factory_wrapper.cc

Issue 2059543002: bluetooth: Move FactoryWrapper to device and expose a function for testing in chooser controller (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@my-origin
Patch Set: Fix typo Created 4 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2016 The Chromium Authors. All rights reserved. 1 // Copyright 2016 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/bluetooth/bluetooth_adapter_factory_wrapper.h" 5 #include "device/bluetooth/bluetooth_adapter_factory_wrapper.h"
6 6
7 #include <stddef.h> 7 #include <stddef.h>
8 8
9 #include <utility> 9 #include <utility>
10 10
11 #include "base/bind.h"
12 #include "base/location.h"
11 #include "base/threading/thread_task_runner_handle.h" 13 #include "base/threading/thread_task_runner_handle.h"
12 #include "base/time/time.h"
13 #include "content/public/browser/browser_thread.h"
14 #include "device/bluetooth/bluetooth_adapter_factory.h" 14 #include "device/bluetooth/bluetooth_adapter_factory.h"
15 15
16 using device::BluetoothAdapter; 16 namespace {
17 using device::BluetoothAdapterFactory;
18 17
19 namespace { 18 static base::LazyInstance<device::BluetoothAdapterFactoryWrapper>::Leaky
20 // TODO(ortuno): Once we have a chooser for scanning and a way to control that 19 g_singleton = LAZY_INSTANCE_INITIALIZER;
21 // chooser from tests we should delete this constant. 20
22 // https://crbug.com/436280
23 enum { kTestingScanDuration = 0 }; // No need to wait when testing.
24 enum { kScanDuration = 10 };
25 } // namespace 21 } // namespace
26 22
27 namespace content { 23 namespace device {
28
29 BluetoothAdapterFactoryWrapper::BluetoothAdapterFactoryWrapper()
30 : scan_duration_(base::TimeDelta::FromSecondsD(kScanDuration)),
31 testing_(false),
32 weak_ptr_factory_(this) {
33 DCHECK_CURRENTLY_ON(BrowserThread::UI);
34 }
35 24
36 BluetoothAdapterFactoryWrapper::~BluetoothAdapterFactoryWrapper() { 25 BluetoothAdapterFactoryWrapper::~BluetoothAdapterFactoryWrapper() {
37 DCHECK_CURRENTLY_ON(BrowserThread::UI);
38 // All observers should have been removed already. 26 // All observers should have been removed already.
39 DCHECK(adapter_observers_.empty()); 27 DCHECK(adapter_observers_.empty());
40 // Clear adapter. 28 // Clear adapter.
41 set_adapter(scoped_refptr<device::BluetoothAdapter>()); 29 set_adapter(scoped_refptr<BluetoothAdapter>());
30 }
31
32 // static
33 BluetoothAdapterFactoryWrapper& BluetoothAdapterFactoryWrapper::Get() {
34 return g_singleton.Get();
42 } 35 }
43 36
44 bool BluetoothAdapterFactoryWrapper::IsBluetoothAdapterAvailable() { 37 bool BluetoothAdapterFactoryWrapper::IsBluetoothAdapterAvailable() {
45 DCHECK_CURRENTLY_ON(BrowserThread::UI); 38 return BluetoothAdapterFactory::IsBluetoothAdapterAvailable();
46 return BluetoothAdapterFactory::IsBluetoothAdapterAvailable() || testing_;
47 } 39 }
48 40
49 void BluetoothAdapterFactoryWrapper::AcquireAdapter( 41 void BluetoothAdapterFactoryWrapper::AcquireAdapter(
50 device::BluetoothAdapter::Observer* observer, 42 BluetoothAdapter::Observer* observer,
51 const AcquireAdapterCallback& callback) { 43 const AcquireAdapterCallback& callback) {
52 DCHECK_CURRENTLY_ON(BrowserThread::UI);
53 DCHECK(!GetAdapter(observer)); 44 DCHECK(!GetAdapter(observer));
54 45
55 AddAdapterObserver(observer); 46 AddAdapterObserver(observer);
56 if (adapter_.get()) { 47 if (adapter_.get()) {
57 base::ThreadTaskRunnerHandle::Get()->PostTask( 48 base::ThreadTaskRunnerHandle::Get()->PostTask(
58 FROM_HERE, base::Bind(callback, base::Unretained(adapter_.get()))); 49 FROM_HERE, base::Bind(callback, base::Unretained(adapter_.get())));
59 return; 50 return;
60 } 51 }
61 52
62 DCHECK(BluetoothAdapterFactory::IsBluetoothAdapterAvailable()); 53 DCHECK(BluetoothAdapterFactory::IsBluetoothAdapterAvailable());
63 BluetoothAdapterFactory::GetAdapter( 54 BluetoothAdapterFactory::GetAdapter(
64 base::Bind(&BluetoothAdapterFactoryWrapper::OnGetAdapter, 55 base::Bind(&BluetoothAdapterFactoryWrapper::OnGetAdapter,
65 weak_ptr_factory_.GetWeakPtr(), callback)); 56 weak_ptr_factory_.GetWeakPtr(), callback));
66 } 57 }
67 58
68 void BluetoothAdapterFactoryWrapper::ReleaseAdapter( 59 void BluetoothAdapterFactoryWrapper::ReleaseAdapter(
69 device::BluetoothAdapter::Observer* observer) { 60 BluetoothAdapter::Observer* observer) {
scheib 2016/06/22 03:44:22 If the thread checks were useful we can keep the g
ortuno 2016/06/23 21:54:59 Done.
70 DCHECK_CURRENTLY_ON(BrowserThread::UI);
71 if (!HasAdapter(observer)) { 61 if (!HasAdapter(observer)) {
72 return; 62 return;
73 } 63 }
74 RemoveAdapterObserver(observer); 64 RemoveAdapterObserver(observer);
75 if (adapter_observers_.empty()) 65 if (adapter_observers_.empty())
76 set_adapter(scoped_refptr<device::BluetoothAdapter>()); 66 set_adapter(scoped_refptr<BluetoothAdapter>());
77 } 67 }
78 68
79 BluetoothAdapter* BluetoothAdapterFactoryWrapper::GetAdapter( 69 BluetoothAdapter* BluetoothAdapterFactoryWrapper::GetAdapter(
80 device::BluetoothAdapter::Observer* observer) { 70 BluetoothAdapter::Observer* observer) {
81 DCHECK_CURRENTLY_ON(BrowserThread::UI);
82 if (HasAdapter(observer)) { 71 if (HasAdapter(observer)) {
83 return adapter_.get(); 72 return adapter_.get();
84 } 73 }
85 return nullptr; 74 return nullptr;
86 } 75 }
87 76
88 void BluetoothAdapterFactoryWrapper::SetBluetoothAdapterForTesting( 77 void BluetoothAdapterFactoryWrapper::SetBluetoothAdapterForTesting(
89 scoped_refptr<device::BluetoothAdapter> mock_adapter) { 78 scoped_refptr<BluetoothAdapter> mock_adapter) {
90 DCHECK_CURRENTLY_ON(BrowserThread::UI);
91 scan_duration_ = base::TimeDelta::FromSecondsD(kTestingScanDuration);
92 testing_ = true;
93 set_adapter(std::move(mock_adapter)); 79 set_adapter(std::move(mock_adapter));
94 } 80 }
95 81
82 BluetoothAdapterFactoryWrapper::BluetoothAdapterFactoryWrapper()
83 : weak_ptr_factory_(this) {}
84
96 void BluetoothAdapterFactoryWrapper::OnGetAdapter( 85 void BluetoothAdapterFactoryWrapper::OnGetAdapter(
97 const AcquireAdapterCallback& continuation, 86 const AcquireAdapterCallback& continuation,
98 scoped_refptr<device::BluetoothAdapter> adapter) { 87 scoped_refptr<BluetoothAdapter> adapter) {
99 DCHECK_CURRENTLY_ON(BrowserThread::UI);
100 set_adapter(adapter); 88 set_adapter(adapter);
101 continuation.Run(adapter_.get()); 89 continuation.Run(adapter_.get());
102 } 90 }
103 91
104 bool BluetoothAdapterFactoryWrapper::HasAdapter( 92 bool BluetoothAdapterFactoryWrapper::HasAdapter(
105 device::BluetoothAdapter::Observer* observer) { 93 BluetoothAdapter::Observer* observer) {
106 DCHECK_CURRENTLY_ON(BrowserThread::UI);
107 return ContainsKey(adapter_observers_, observer); 94 return ContainsKey(adapter_observers_, observer);
108 } 95 }
109 96
110 void BluetoothAdapterFactoryWrapper::AddAdapterObserver( 97 void BluetoothAdapterFactoryWrapper::AddAdapterObserver(
111 device::BluetoothAdapter::Observer* observer) { 98 BluetoothAdapter::Observer* observer) {
112 DCHECK_CURRENTLY_ON(BrowserThread::UI);
113 auto iter = adapter_observers_.insert(observer); 99 auto iter = adapter_observers_.insert(observer);
114 DCHECK(iter.second); 100 DCHECK(iter.second);
115 if (adapter_) { 101 if (adapter_) {
116 adapter_->AddObserver(observer); 102 adapter_->AddObserver(observer);
117 } 103 }
118 } 104 }
119 105
120 void BluetoothAdapterFactoryWrapper::RemoveAdapterObserver( 106 void BluetoothAdapterFactoryWrapper::RemoveAdapterObserver(
121 device::BluetoothAdapter::Observer* observer) { 107 BluetoothAdapter::Observer* observer) {
122 DCHECK_CURRENTLY_ON(BrowserThread::UI);
123 size_t removed = adapter_observers_.erase(observer); 108 size_t removed = adapter_observers_.erase(observer);
124 DCHECK(removed); 109 DCHECK(removed);
125 if (adapter_) { 110 if (adapter_) {
126 adapter_->RemoveObserver(observer); 111 adapter_->RemoveObserver(observer);
127 } 112 }
128 } 113 }
129 114
130 void BluetoothAdapterFactoryWrapper::set_adapter( 115 void BluetoothAdapterFactoryWrapper::set_adapter(
131 scoped_refptr<device::BluetoothAdapter> adapter) { 116 scoped_refptr<BluetoothAdapter> adapter) {
132 DCHECK_CURRENTLY_ON(BrowserThread::UI);
133 if (adapter_.get()) { 117 if (adapter_.get()) {
134 for (device::BluetoothAdapter::Observer* observer : adapter_observers_) { 118 for (BluetoothAdapter::Observer* observer : adapter_observers_) {
135 adapter_->RemoveObserver(observer); 119 adapter_->RemoveObserver(observer);
136 } 120 }
137 } 121 }
138 adapter_ = adapter; 122 adapter_ = adapter;
139 if (adapter_.get()) { 123 if (adapter_.get()) {
140 for (device::BluetoothAdapter::Observer* observer : adapter_observers_) { 124 for (BluetoothAdapter::Observer* observer : adapter_observers_) {
141 adapter_->AddObserver(observer); 125 adapter_->AddObserver(observer);
142 } 126 }
143 } 127 }
144 } 128 }
145 129
146 } // namespace content 130 } // namespace device
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698