Chromium Code Reviews| Index: content/browser/vr/vr_service.cc |
| diff --git a/content/browser/vr/vr_service.cc b/content/browser/vr/vr_service.cc |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..3051ca5bdcb9d4b02cef2e1978e61cec17e39a22 |
| --- /dev/null |
| +++ b/content/browser/vr/vr_service.cc |
| @@ -0,0 +1,147 @@ |
| +// Copyright 2015 The Chromium Authors. All rights reserved. |
| +// Use of this source code is governed by a BSD-style license that can be |
| +// found in the LICENSE file. |
| + |
| +#include "content/browser/vr/vr_service.h" |
| + |
| +#include "base/memory/singleton.h" |
| +#include "third_party/WebKit/public/platform/WebVR.h" |
| + |
| +#if defined(OS_ANDROID) |
| +#include "content/browser/vr/cardboard/cardboard_vr_device_provider.h" |
| +#endif |
| + |
| +namespace content { |
| + |
| +namespace { |
| +VRService* g_vr_service = NULL; |
| +} |
| + |
| +VRService::VRService() : |
| + vr_initialized_(false), |
| + keep_alive_(false) { |
| +#if defined(OS_ANDROID) |
| + scoped_ptr<VRDeviceProvider> cardboard_provider( |
| + new CardboardVRDeviceProvider()); |
| + RegisterProvider(cardboard_provider.Pass()); |
| +#endif |
| +} |
| + |
| +VRService::VRService(scoped_ptr<VRDeviceProvider> provider) : |
| + vr_initialized_(false), |
| + keep_alive_(true) { |
| + thread_checker_.DetachFromThread(); |
| + RegisterProvider(provider.Pass()); |
| + SetInstance(this); |
| +} |
| + |
| +VRService::~VRService() { |
| + DCHECK(thread_checker_.CalledOnValidThread()); |
| + g_vr_service = NULL; |
| +} |
| + |
| +VRService* VRService::GetInstance() { |
| + if (!g_vr_service) |
| + g_vr_service = new VRService(); |
| + return g_vr_service; |
| +} |
| + |
| +void VRService::SetInstance(VRService* instance) { |
| + // Unit tests can create multiple instances but only one should exist at any |
| + // given time so g_vr_service should only go from NULL to non-NULL and |
| + // vica versa. |
| + CHECK_NE(!!instance, !!g_vr_service); |
| + g_vr_service = instance; |
| +} |
| + |
| +bool VRService::HasInstance() { |
| + // For testing. Checks to see if a VRService instance is active. |
| + return !!g_vr_service; |
| +} |
| + |
| +void VRService::GetVRDevices( |
| + std::vector<blink::WebVRDevice>* webvr_devices) { |
| + DCHECK(thread_checker_.CalledOnValidThread()); |
| + |
| + if(webvr_devices == NULL) |
|
Ted C
2015/03/28 00:56:04
space after if...more often I would see !webvr_dev
|
| + return; |
| + |
| + InitializeProviders(); |
| + |
| + webvr_devices->clear(); |
| + |
| + ProviderList::iterator iter; |
| + |
| + std::vector<VRDevice*> devices; |
| + |
| + for (iter = providers_.begin(); iter != providers_.end(); ++iter) { |
| + (*iter)->GetDevices(devices); |
| + } |
| + |
| + std::vector<VRDevice*>::iterator diter; |
| + for (diter = devices.begin(); diter != devices.end(); ++diter) { |
| + VRDevice* device = *diter; |
| + if (devices_.find(device->id()) == devices_.end()) { |
| + devices_[device->id()] = device; |
| + } |
| + |
| + blink::WebVRDevice webvr_device; |
| + device->GetVRDevice(&webvr_device); |
| + webvr_device.index = device->id(); |
| + webvr_devices->push_back(webvr_device); |
| + } |
| +} |
| + |
| +VRDevice* VRService::GetDevice(unsigned int index) { |
| + DCHECK(thread_checker_.CalledOnValidThread()); |
| + |
| + DeviceMap::iterator iter = devices_.find(index); |
| + if (iter == devices_.end()) { |
| + return NULL; |
| + } |
| + return iter->second; |
| +} |
| + |
| +void VRService::AddConsumer(VRServiceConsumer* consumer) { |
| + VRService* service = GetInstance(); |
| + DCHECK(service->thread_checker_.CalledOnValidThread()); |
| + |
| + // Explicitly does not initialize the providers. That's done lazily the first |
| + // time GetVRDevices is called. |
| + service->consumers_.insert(consumer); |
| +} |
| + |
| +void VRService::RemoveConsumer(VRServiceConsumer* consumer) { |
| + CHECK(g_vr_service); |
| + DCHECK(g_vr_service->thread_checker_.CalledOnValidThread()); |
| + |
| + ConsumerSet::iterator it = g_vr_service->consumers_.find(consumer); |
| + DCHECK(it != g_vr_service->consumers_.end()); |
| + |
| + if (it != g_vr_service->consumers_.end()) { |
| + g_vr_service->consumers_.erase(it); |
| + if (g_vr_service->consumers_.size() == 0 && !g_vr_service->keep_alive_) { |
| + // Delete the service when it has no consumers left. |
| + delete g_vr_service; |
| + } |
| + } |
| +} |
| + |
| +void VRService::InitializeProviders() { |
| + if (vr_initialized_ == true) { |
| + return; |
| + } |
| + |
| + ProviderList::iterator iter; |
| + for (iter = providers_.begin(); iter != providers_.end(); ++iter) { |
| + (*iter)->Initialize(); |
| + } |
| + |
| + vr_initialized_ = true; |
| +} |
| + |
| +void VRService::RegisterProvider(scoped_ptr<VRDeviceProvider> provider) { |
| + providers_.push_back(make_linked_ptr(provider.release())); |
| +} |
| + |
| +} // namespace content |