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

Side by Side Diff: chrome/nacl/nacl_listener.cc

Issue 8513018: NaCl: preallocate shared-memory object on Linux as on MacOSX (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: restore MakeSharedMemorySegmentViaIPC Created 9 years, 1 month 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 | « chrome/browser/nacl_host/nacl_process_host.cc ('k') | no next file » | 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) 2011 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2011 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 "chrome/nacl/nacl_listener.h" 5 #include "chrome/nacl/nacl_listener.h"
6 6
7 #include <errno.h> 7 #include <errno.h>
8 8
9 #include "base/command_line.h" 9 #include "base/command_line.h"
10 #include "base/logging.h" 10 #include "base/logging.h"
(...skipping 15 matching lines...) Expand all
26 26
27 // This is ugly. We need an interface header file for the exported 27 // This is ugly. We need an interface header file for the exported
28 // sel_ldr interfaces. 28 // sel_ldr interfaces.
29 // TODO(gregoryd,sehr): Add an interface header. 29 // TODO(gregoryd,sehr): Add an interface header.
30 #if defined(OS_WIN) 30 #if defined(OS_WIN)
31 typedef HANDLE NaClHandle; 31 typedef HANDLE NaClHandle;
32 #else 32 #else
33 typedef int NaClHandle; 33 typedef int NaClHandle;
34 #endif // NaClHandle 34 #endif // NaClHandle
35 35
36 #if defined(OS_MACOSX) 36 #if defined(OS_POSIX)
37 namespace { 37 namespace {
38 38
39 // On Mac OS X, shm_open() works in the sandbox but does not give us 39 // On Mac OS X, shm_open() works in the sandbox but does not give us an FD
40 // an FD that we can map as PROT_EXEC. Rather than doing an IPC to 40 // that we can map as PROT_EXEC. On Linux, shm_open() can only be used
41 // get an executable SHM region when CreateMemoryObject() is called, 41 // outside the sandbox anyway. Rather than doing an IPC to get an
42 // we preallocate one on startup, since NaCl's sel_ldr only needs one 42 // executable SHM region when CreateMemoryObject() is called, we
43 // of them. This saves a round trip. 43 // preallocate one on startup, since NaCl's sel_ldr only needs one of them.
44 // This saves a round trip.
45
46 bool SetShmFdSize(int fd, size_t size) {
47 #if defined(OS_MACOSX)
48 // ftruncate() is disallowed by the Mac OS X sandbox and returns EPERM.
49 // Luckily, we can get the same effect with lseek() + write().
50 if (lseek(fd, size - 1, SEEK_SET) == -1) {
51 LOG(ERROR) << "lseek() failed: " << errno;
52 close(fd);
53 return false;
54 }
55 if (write(fd, "", 1) != 1) {
56 LOG(ERROR) << "write() failed: " << errno;
57 close(fd);
58 return -1;
59 }
60 #else
61 if (ftruncate(fd, size) < 0) {
62 LOG(ERROR) << "ftruncate() failed: " << errno;
63 close(fd);
64 return false;
65 }
66 #endif // defined(OS_MACOSX)
67 return true;
68 }
44 69
45 base::subtle::Atomic32 g_shm_fd = -1; 70 base::subtle::Atomic32 g_shm_fd = -1;
46 71
47 int CreateMemoryObject(size_t size, bool executable) { 72 int CreateMemoryObject(size_t size, bool executable) {
48 if (executable && size > 0) { 73 if (executable && size > 0) {
49 int result_fd = base::subtle::NoBarrier_AtomicExchange(&g_shm_fd, -1); 74 int result_fd = base::subtle::NoBarrier_AtomicExchange(&g_shm_fd, -1);
50 if (result_fd != -1) { 75 if (result_fd != -1 && SetShmFdSize(result_fd, size))
51 // ftruncate() is disallowed by the Mac OS X sandbox and
52 // returns EPERM. Luckily, we can get the same effect with
53 // lseek() + write().
54 if (lseek(result_fd, size - 1, SEEK_SET) == -1) {
55 LOG(ERROR) << "lseek() failed: " << errno;
56 return -1;
57 }
58 if (write(result_fd, "", 1) != 1) {
59 LOG(ERROR) << "write() failed: " << errno;
60 return -1;
61 }
62 return result_fd; 76 return result_fd;
63 }
64 } 77 }
78 #if defined(OS_LINUX)
79 // Use the proxied implementation. It doesn't really support executability.
80 CHECK(!executable);
81 return content::MakeSharedMemorySegmentViaIPC(size, executable);
82 #endif
65 // Fall back to NaCl's default implementation. 83 // Fall back to NaCl's default implementation.
66 return -1; 84 return -1;
67 } 85 }
68 86
69 } // namespace 87 } // namespace
70 #endif // defined(OS_MACOSX) 88 #endif // defined(OS_POSIX)
71 89
72 extern "C" void NaClMainForChromium(int handle_count, 90 extern "C" void NaClMainForChromium(int handle_count,
73 const NaClHandle* handles, 91 const NaClHandle* handles,
74 int debug); 92 int debug);
75 extern "C" void NaClSetIrtFileDesc(int fd); 93 extern "C" void NaClSetIrtFileDesc(int fd);
76 94
77 NaClListener::NaClListener() : debug_enabled_(false) {} 95 NaClListener::NaClListener() : debug_enabled_(false) {}
78 96
79 NaClListener::~NaClListener() {} 97 NaClListener::~NaClListener() {}
80 98
81 void NaClListener::Listen() { 99 void NaClListener::Listen() {
82 std::string channel_name = 100 std::string channel_name =
83 CommandLine::ForCurrentProcess()->GetSwitchValueASCII( 101 CommandLine::ForCurrentProcess()->GetSwitchValueASCII(
84 switches::kProcessChannelID); 102 switches::kProcessChannelID);
85 IPC::Channel channel(channel_name, IPC::Channel::MODE_CLIENT, this); 103 IPC::Channel channel(channel_name, IPC::Channel::MODE_CLIENT, this);
86 CHECK(channel.Connect()); 104 CHECK(channel.Connect());
87 MessageLoop::current()->Run(); 105 MessageLoop::current()->Run();
88 } 106 }
89 107
90 bool NaClListener::OnMessageReceived(const IPC::Message& msg) { 108 bool NaClListener::OnMessageReceived(const IPC::Message& msg) {
91 bool handled = true; 109 bool handled = true;
92 IPC_BEGIN_MESSAGE_MAP(NaClListener, msg) 110 IPC_BEGIN_MESSAGE_MAP(NaClListener, msg)
93 IPC_MESSAGE_HANDLER(NaClProcessMsg_Start, OnStartSelLdr) 111 IPC_MESSAGE_HANDLER(NaClProcessMsg_Start, OnStartSelLdr)
94 IPC_MESSAGE_UNHANDLED(handled = false) 112 IPC_MESSAGE_UNHANDLED(handled = false)
95 IPC_END_MESSAGE_MAP() 113 IPC_END_MESSAGE_MAP()
96 return handled; 114 return handled;
97 } 115 }
98 116
99 void NaClListener::OnStartSelLdr(std::vector<nacl::FileDescriptor> handles) { 117 void NaClListener::OnStartSelLdr(std::vector<nacl::FileDescriptor> handles) {
100 #if defined(OS_LINUX) 118 #if defined(OS_POSIX)
101 nacl::SetCreateMemoryObjectFunc(content::MakeSharedMemorySegmentViaIPC);
102 #elif defined(OS_MACOSX)
103 nacl::SetCreateMemoryObjectFunc(CreateMemoryObject); 119 nacl::SetCreateMemoryObjectFunc(CreateMemoryObject);
104 CHECK(handles.size() >= 1); 120 CHECK(!handles.empty());
105 g_shm_fd = nacl::ToNativeHandle(handles[handles.size() - 1]); 121 g_shm_fd = nacl::ToNativeHandle(handles.back());
106 handles.pop_back(); 122 handles.pop_back();
107 #endif 123 #endif
108 124
109 CHECK(handles.size() >= 1); 125 CHECK(!handles.empty());
110 NaClHandle irt_handle = nacl::ToNativeHandle(handles[handles.size() - 1]); 126 NaClHandle irt_handle = nacl::ToNativeHandle(handles.back());
111 handles.pop_back(); 127 handles.pop_back();
112 128
113 #if defined(OS_WIN) 129 #if defined(OS_WIN)
114 int irt_desc = _open_osfhandle(reinterpret_cast<intptr_t>(irt_handle), 130 int irt_desc = _open_osfhandle(reinterpret_cast<intptr_t>(irt_handle),
115 _O_RDONLY | _O_BINARY); 131 _O_RDONLY | _O_BINARY);
116 if (irt_desc < 0) { 132 if (irt_desc < 0) {
117 LOG(ERROR) << "_open_osfhandle() failed"; 133 LOG(ERROR) << "_open_osfhandle() failed";
118 return; 134 return;
119 } 135 }
120 #else 136 #else
121 int irt_desc = irt_handle; 137 int irt_desc = irt_handle;
122 #endif 138 #endif
123 139
124 NaClSetIrtFileDesc(irt_desc); 140 NaClSetIrtFileDesc(irt_desc);
125 141
126 scoped_array<NaClHandle> array(new NaClHandle[handles.size()]); 142 scoped_array<NaClHandle> array(new NaClHandle[handles.size()]);
127 for (size_t i = 0; i < handles.size(); i++) { 143 for (size_t i = 0; i < handles.size(); i++) {
128 array[i] = nacl::ToNativeHandle(handles[i]); 144 array[i] = nacl::ToNativeHandle(handles[i]);
129 } 145 }
130 NaClMainForChromium(static_cast<int>(handles.size()), array.get(), 146 NaClMainForChromium(static_cast<int>(handles.size()), array.get(),
131 debug_enabled_); 147 debug_enabled_);
132 NOTREACHED(); 148 NOTREACHED();
133 } 149 }
OLDNEW
« no previous file with comments | « chrome/browser/nacl_host/nacl_process_host.cc ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698