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 3// found in the LICENSE file. 4 5#include "ppapi/nacl_irt/plugin_startup.h" 6 7#include "base/bind.h" 8#include "base/file_descriptor_posix.h" 9#include "base/logging.h" 10#include "base/synchronization/waitable_event.h" 11#include "base/threading/thread.h" 12#include "ipc/ipc_channel_handle.h" 13#include "ppapi/nacl_irt/manifest_service.h" 14#include "ppapi/shared_impl/ppb_audio_shared.h" 15 16namespace ppapi { 17namespace { 18 19int g_nacl_browser_ipc_fd = -1; 20int g_nacl_renderer_ipc_fd = -1; 21int g_manifest_service_fd = -1; 22 23base::WaitableEvent* g_shutdown_event = NULL; 24base::Thread* g_io_thread = NULL; 25ManifestService* g_manifest_service = NULL; 26 27// Creates the manifest service on IO thread so that its Listener's thread and 28// IO thread are shared. Upon completion of the manifest service creation, 29// event is signaled. 30void StartUpManifestServiceOnIOThread(base::WaitableEvent* event) { 31 // The start up must be called only once. 32 DCHECK(!g_manifest_service); 33 // manifest_service_fd must be set. 34 DCHECK_NE(g_manifest_service_fd, -1); 35 // IOThread and shutdown event must be initialized in advance. 36 DCHECK(g_io_thread); 37 DCHECK(g_shutdown_event); 38 39 g_manifest_service = new ManifestService( 40 IPC::ChannelHandle( 41 "NaCl IPC", base::FileDescriptor(g_manifest_service_fd, false)), 42 g_io_thread->message_loop_proxy(), 43 g_shutdown_event); 44 event->Signal(); 45} 46 47} // namespace 48 49void SetIPCFileDescriptors( 50 int browser_ipc_fd, int renderer_ipc_fd, int manifest_service_fd) { 51 // The initialization must be only once. 52 DCHECK_EQ(g_nacl_browser_ipc_fd, -1); 53 DCHECK_EQ(g_nacl_renderer_ipc_fd, -1); 54 DCHECK_EQ(g_manifest_service_fd, -1); 55 g_nacl_browser_ipc_fd = browser_ipc_fd; 56 g_nacl_renderer_ipc_fd = renderer_ipc_fd; 57 g_manifest_service_fd = manifest_service_fd; 58} 59 60void StartUpPlugin() { 61 // The start up must be called only once. 62 DCHECK(!g_shutdown_event); 63 DCHECK(!g_io_thread); 64 65 g_shutdown_event = new base::WaitableEvent(true, false); 66 g_io_thread = new base::Thread("Chrome_NaClIOThread"); 67 g_io_thread->StartWithOptions( 68 base::Thread::Options(base::MessageLoop::TYPE_IO, 0)); 69 70 if (g_manifest_service_fd != -1) { 71 // Manifest service must be created on IOThread so that the main message 72 // handling will be done on the thread, which has a message loop 73 // even before irt_ppapi_start invocation. 74 // TODO(hidehiko,dmichael): This works, but is probably not well designed 75 // usage. Once a better approach is made, replace this by that way. 76 // (crbug.com/364241). 77 base::WaitableEvent event(true, false); 78 g_io_thread->message_loop_proxy()->PostTask( 79 FROM_HERE, 80 base::Bind(StartUpManifestServiceOnIOThread, &event)); 81 event.Wait(); 82 } 83 84 PPB_Audio_Shared::SetNaClMode(); 85} 86 87int GetBrowserIPCFileDescriptor() { 88 // The descriptor must be initialized in advance. 89 DCHECK_NE(g_nacl_browser_ipc_fd, -1); 90 return g_nacl_browser_ipc_fd; 91} 92 93int GetRendererIPCFileDescriptor() { 94 // The descriptor must be initialized in advance. 95 DCHECK_NE(g_nacl_renderer_ipc_fd, -1); 96 return g_nacl_renderer_ipc_fd; 97} 98 99base::WaitableEvent* GetShutdownEvent() { 100 // The shutdown event must be initialized in advance. 101 DCHECK(g_shutdown_event); 102 return g_shutdown_event; 103} 104 105base::Thread* GetIOThread() { 106 // The IOThread must be initialized in advance. 107 DCHECK(g_io_thread); 108 return g_io_thread; 109} 110 111ManifestService* GetManifestService() { 112 return g_manifest_service; 113} 114 115} // namespace ppapi 116