OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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/child/bluetooth/bluetooth_dispatcher.h" | 5 #include "content/child/bluetooth/bluetooth_dispatcher.h" |
6 | 6 |
7 #include "base/lazy_instance.h" | 7 #include "base/lazy_instance.h" |
8 #include "base/memory/scoped_ptr.h" | 8 #include "base/memory/scoped_ptr.h" |
9 #include "base/message_loop/message_loop.h" | 9 #include "base/message_loop/message_loop.h" |
10 #include "base/thread_task_runner_handle.h" | 10 #include "base/thread_task_runner_handle.h" |
11 #include "content/child/thread_safe_sender.h" | 11 #include "content/child/thread_safe_sender.h" |
12 #include "content/child/worker_thread_task_runner.h" | 12 #include "content/child/worker_thread_task_runner.h" |
13 #include "content/common/bluetooth/bluetooth_messages.h" | 13 #include "content/common/bluetooth/bluetooth_messages.h" |
14 #include "third_party/WebKit/public/platform/WebBluetoothDevice.h" | 14 #include "third_party/WebKit/public/platform/WebBluetoothDevice.h" |
15 #include "third_party/WebKit/public/platform/WebBluetoothError.h" | 15 #include "third_party/WebKit/public/platform/WebBluetoothError.h" |
16 | 16 |
17 using blink::WebBluetoothDevice; | 17 using blink::WebBluetoothDevice; |
18 using blink::WebBluetoothError; | 18 using blink::WebBluetoothError; |
19 using blink::WebBluetoothRequestDeviceCallbacks; | 19 using blink::WebBluetoothRequestDeviceCallbacks; |
20 using blink::WebString; | 20 using blink::WebString; |
| 21 using blink::WebVector; |
21 | 22 |
22 namespace content { | 23 namespace content { |
23 | 24 |
24 namespace { | 25 namespace { |
25 | 26 |
26 base::LazyInstance<base::ThreadLocalPointer<BluetoothDispatcher>>::Leaky | 27 base::LazyInstance<base::ThreadLocalPointer<BluetoothDispatcher>>::Leaky |
27 g_dispatcher_tls = LAZY_INSTANCE_INITIALIZER; | 28 g_dispatcher_tls = LAZY_INSTANCE_INITIALIZER; |
28 | 29 |
29 BluetoothDispatcher* const kHasBeenDeleted = | 30 BluetoothDispatcher* const kHasBeenDeleted = |
30 reinterpret_cast<BluetoothDispatcher*>(0x1); | 31 reinterpret_cast<BluetoothDispatcher*>(0x1); |
31 | 32 |
32 int CurrentWorkerId() { | 33 int CurrentWorkerId() { |
33 return WorkerTaskRunner::Instance()->CurrentWorkerId(); | 34 return WorkerTaskRunner::Instance()->CurrentWorkerId(); |
34 } | 35 } |
35 | 36 |
36 WebBluetoothError::ErrorType WebBluetoothErrorFromBluetoothError( | 37 WebBluetoothError::ErrorType WebBluetoothErrorFromBluetoothError( |
37 BluetoothError error_type) { | 38 BluetoothError error_type) { |
38 switch (error_type) { | 39 switch (error_type) { |
39 case BluetoothError::NOT_FOUND: | 40 case BluetoothError::NOT_FOUND: |
40 return WebBluetoothError::NotFoundError; | 41 return WebBluetoothError::NotFoundError; |
41 case BluetoothError::SECURITY: | 42 case BluetoothError::SECURITY: |
42 return WebBluetoothError::SecurityError; | 43 return WebBluetoothError::SecurityError; |
43 } | 44 } |
44 NOTIMPLEMENTED(); | 45 NOTIMPLEMENTED(); |
45 return WebBluetoothError::NotFoundError; | 46 return WebBluetoothError::NotFoundError; |
46 } | 47 } |
47 | 48 |
| 49 WebBluetoothDevice::VendorIDSource GetWebVendorIdSource( |
| 50 device::BluetoothDevice::VendorIDSource vendor_id_source) { |
| 51 switch (vendor_id_source) { |
| 52 case device::BluetoothDevice::VENDOR_ID_UNKNOWN: |
| 53 return WebBluetoothDevice::VendorIDSource::Unknown; |
| 54 case device::BluetoothDevice::VENDOR_ID_BLUETOOTH: |
| 55 return WebBluetoothDevice::VendorIDSource::Bluetooth; |
| 56 case device::BluetoothDevice::VENDOR_ID_USB: |
| 57 return WebBluetoothDevice::VendorIDSource::USB; |
| 58 } |
| 59 NOTREACHED(); |
| 60 return WebBluetoothDevice::VendorIDSource::Unknown; |
| 61 } |
| 62 |
48 } // namespace | 63 } // namespace |
49 | 64 |
50 BluetoothDispatcher::BluetoothDispatcher(ThreadSafeSender* sender) | 65 BluetoothDispatcher::BluetoothDispatcher(ThreadSafeSender* sender) |
51 : thread_safe_sender_(sender) { | 66 : thread_safe_sender_(sender) { |
52 g_dispatcher_tls.Pointer()->Set(this); | 67 g_dispatcher_tls.Pointer()->Set(this); |
53 } | 68 } |
54 | 69 |
55 BluetoothDispatcher::~BluetoothDispatcher() { | 70 BluetoothDispatcher::~BluetoothDispatcher() { |
56 g_dispatcher_tls.Pointer()->Set(kHasBeenDeleted); | 71 g_dispatcher_tls.Pointer()->Set(kHasBeenDeleted); |
57 } | 72 } |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
97 Send(new BluetoothHostMsg_SetBluetoothMockDataSetForTesting(name)); | 112 Send(new BluetoothHostMsg_SetBluetoothMockDataSetForTesting(name)); |
98 } | 113 } |
99 | 114 |
100 void BluetoothDispatcher::OnWorkerRunLoopStopped() { | 115 void BluetoothDispatcher::OnWorkerRunLoopStopped() { |
101 delete this; | 116 delete this; |
102 } | 117 } |
103 | 118 |
104 void BluetoothDispatcher::OnRequestDeviceSuccess( | 119 void BluetoothDispatcher::OnRequestDeviceSuccess( |
105 int thread_id, | 120 int thread_id, |
106 int request_id, | 121 int request_id, |
107 const std::string& device_instance_id) { | 122 const BluetoothDevice& device) { |
108 DCHECK(pending_requests_.Lookup(request_id)) << request_id; | 123 DCHECK(pending_requests_.Lookup(request_id)) << request_id; |
| 124 |
| 125 WebVector<WebString> uuids(device.uuids.size()); |
| 126 for (size_t i = 0; i < device.uuids.size(); ++i) |
| 127 uuids[i] = WebString::fromUTF8(device.uuids[i].c_str()); |
| 128 |
109 pending_requests_.Lookup(request_id) | 129 pending_requests_.Lookup(request_id) |
110 ->onSuccess( | 130 ->onSuccess(new WebBluetoothDevice( |
111 new WebBluetoothDevice(WebString::fromUTF8(device_instance_id))); | 131 WebString::fromUTF8(device.instance_id), WebString(device.name), |
| 132 device.device_class, GetWebVendorIdSource(device.vendor_id_source), |
| 133 device.vendor_id, device.product_id, device.product_version, |
| 134 device.paired, device.connected, uuids)); |
112 pending_requests_.Remove(request_id); | 135 pending_requests_.Remove(request_id); |
113 } | 136 } |
114 | 137 |
115 void BluetoothDispatcher::OnRequestDeviceError(int thread_id, | 138 void BluetoothDispatcher::OnRequestDeviceError(int thread_id, |
116 int request_id, | 139 int request_id, |
117 BluetoothError error_type) { | 140 BluetoothError error_type) { |
118 DCHECK(pending_requests_.Lookup(request_id)) << request_id; | 141 DCHECK(pending_requests_.Lookup(request_id)) << request_id; |
119 pending_requests_.Lookup(request_id) | 142 pending_requests_.Lookup(request_id) |
120 ->onError(new WebBluetoothError( | 143 ->onError(new WebBluetoothError( |
121 WebBluetoothErrorFromBluetoothError(error_type), "")); | 144 WebBluetoothErrorFromBluetoothError(error_type), "")); |
122 pending_requests_.Remove(request_id); | 145 pending_requests_.Remove(request_id); |
123 } | 146 } |
124 | 147 |
125 } // namespace content | 148 } // namespace content |
OLD | NEW |