OLD | NEW |
---|---|
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 "components/nacl/browser/nacl_process_host.h" | 5 #include "components/nacl/browser/nacl_process_host.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <string> | 8 #include <string> |
9 #include <vector> | 9 #include <vector> |
10 | 10 |
(...skipping 232 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
243 socket_for_sel_ldr(NACL_INVALID_HANDLE) { } | 243 socket_for_sel_ldr(NACL_INVALID_HANDLE) { } |
244 }; | 244 }; |
245 | 245 |
246 // ----------------------------------------------------------------------------- | 246 // ----------------------------------------------------------------------------- |
247 | 247 |
248 unsigned NaClProcessHost::keepalive_throttle_interval_milliseconds_ = | 248 unsigned NaClProcessHost::keepalive_throttle_interval_milliseconds_ = |
249 ppapi::kKeepaliveThrottleIntervalDefaultMilliseconds; | 249 ppapi::kKeepaliveThrottleIntervalDefaultMilliseconds; |
250 | 250 |
251 NaClProcessHost::NaClProcessHost(const GURL& manifest_url, | 251 NaClProcessHost::NaClProcessHost(const GURL& manifest_url, |
252 base::File nexe_file, | 252 base::File nexe_file, |
253 NaClFileToken nexe_token, | |
253 ppapi::PpapiPermissions permissions, | 254 ppapi::PpapiPermissions permissions, |
254 int render_view_id, | 255 int render_view_id, |
255 uint32 permission_bits, | 256 uint32 permission_bits, |
256 bool uses_irt, | 257 bool uses_irt, |
257 bool uses_nonsfi_mode, | 258 bool uses_nonsfi_mode, |
258 bool enable_dyncode_syscalls, | 259 bool enable_dyncode_syscalls, |
259 bool enable_exception_handling, | 260 bool enable_exception_handling, |
260 bool enable_crash_throttling, | 261 bool enable_crash_throttling, |
261 bool off_the_record, | 262 bool off_the_record, |
262 const base::FilePath& profile_directory) | 263 const base::FilePath& profile_directory) |
263 : manifest_url_(manifest_url), | 264 : manifest_url_(manifest_url), |
264 nexe_file_(nexe_file.Pass()), | 265 nexe_file_(nexe_file.Pass()), |
266 nexe_token_(nexe_token), | |
265 permissions_(permissions), | 267 permissions_(permissions), |
266 #if defined(OS_WIN) | 268 #if defined(OS_WIN) |
267 process_launched_by_broker_(false), | 269 process_launched_by_broker_(false), |
268 #endif | 270 #endif |
269 reply_msg_(NULL), | 271 reply_msg_(NULL), |
270 #if defined(OS_WIN) | 272 #if defined(OS_WIN) |
271 debug_exception_handler_requested_(false), | 273 debug_exception_handler_requested_(false), |
272 #endif | 274 #endif |
273 internal_(new NaClInternal()), | 275 internal_(new NaClInternal()), |
274 weak_factory_(this), | 276 weak_factory_(this), |
(...skipping 535 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
810 } | 812 } |
811 #endif | 813 #endif |
812 | 814 |
813 bool NaClProcessHost::StartNaClExecution() { | 815 bool NaClProcessHost::StartNaClExecution() { |
814 NaClBrowser* nacl_browser = NaClBrowser::GetInstance(); | 816 NaClBrowser* nacl_browser = NaClBrowser::GetInstance(); |
815 | 817 |
816 NaClStartParams params; | 818 NaClStartParams params; |
817 | 819 |
818 // Enable PPAPI proxy channel creation only for renderer processes. | 820 // Enable PPAPI proxy channel creation only for renderer processes. |
819 params.enable_ipc_proxy = enable_ppapi_proxy(); | 821 params.enable_ipc_proxy = enable_ppapi_proxy(); |
822 // nexe_file_ still keeps the ownership at this moment, because |params| | |
823 // may just be destroyed before sending IPC is properly processed. | |
824 // Note that although we set auto_close=true for FileDescriptor's | |
825 // constructor, it is not automatically handled in its destructor as RAII. | |
826 #if defined(OS_POSIX) | |
827 params.nexe_file = | |
828 base::FileDescriptor(nexe_file_.TakePlatformFile(), false); | |
Mark Seaborn
2014/07/08 18:46:00
This leaks the FD. You should either do:
// take
teravest
2014/07/08 19:03:45
Yes, you're right. I wanted GetPlatformFile() here
| |
829 #elif defined(OS_WIN) | |
830 params.nexe_file = IPC::GetFileHandleForProcess(nexe_file_.TakePlatformFile(), | |
Mark Seaborn
2014/07/08 18:46:00
This has a similar leak.
teravest
2014/07/08 19:03:45
Done.
| |
831 process_->GetData().handle, | |
832 false); | |
833 #else | |
834 #error Unsupported target platform. | |
835 #endif | |
836 | |
820 if (uses_nonsfi_mode_) { | 837 if (uses_nonsfi_mode_) { |
821 // Currently, non-SFI mode is supported only on Linux. | 838 // Currently, non-SFI mode is supported only on Linux. |
822 #if defined(OS_LINUX) | 839 #if defined(OS_LINUX) |
823 // nexe_file_ still keeps the ownership at this moment, because |params| | |
824 // may just be destroyed before sending IPC is properly processed. | |
825 // Note that although we set auto_close=true for FileDescriptor's | |
826 // constructor, it is not automatically handled in its destructor as RAII. | |
827 params.nexe_file = | |
828 base::FileDescriptor(nexe_file_.GetPlatformFile(), true); | |
829 // In non-SFI mode, we do not use SRPC. Make sure that the socketpair is | 840 // In non-SFI mode, we do not use SRPC. Make sure that the socketpair is |
830 // not created. | 841 // not created. |
831 DCHECK_EQ(internal_->socket_for_sel_ldr, NACL_INVALID_HANDLE); | 842 DCHECK_EQ(internal_->socket_for_sel_ldr, NACL_INVALID_HANDLE); |
832 #endif | 843 #endif |
833 } else { | 844 } else { |
834 params.validation_cache_enabled = nacl_browser->ValidationCacheIsEnabled(); | 845 params.validation_cache_enabled = nacl_browser->ValidationCacheIsEnabled(); |
835 params.validation_cache_key = nacl_browser->GetValidationCacheKey(); | 846 params.validation_cache_key = nacl_browser->GetValidationCacheKey(); |
836 params.version = NaClBrowser::GetDelegate()->GetVersionString(); | 847 params.version = NaClBrowser::GetDelegate()->GetVersionString(); |
837 params.enable_exception_handling = enable_exception_handling_; | 848 params.enable_exception_handling = enable_exception_handling_; |
838 params.enable_debug_stub = enable_debug_stub_ && | 849 params.enable_debug_stub = enable_debug_stub_ && |
839 NaClBrowser::GetDelegate()->URLMatchesDebugPatterns(manifest_url_); | 850 NaClBrowser::GetDelegate()->URLMatchesDebugPatterns(manifest_url_); |
840 params.uses_irt = uses_irt_; | 851 params.uses_irt = uses_irt_; |
841 params.enable_dyncode_syscalls = enable_dyncode_syscalls_; | 852 params.enable_dyncode_syscalls = enable_dyncode_syscalls_; |
842 | 853 |
854 // TODO(teravest): Resolve the file tokens right now instead of making the | |
855 // loader send IPC to resolve them later. | |
856 params.nexe_token_lo = nexe_token_.lo; | |
857 params.nexe_token_hi = nexe_token_.hi; | |
858 | |
843 const ChildProcessData& data = process_->GetData(); | 859 const ChildProcessData& data = process_->GetData(); |
844 if (!ShareHandleToSelLdr(data.handle, | 860 if (!ShareHandleToSelLdr(data.handle, |
845 internal_->socket_for_sel_ldr, true, | 861 internal_->socket_for_sel_ldr, true, |
846 ¶ms.handles)) { | 862 ¶ms.handles)) { |
847 return false; | 863 return false; |
848 } | 864 } |
849 | 865 |
850 if (params.uses_irt) { | 866 if (params.uses_irt) { |
851 const base::File& irt_file = nacl_browser->IrtFile(); | 867 const base::File& irt_file = nacl_browser->IrtFile(); |
852 CHECK(irt_file.IsValid()); | 868 CHECK(irt_file.IsValid()); |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
884 if (params.enable_debug_stub) { | 900 if (params.enable_debug_stub) { |
885 net::SocketDescriptor server_bound_socket = GetDebugStubSocketHandle(); | 901 net::SocketDescriptor server_bound_socket = GetDebugStubSocketHandle(); |
886 if (server_bound_socket != net::kInvalidSocket) { | 902 if (server_bound_socket != net::kInvalidSocket) { |
887 params.debug_stub_server_bound_socket = | 903 params.debug_stub_server_bound_socket = |
888 FileDescriptor(server_bound_socket, true); | 904 FileDescriptor(server_bound_socket, true); |
889 } | 905 } |
890 } | 906 } |
891 #endif | 907 #endif |
892 } | 908 } |
893 | 909 |
894 // Here we are about to send the IPC, so release file descriptors to delegate | 910 // Here we are about to send the IPC, so close the file descriptor in |
895 // the ownership to the message. | 911 // nexe_file_. |
896 if (uses_nonsfi_mode_) { | 912 nexe_file_.Close(); |
Mark Seaborn
2014/07/08 18:46:00
This has no effect, because the code did TakePlatf
teravest
2014/07/08 19:03:45
Done.
| |
897 nexe_file_.TakePlatformFile(); | 913 if (!uses_nonsfi_mode_) { |
898 } else { | |
899 internal_->socket_for_sel_ldr = NACL_INVALID_HANDLE; | 914 internal_->socket_for_sel_ldr = NACL_INVALID_HANDLE; |
900 } | 915 } |
901 | 916 |
902 process_->Send(new NaClProcessMsg_Start(params)); | 917 process_->Send(new NaClProcessMsg_Start(params)); |
903 return true; | 918 return true; |
904 } | 919 } |
905 | 920 |
906 // This method is called when NaClProcessHostMsg_PpapiChannelCreated is | 921 // This method is called when NaClProcessHostMsg_PpapiChannelCreated is |
907 // received. | 922 // received. |
908 void NaClProcessHost::OnPpapiChannelsCreated( | 923 void NaClProcessHost::OnPpapiChannelsCreated( |
(...skipping 237 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
1146 process_handle.Take(), info, | 1161 process_handle.Take(), info, |
1147 base::MessageLoopProxy::current(), | 1162 base::MessageLoopProxy::current(), |
1148 base::Bind(&NaClProcessHost::OnDebugExceptionHandlerLaunchedByBroker, | 1163 base::Bind(&NaClProcessHost::OnDebugExceptionHandlerLaunchedByBroker, |
1149 weak_factory_.GetWeakPtr())); | 1164 weak_factory_.GetWeakPtr())); |
1150 return true; | 1165 return true; |
1151 } | 1166 } |
1152 } | 1167 } |
1153 #endif | 1168 #endif |
1154 | 1169 |
1155 } // namespace nacl | 1170 } // namespace nacl |
OLD | NEW |