Chromium Code Reviews| 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/zygote/nacl_fork_delegate_linux.h" | 5 #include "components/nacl/zygote/nacl_fork_delegate_linux.h" |
| 6 | 6 |
| 7 #include <signal.h> | 7 #include <signal.h> |
| 8 #include <stdlib.h> | 8 #include <stdlib.h> |
| 9 #include <sys/resource.h> | 9 #include <sys/resource.h> |
| 10 #include <sys/socket.h> | 10 #include <sys/socket.h> |
| (...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 101 if (msg_len <= 0) { | 101 if (msg_len <= 0) { |
| 102 LOG(ERROR) << "SendIPCRequestAndReadReply: RecvMsg failed"; | 102 LOG(ERROR) << "SendIPCRequestAndReadReply: RecvMsg failed"; |
| 103 return false; | 103 return false; |
| 104 } | 104 } |
| 105 *reply_size = msg_len; | 105 *reply_size = msg_len; |
| 106 return true; | 106 return true; |
| 107 } | 107 } |
| 108 | 108 |
| 109 } // namespace. | 109 } // namespace. |
| 110 | 110 |
| 111 NaClForkDelegate::NaClForkDelegate() | 111 NaClForkDelegate::NaClForkDelegate(bool nonsfi_mode) |
| 112 : status_(kNaClHelperUnused), | 112 : nonsfi_mode_(nonsfi_mode), status_(kNaClHelperUnused), fd_(-1) { |
| 113 fd_(-1) {} | 113 } |
| 114 | 114 |
| 115 void NaClForkDelegate::Init(const int sandboxdesc, | 115 void NaClForkDelegate::Init(const int sandboxdesc, |
| 116 const bool enable_layer1_sandbox) { | 116 const bool enable_layer1_sandbox) { |
| 117 VLOG(1) << "NaClForkDelegate::Init()"; | 117 VLOG(1) << "NaClForkDelegate::Init()"; |
| 118 int fds[2]; | 118 int fds[2]; |
| 119 | 119 |
| 120 scoped_ptr<sandbox::SetuidSandboxClient> setuid_sandbox_client( | 120 scoped_ptr<sandbox::SetuidSandboxClient> setuid_sandbox_client( |
| 121 sandbox::SetuidSandboxClient::Create()); | 121 sandbox::SetuidSandboxClient::Create()); |
| 122 | 122 |
| 123 // For communications between the NaCl loader process and | 123 // For communications between the NaCl loader process and |
| (...skipping 131 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 255 // TODO(bradchen): Make this LOG(ERROR) when the NaCl helper | 255 // TODO(bradchen): Make this LOG(ERROR) when the NaCl helper |
| 256 // becomes the default. | 256 // becomes the default. |
| 257 fd_ = -1; | 257 fd_ = -1; |
| 258 if (IGNORE_EINTR(close(fds[0])) != 0) | 258 if (IGNORE_EINTR(close(fds[0])) != 0) |
| 259 LOG(ERROR) << "close(fds[0]) failed"; | 259 LOG(ERROR) << "close(fds[0]) failed"; |
| 260 } | 260 } |
| 261 | 261 |
| 262 void NaClForkDelegate::InitialUMA(std::string* uma_name, | 262 void NaClForkDelegate::InitialUMA(std::string* uma_name, |
| 263 int* uma_sample, | 263 int* uma_sample, |
| 264 int* uma_boundary_value) { | 264 int* uma_boundary_value) { |
| 265 *uma_name = "NaCl.Client.Helper.InitState"; | 265 *uma_name = nonsfi_mode_ ? "NaCl.Client.HelperNonSFI.InitState" |
| 266 : "NaCl.Client.Helper.InitState"; | |
| 266 *uma_sample = status_; | 267 *uma_sample = status_; |
| 267 *uma_boundary_value = kNaClHelperStatusBoundary; | 268 *uma_boundary_value = kNaClHelperStatusBoundary; |
| 268 } | 269 } |
| 269 | 270 |
| 270 NaClForkDelegate::~NaClForkDelegate() { | 271 NaClForkDelegate::~NaClForkDelegate() { |
| 271 // side effect of close: delegate process will terminate | 272 // side effect of close: delegate process will terminate |
| 272 if (status_ == kNaClHelperSuccess) { | 273 if (status_ == kNaClHelperSuccess) { |
| 273 if (IGNORE_EINTR(close(fd_)) != 0) | 274 if (IGNORE_EINTR(close(fd_)) != 0) |
| 274 LOG(ERROR) << "close(fd_) failed"; | 275 LOG(ERROR) << "close(fd_) failed"; |
| 275 } | 276 } |
| 276 } | 277 } |
| 277 | 278 |
| 278 bool NaClForkDelegate::CanHelp(const std::string& process_type, | 279 bool NaClForkDelegate::CanHelp(const std::string& process_type, |
| 279 std::string* uma_name, | 280 std::string* uma_name, |
| 280 int* uma_sample, | 281 int* uma_sample, |
| 281 int* uma_boundary_value) { | 282 int* uma_boundary_value) { |
| 282 if (process_type != switches::kNaClLoaderProcess && | 283 if (process_type != (nonsfi_mode_ ? switches::kNaClLoaderNonSfiProcess |
|
jln (very slow on Chromium)
2014/05/09 20:51:20
This is hard to read.
Maybe have an intermediate
mdempsky
2014/05/09 21:34:11
Done. (I named it helpable_process_type.)
| |
| 283 process_type != switches::kNaClLoaderNonSfiProcess) | 284 : switches::kNaClLoaderProcess)) |
| 284 return false; | 285 return false; |
| 285 *uma_name = "NaCl.Client.Helper.StateOnFork"; | 286 *uma_name = nonsfi_mode_ ? "NaCl.Client.HelperNonSFI.StateOnFork" |
| 287 : "NaCl.Client.Helper.StateOnFork"; | |
| 286 *uma_sample = status_; | 288 *uma_sample = status_; |
| 287 *uma_boundary_value = kNaClHelperStatusBoundary; | 289 *uma_boundary_value = kNaClHelperStatusBoundary; |
| 288 return true; | 290 return true; |
| 289 } | 291 } |
| 290 | 292 |
| 291 pid_t NaClForkDelegate::Fork(const std::string& process_type, | 293 pid_t NaClForkDelegate::Fork(const std::string& process_type, |
| 292 const std::vector<int>& fds, | 294 const std::vector<int>& fds, |
| 293 const std::string& channel_id) { | 295 const std::string& channel_id) { |
| 294 VLOG(1) << "NaClForkDelegate::Fork"; | 296 VLOG(1) << "NaClForkDelegate::Fork"; |
| 295 | 297 |
| 296 DCHECK(fds.size() == kNumPassedFDs); | 298 DCHECK(fds.size() == kNumPassedFDs); |
| 297 | 299 |
| 298 if (status_ != kNaClHelperSuccess) { | 300 if (status_ != kNaClHelperSuccess) { |
| 299 LOG(ERROR) << "Cannot launch NaCl process: nacl_helper failed to start"; | 301 LOG(ERROR) << "Cannot launch NaCl process: nacl_helper failed to start"; |
| 300 return -1; | 302 return -1; |
| 301 } | 303 } |
| 302 | 304 |
| 303 // First, send a remote fork request. | 305 // First, send a remote fork request. |
| 304 Pickle write_pickle; | 306 Pickle write_pickle; |
| 305 write_pickle.WriteInt(nacl::kNaClForkRequest); | 307 write_pickle.WriteInt(nacl::kNaClForkRequest); |
| 306 // TODO(hamaji): When we split the helper binary for non-SFI mode | 308 write_pickle.WriteBool(nonsfi_mode_); |
| 307 // from nacl_helper, stop sending this information. | |
| 308 const bool uses_nonsfi_mode = | |
| 309 process_type == switches::kNaClLoaderNonSfiProcess; | |
| 310 write_pickle.WriteBool(uses_nonsfi_mode); | |
| 311 write_pickle.WriteString(channel_id); | 309 write_pickle.WriteString(channel_id); |
| 312 | 310 |
| 313 char reply_buf[kNaClMaxIPCMessageLength]; | 311 char reply_buf[kNaClMaxIPCMessageLength]; |
| 314 ssize_t reply_size = 0; | 312 ssize_t reply_size = 0; |
| 315 bool got_reply = | 313 bool got_reply = |
| 316 SendIPCRequestAndReadReply(fd_, fds, write_pickle, | 314 SendIPCRequestAndReadReply(fd_, fds, write_pickle, |
| 317 reply_buf, sizeof(reply_buf), &reply_size); | 315 reply_buf, sizeof(reply_buf), &reply_size); |
| 318 if (!got_reply) { | 316 if (!got_reply) { |
| 319 LOG(ERROR) << "Could not perform remote fork."; | 317 LOG(ERROR) << "Could not perform remote fork."; |
| 320 return -1; | 318 return -1; |
| (...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 368 int remote_exit_code; | 366 int remote_exit_code; |
| 369 if (!iter.ReadInt(&remote_exit_code)) { | 367 if (!iter.ReadInt(&remote_exit_code)) { |
| 370 LOG(ERROR) << "GetTerminationStatus: pickle failed"; | 368 LOG(ERROR) << "GetTerminationStatus: pickle failed"; |
| 371 return false; | 369 return false; |
| 372 } | 370 } |
| 373 | 371 |
| 374 *status = static_cast<base::TerminationStatus>(termination_status); | 372 *status = static_cast<base::TerminationStatus>(termination_status); |
| 375 *exit_code = remote_exit_code; | 373 *exit_code = remote_exit_code; |
| 376 return true; | 374 return true; |
| 377 } | 375 } |
| OLD | NEW |