OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 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 | 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 "device/vr/vr_device_manager.h" | 5 #include "device/vr/vr_device_manager.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/memory/singleton.h" | 10 #include "base/memory/singleton.h" |
11 #include "build/build_config.h" | 11 #include "build/build_config.h" |
12 | 12 |
13 #if defined(OS_ANDROID) | 13 #if defined(OS_ANDROID) |
14 #include "device/vr/android/cardboard/cardboard_vr_device_provider.h" | 14 #include "device/vr/android/cardboard/cardboard_vr_device_provider.h" |
15 #endif | 15 #endif |
16 | 16 |
17 namespace device { | 17 namespace device { |
18 | 18 |
19 namespace { | 19 namespace { |
20 VRDeviceManager* g_vr_device_manager = nullptr; | 20 VRDeviceManager* g_vr_device_manager = nullptr; |
21 } | 21 } |
22 | 22 |
23 VRDeviceManager::VRDeviceManager() | 23 VRDeviceManager::VRDeviceManager() |
24 : vr_initialized_(false), keep_alive_(false) { | 24 : vr_initialized_(false), keep_alive_(false) { |
25 bindings_.set_connection_error_handler( | |
26 base::Bind(&VRDeviceManager::OnConnectionError, base::Unretained(this))); | |
27 // Register VRDeviceProviders for the current platform | 25 // Register VRDeviceProviders for the current platform |
28 #if defined(OS_ANDROID) | 26 #if defined(OS_ANDROID) |
29 std::unique_ptr<VRDeviceProvider> cardboard_provider( | 27 std::unique_ptr<VRDeviceProvider> cardboard_provider( |
30 new CardboardVRDeviceProvider()); | 28 new CardboardVRDeviceProvider()); |
31 RegisterProvider(std::move(cardboard_provider)); | 29 RegisterProvider(std::move(cardboard_provider)); |
32 #endif | 30 #endif |
33 } | 31 } |
34 | 32 |
35 VRDeviceManager::VRDeviceManager(std::unique_ptr<VRDeviceProvider> provider) | 33 VRDeviceManager::VRDeviceManager(std::unique_ptr<VRDeviceProvider> provider) |
36 : vr_initialized_(false), keep_alive_(true) { | 34 : vr_initialized_(false), keep_alive_(true) { |
37 thread_checker_.DetachFromThread(); | 35 thread_checker_.DetachFromThread(); |
38 RegisterProvider(std::move(provider)); | 36 RegisterProvider(std::move(provider)); |
39 SetInstance(this); | 37 SetInstance(this); |
40 } | 38 } |
41 | 39 |
42 VRDeviceManager::~VRDeviceManager() { | 40 VRDeviceManager::~VRDeviceManager() { |
43 DCHECK(thread_checker_.CalledOnValidThread()); | 41 DCHECK(thread_checker_.CalledOnValidThread()); |
44 g_vr_device_manager = nullptr; | 42 g_vr_device_manager = nullptr; |
45 } | 43 } |
46 | 44 |
47 void VRDeviceManager::BindRequest(mojo::InterfaceRequest<VRService> request) { | |
48 VRDeviceManager* device_manager = GetInstance(); | |
49 device_manager->bindings_.AddBinding(device_manager, std::move(request)); | |
50 } | |
51 | |
52 void VRDeviceManager::OnConnectionError() { | |
53 DCHECK(thread_checker_.CalledOnValidThread()); | |
54 if (bindings_.empty() && !keep_alive_) { | |
55 // Delete the device manager when it has no active connections. | |
56 delete g_vr_device_manager; | |
57 } | |
58 } | |
59 | |
60 VRDeviceManager* VRDeviceManager::GetInstance() { | 45 VRDeviceManager* VRDeviceManager::GetInstance() { |
61 if (!g_vr_device_manager) | 46 if (!g_vr_device_manager) |
62 g_vr_device_manager = new VRDeviceManager(); | 47 g_vr_device_manager = new VRDeviceManager(); |
63 return g_vr_device_manager; | 48 return g_vr_device_manager; |
64 } | 49 } |
65 | 50 |
66 void VRDeviceManager::SetInstance(VRDeviceManager* instance) { | 51 void VRDeviceManager::SetInstance(VRDeviceManager* instance) { |
67 // Unit tests can create multiple instances but only one should exist at any | 52 // Unit tests can create multiple instances but only one should exist at any |
68 // given time so g_vr_device_manager should only go from nullptr to | 53 // given time so g_vr_device_manager should only go from nullptr to |
69 // non-nullptr and vica versa. | 54 // non-nullptr and vica versa. |
70 CHECK_NE(!!instance, !!g_vr_device_manager); | 55 CHECK_NE(!!instance, !!g_vr_device_manager); |
71 g_vr_device_manager = instance; | 56 g_vr_device_manager = instance; |
72 } | 57 } |
73 | 58 |
74 bool VRDeviceManager::HasInstance() { | 59 bool VRDeviceManager::HasInstance() { |
75 // For testing. Checks to see if a VRDeviceManager instance is active. | 60 // For testing. Checks to see if a VRDeviceManager instance is active. |
76 return !!g_vr_device_manager; | 61 return !!g_vr_device_manager; |
77 } | 62 } |
78 | 63 |
| 64 void VRDeviceManager::AddService(VRServiceImpl* service) { |
| 65 LOG(ERROR) << "VRDeviceManager::AddService"; |
| 66 services_.push_back(service); |
| 67 |
| 68 // Ensure that the device providers are initialized |
| 69 InitializeProviders(); |
| 70 } |
| 71 |
| 72 void VRDeviceManager::RemoveService(VRServiceImpl* service) { |
| 73 LOG(ERROR) << "VRDeviceManager::RemoveService"; |
| 74 services_.erase(std::remove(services_.begin(), services_.end(), service), |
| 75 services_.end()); |
| 76 |
| 77 if (services_.empty() && !keep_alive_) { |
| 78 // Delete the device manager when it has no active connections. |
| 79 delete g_vr_device_manager; |
| 80 } |
| 81 } |
| 82 |
79 mojo::Array<VRDisplayPtr> VRDeviceManager::GetVRDevices() { | 83 mojo::Array<VRDisplayPtr> VRDeviceManager::GetVRDevices() { |
80 DCHECK(thread_checker_.CalledOnValidThread()); | 84 DCHECK(thread_checker_.CalledOnValidThread()); |
81 | 85 |
82 InitializeProviders(); | 86 InitializeProviders(); |
83 | 87 |
84 std::vector<VRDevice*> devices; | 88 std::vector<VRDevice*> devices; |
85 for (const auto& provider : providers_) | 89 for (const auto& provider : providers_) |
86 provider->GetDevices(&devices); | 90 provider->GetDevices(&devices); |
87 | 91 |
88 mojo::Array<VRDisplayPtr> out_devices; | 92 mojo::Array<VRDisplayPtr> out_devices; |
(...skipping 22 matching lines...) Expand all Loading... |
111 return NULL; | 115 return NULL; |
112 } | 116 } |
113 | 117 |
114 DeviceMap::iterator iter = devices_.find(index); | 118 DeviceMap::iterator iter = devices_.find(index); |
115 if (iter == devices_.end()) { | 119 if (iter == devices_.end()) { |
116 return nullptr; | 120 return nullptr; |
117 } | 121 } |
118 return iter->second; | 122 return iter->second; |
119 } | 123 } |
120 | 124 |
| 125 // These dispatchers must use Clone() instead of std::move to ensure that |
| 126 // if there are multiple registered services they all get a copy of the data. |
| 127 void VRDeviceManager::OnDeviceChanged(VRDisplayPtr device) { |
| 128 for (const auto& service : services_) |
| 129 service->client()->OnDisplayChanged(device.Clone()); |
| 130 } |
| 131 |
121 void VRDeviceManager::InitializeProviders() { | 132 void VRDeviceManager::InitializeProviders() { |
122 if (vr_initialized_) { | 133 if (vr_initialized_) { |
123 return; | 134 return; |
124 } | 135 } |
125 | 136 |
126 for (const auto& provider : providers_) | 137 for (const auto& provider : providers_) |
127 provider->Initialize(); | 138 provider->Initialize(); |
128 | 139 |
129 vr_initialized_ = true; | 140 vr_initialized_ = true; |
130 } | 141 } |
131 | 142 |
132 void VRDeviceManager::RegisterProvider( | 143 void VRDeviceManager::RegisterProvider( |
133 std::unique_ptr<VRDeviceProvider> provider) { | 144 std::unique_ptr<VRDeviceProvider> provider) { |
134 providers_.push_back(make_linked_ptr(provider.release())); | 145 providers_.push_back(make_linked_ptr(provider.release())); |
135 } | 146 } |
136 | 147 |
137 void VRDeviceManager::GetDisplays(const GetDisplaysCallback& callback) { | |
138 callback.Run(GetVRDevices()); | |
139 } | |
140 | |
141 void VRDeviceManager::GetPose(uint32_t index, const GetPoseCallback& callback) { | |
142 VRDevice* device = GetDevice(index); | |
143 if (device) { | |
144 callback.Run(device->GetPose()); | |
145 } else { | |
146 callback.Run(nullptr); | |
147 } | |
148 } | |
149 | |
150 void VRDeviceManager::ResetPose(uint32_t index) { | |
151 VRDevice* device = GetDevice(index); | |
152 if (device) | |
153 device->ResetPose(); | |
154 } | |
155 | |
156 } // namespace device | 148 } // namespace device |
OLD | NEW |