Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(101)

Side by Side Diff: ppapi/proxy/plugin_main_nacl.cc

Issue 128433005: Revert of Test Keeping NaCl plugins used in app background pages alive when active. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « extensions/browser/process_manager.cc ('k') | ppapi/shared_impl/ppapi_switches.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 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 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 <map> 5 #include <map>
6 #include <set> 6 #include <set>
7 7
8 #include "build/build_config.h" 8 #include "build/build_config.h"
9 // Need to include this before most other files because it defines 9 // Need to include this before most other files because it defines
10 // IPC_MESSAGE_LOG_ENABLED. We need to use it to define 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 11 // IPC_MESSAGE_MACROS_LOG_ENABLED so ppapi_messages.h will generate the
12 // ViewMsgLog et al. functions. 12 // ViewMsgLog et al. functions.
13 13
14 #include "base/command_line.h" 14 #include "base/command_line.h"
15 #include "base/message_loop/message_loop.h" 15 #include "base/message_loop/message_loop.h"
16 #include "base/strings/string_number_conversions.h"
17 #include "base/synchronization/waitable_event.h" 16 #include "base/synchronization/waitable_event.h"
18 #include "base/threading/thread.h" 17 #include "base/threading/thread.h"
19 #include "components/tracing/child_trace_message_filter.h" 18 #include "components/tracing/child_trace_message_filter.h"
20 #include "ipc/ipc_channel_handle.h" 19 #include "ipc/ipc_channel_handle.h"
21 #include "ipc/ipc_logging.h" 20 #include "ipc/ipc_logging.h"
22 #include "ipc/ipc_message.h" 21 #include "ipc/ipc_message.h"
23 #include "native_client/src/shared/srpc/nacl_srpc.h" 22 #include "native_client/src/shared/srpc/nacl_srpc.h"
24 #include "native_client/src/untrusted/irt/irt_ppapi.h" 23 #include "native_client/src/untrusted/irt/irt_ppapi.h"
25 #include "ppapi/c/ppp.h" 24 #include "ppapi/c/ppp.h"
26 #include "ppapi/c/ppp_instance.h" 25 #include "ppapi/c/ppp_instance.h"
27 #include "ppapi/native_client/src/shared/ppapi_proxy/ppruntime.h" 26 #include "ppapi/native_client/src/shared/ppapi_proxy/ppruntime.h"
28 #include "ppapi/proxy/plugin_dispatcher.h" 27 #include "ppapi/proxy/plugin_dispatcher.h"
29 #include "ppapi/proxy/plugin_globals.h" 28 #include "ppapi/proxy/plugin_globals.h"
30 #include "ppapi/proxy/plugin_message_filter.h" 29 #include "ppapi/proxy/plugin_message_filter.h"
31 #include "ppapi/proxy/plugin_proxy_delegate.h" 30 #include "ppapi/proxy/plugin_proxy_delegate.h"
32 #include "ppapi/proxy/resource_reply_thread_registrar.h" 31 #include "ppapi/proxy/resource_reply_thread_registrar.h"
33 #include "ppapi/shared_impl/ppapi_switches.h"
34 #include "ppapi/shared_impl/ppb_audio_shared.h" 32 #include "ppapi/shared_impl/ppb_audio_shared.h"
35 33
36 #if defined(IPC_MESSAGE_LOG_ENABLED) 34 #if defined(IPC_MESSAGE_LOG_ENABLED)
37 #include "base/containers/hash_tables.h" 35 #include "base/containers/hash_tables.h"
38 36
39 LogFunctionMap g_log_function_mapping; 37 LogFunctionMap g_log_function_mapping;
40 38
41 #define IPC_MESSAGE_MACROS_LOG_ENABLED 39 #define IPC_MESSAGE_MACROS_LOG_ENABLED
42 #define IPC_LOG_TABLE_ADD_ENTRY(msg_id, logger) \ 40 #define IPC_LOG_TABLE_ADD_ENTRY(msg_id, logger) \
43 g_log_function_mapping[msg_id] = logger 41 g_log_function_mapping[msg_id] = logger
(...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after
90 88
91 // IPC::Listener implementation. 89 // IPC::Listener implementation.
92 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE; 90 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE;
93 91
94 private: 92 private:
95 void OnMsgCreateNaClChannel(int renderer_id, 93 void OnMsgCreateNaClChannel(int renderer_id,
96 const ppapi::PpapiNaClChannelArgs& args, 94 const ppapi::PpapiNaClChannelArgs& args,
97 SerializedHandle handle); 95 SerializedHandle handle);
98 void OnPluginDispatcherMessageReceived(const IPC::Message& msg); 96 void OnPluginDispatcherMessageReceived(const IPC::Message& msg);
99 97
100 void SetPpapiKeepAliveThrottleFromCommandLine();
101
102 std::set<PP_Instance> instances_; 98 std::set<PP_Instance> instances_;
103 std::map<uint32, PluginDispatcher*> plugin_dispatchers_; 99 std::map<uint32, PluginDispatcher*> plugin_dispatchers_;
104 uint32 next_plugin_dispatcher_id_; 100 uint32 next_plugin_dispatcher_id_;
105 scoped_refptr<base::MessageLoopProxy> message_loop_; 101 scoped_refptr<base::MessageLoopProxy> message_loop_;
106 base::WaitableEvent shutdown_event_; 102 base::WaitableEvent shutdown_event_;
107 }; 103 };
108 104
109 PpapiDispatcher::PpapiDispatcher(scoped_refptr<base::MessageLoopProxy> io_loop) 105 PpapiDispatcher::PpapiDispatcher(scoped_refptr<base::MessageLoopProxy> io_loop)
110 : next_plugin_dispatcher_id_(0), 106 : next_plugin_dispatcher_id_(0),
111 message_loop_(io_loop), 107 message_loop_(io_loop),
(...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after
205 if (!command_line_and_logging_initialized) { 201 if (!command_line_and_logging_initialized) {
206 CommandLine::Init(0, NULL); 202 CommandLine::Init(0, NULL);
207 for (size_t i = 0; i < args.switch_names.size(); ++i) { 203 for (size_t i = 0; i < args.switch_names.size(); ++i) {
208 DCHECK(i < args.switch_values.size()); 204 DCHECK(i < args.switch_values.size());
209 CommandLine::ForCurrentProcess()->AppendSwitchASCII( 205 CommandLine::ForCurrentProcess()->AppendSwitchASCII(
210 args.switch_names[i], args.switch_values[i]); 206 args.switch_names[i], args.switch_values[i]);
211 } 207 }
212 logging::LoggingSettings settings; 208 logging::LoggingSettings settings;
213 settings.logging_dest = logging::LOG_TO_SYSTEM_DEBUG_LOG; 209 settings.logging_dest = logging::LOG_TO_SYSTEM_DEBUG_LOG;
214 logging::InitLogging(settings); 210 logging::InitLogging(settings);
215 SetPpapiKeepAliveThrottleFromCommandLine();
216 command_line_and_logging_initialized = true; 211 command_line_and_logging_initialized = true;
217 } 212 }
218 // Tell the process-global GetInterface which interfaces it can return to the 213 // Tell the process-global GetInterface which interfaces it can return to the
219 // plugin. 214 // plugin.
220 ppapi::proxy::InterfaceList::SetProcessGlobalPermissions( 215 ppapi::proxy::InterfaceList::SetProcessGlobalPermissions(
221 args.permissions); 216 args.permissions);
222 217
223 int32_t error = ::PPP_InitializeModule( 218 int32_t error = ::PPP_InitializeModule(
224 0 /* module */, 219 0 /* module */,
225 &ppapi::proxy::PluginDispatcher::GetBrowserInterface); 220 &ppapi::proxy::PluginDispatcher::GetBrowserInterface);
(...skipping 22 matching lines...) Expand all
248 if (!msg.ReadUInt32(&iter, &id)) { 243 if (!msg.ReadUInt32(&iter, &id)) {
249 NOTREACHED(); 244 NOTREACHED();
250 return; 245 return;
251 } 246 }
252 std::map<uint32, ppapi::proxy::PluginDispatcher*>::iterator dispatcher = 247 std::map<uint32, ppapi::proxy::PluginDispatcher*>::iterator dispatcher =
253 plugin_dispatchers_.find(id); 248 plugin_dispatchers_.find(id);
254 if (dispatcher != plugin_dispatchers_.end()) 249 if (dispatcher != plugin_dispatchers_.end())
255 dispatcher->second->OnMessageReceived(msg); 250 dispatcher->second->OnMessageReceived(msg);
256 } 251 }
257 252
258 void PpapiDispatcher::SetPpapiKeepAliveThrottleFromCommandLine() {
259 unsigned keepalive_throttle_interval_milliseconds = 0;
260 if (base::StringToUint(
261 CommandLine::ForCurrentProcess()->GetSwitchValueASCII(
262 switches::kPpapiKeepAliveThrottle),
263 &keepalive_throttle_interval_milliseconds)) {
264 ppapi::proxy::PluginGlobals::Get()->
265 set_keepalive_throttle_interval_milliseconds(
266 keepalive_throttle_interval_milliseconds);
267 }
268 }
269
270 } // namespace 253 } // namespace
271 254
272 void PpapiPluginRegisterThreadCreator( 255 void PpapiPluginRegisterThreadCreator(
273 const struct PP_ThreadFunctions* thread_functions) { 256 const struct PP_ThreadFunctions* thread_functions) {
274 // Initialize all classes that need to create threads that call back into 257 // Initialize all classes that need to create threads that call back into
275 // user code. 258 // user code.
276 ppapi::PPB_Audio_Shared::SetThreadFunctions(thread_functions); 259 ppapi::PPB_Audio_Shared::SetThreadFunctions(thread_functions);
277 } 260 }
278 261
279 int PpapiPluginMain() { 262 int PpapiPluginMain() {
(...skipping 16 matching lines...) Expand all
296 return 1; 279 return 1;
297 } 280 }
298 281
299 PpapiDispatcher ppapi_dispatcher(io_thread.message_loop_proxy()); 282 PpapiDispatcher ppapi_dispatcher(io_thread.message_loop_proxy());
300 plugin_globals.set_plugin_proxy_delegate(&ppapi_dispatcher); 283 plugin_globals.set_plugin_proxy_delegate(&ppapi_dispatcher);
301 284
302 loop.Run(); 285 loop.Run();
303 286
304 return 0; 287 return 0;
305 } 288 }
OLDNEW
« no previous file with comments | « extensions/browser/process_manager.cc ('k') | ppapi/shared_impl/ppapi_switches.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698