OLD | NEW |
| (Empty) |
1 // Copyright (c) 2012 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 <map> | |
6 #include <set> | |
7 | |
8 #include "build/build_config.h" | |
9 // Need to include this before most other files because it defines | |
10 // IPC_MESSAGE_LOG_ENABLED. We need to use it to define | |
11 // IPC_MESSAGE_MACROS_LOG_ENABLED so ppapi_messages.h will generate the | |
12 // ViewMsgLog et al. functions. | |
13 | |
14 #include "base/message_loop.h" | |
15 #include "base/synchronization/waitable_event.h" | |
16 #include "base/threading/thread.h" | |
17 #include "ipc/ipc_channel_handle.h" | |
18 #include "ipc/ipc_logging.h" | |
19 #include "ipc/ipc_message.h" | |
20 #include "native_client/src/shared/ppapi_proxy/ppruntime.h" | |
21 #include "native_client/src/untrusted/irt/irt_ppapi.h" | |
22 #include "ppapi/c/ppp.h" | |
23 #include "ppapi/c/ppp_instance.h" | |
24 #include "ppapi/proxy/plugin_dispatcher.h" | |
25 #include "ppapi/proxy/plugin_globals.h" | |
26 | |
27 #if defined(IPC_MESSAGE_LOG_ENABLED) | |
28 #define IPC_MESSAGE_MACROS_LOG_ENABLED | |
29 #include "ppapi/proxy/ppapi_messages.h" | |
30 #endif | |
31 | |
32 // This must match up with NACL_CHROME_INITIAL_IPC_DESC, | |
33 // defined in sel_main_chrome.h | |
34 #define NACL_IPC_FD 6 | |
35 | |
36 using ppapi::proxy::PluginDispatcher; | |
37 using ppapi::proxy::PluginGlobals; | |
38 | |
39 namespace { | |
40 | |
41 struct PP_ThreadFunctions thread_funcs; | |
42 | |
43 // Copied from src/content/ppapi_plugin/ppapi_thread. This is a minimal | |
44 // implementation to get us started. | |
45 class PluginDispatcherDelegate : public PluginDispatcher::PluginDelegate { | |
46 public: | |
47 explicit PluginDispatcherDelegate( | |
48 scoped_refptr<base::MessageLoopProxy> io_loop) | |
49 : message_loop_(io_loop), | |
50 shutdown_event_(true, false) { | |
51 } | |
52 | |
53 virtual base::MessageLoopProxy* GetIPCMessageLoop() OVERRIDE { | |
54 return message_loop_.get(); | |
55 } | |
56 | |
57 virtual base::WaitableEvent* GetShutdownEvent() OVERRIDE { | |
58 return &shutdown_event_; | |
59 } | |
60 | |
61 virtual IPC::PlatformFileForTransit ShareHandleWithRemote( | |
62 base::PlatformFile handle, | |
63 const IPC::SyncChannel& channel, | |
64 bool should_close_source) OVERRIDE { | |
65 return IPC::InvalidPlatformFileForTransit(); | |
66 } | |
67 | |
68 virtual std::set<PP_Instance>* GetGloballySeenInstanceIDSet() OVERRIDE { | |
69 return &instances_; | |
70 } | |
71 | |
72 virtual uint32 Register(PluginDispatcher* plugin_dispatcher) OVERRIDE { | |
73 if (!plugin_dispatcher || | |
74 plugin_dispatchers_.size() >= std::numeric_limits<uint32>::max()) { | |
75 return 0; | |
76 } | |
77 | |
78 uint32 id = 0; | |
79 do { | |
80 // Although it is unlikely, make sure that we won't cause any trouble when | |
81 // the counter overflows. | |
82 id = next_plugin_dispatcher_id_++; | |
83 } while (id == 0 || | |
84 plugin_dispatchers_.find(id) != plugin_dispatchers_.end()); | |
85 plugin_dispatchers_[id] = plugin_dispatcher; | |
86 return id; | |
87 } | |
88 | |
89 virtual void Unregister(uint32 plugin_dispatcher_id) OVERRIDE { | |
90 plugin_dispatchers_.erase(plugin_dispatcher_id); | |
91 } | |
92 | |
93 private: | |
94 std::set<PP_Instance> instances_; | |
95 std::map<uint32, PluginDispatcher*> plugin_dispatchers_; | |
96 uint32 next_plugin_dispatcher_id_; | |
97 scoped_refptr<base::MessageLoopProxy> message_loop_; | |
98 base::WaitableEvent shutdown_event_; | |
99 }; | |
100 | |
101 } // namespace | |
102 | |
103 void PpapiPluginRegisterThreadCreator( | |
104 const struct PP_ThreadFunctions* new_funcs) { | |
105 thread_funcs = *new_funcs; | |
106 } | |
107 | |
108 int IrtInit() { | |
109 return 0; | |
110 } | |
111 | |
112 int PpapiPluginMain() { | |
113 base::AtExitManager exit_manager; | |
114 MessageLoop loop; | |
115 IPC::Logging::set_log_function_map(&g_log_function_mapping); | |
116 ppapi::proxy::PluginGlobals plugin_globals; | |
117 base::Thread io_thread("Chrome_NaClIOThread"); | |
118 base::Thread::Options options; | |
119 options.message_loop_type = MessageLoop::TYPE_IO; | |
120 io_thread.StartWithOptions(options); | |
121 | |
122 int32_t error = ::PPP_InitializeModule( | |
123 0 /* module */, | |
124 &ppapi::proxy::PluginDispatcher::GetBrowserInterface); | |
125 // TODO(dmichael): Handle other error conditions, like failure to connect? | |
126 if (error) | |
127 return error; | |
128 | |
129 PluginDispatcherDelegate delegate(io_thread.message_loop_proxy()); | |
130 | |
131 // TODO(dmichael) Figure out how to determine if we're in incognito | |
132 PluginDispatcher dispatcher(::PPP_GetInterface, false /* incognito */); | |
133 IPC::ChannelHandle channel_handle("NaCl IPC", | |
134 base::FileDescriptor(NACL_IPC_FD, false)); | |
135 dispatcher.InitPluginWithChannel(&delegate, channel_handle, false); | |
136 | |
137 loop.Run(); | |
138 return 0; | |
139 } | |
140 | |
OLD | NEW |