clang-format runtime/bin

runtime/bin/process_macos.cc

 // Copyright (c) 2012, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 #if !defined(DART_IO_DISABLED)
 
 #include "platform/globals.h"
 #if defined(TARGET_OS_MACOS)
 
 #include "bin/process.h"
 
 #if !TARGET_OS_IOS
 #include <crt_externs.h>  // NOLINT
 #endif
-#include <errno.h>  // NOLINT
-#include <fcntl.h>  // NOLINT
-#include <poll.h>  // NOLINT
+#include <errno.h>   // NOLINT
+#include <fcntl.h>   // NOLINT
+#include <poll.h>    // NOLINT
 #include <signal.h>  // NOLINT
-#include <stdio.h>  // NOLINT
+#include <stdio.h>   // NOLINT
 #include <stdlib.h>  // NOLINT
 #include <string.h>  // NOLINT
 #include <unistd.h>  // NOLINT
 
 #include "bin/dartutils.h"
 #include "bin/fdutils.h"
 #include "bin/lockers.h"
 #include "bin/log.h"
 #include "bin/thread.h"
 
 #include "platform/signal_blocker.h"
 #include "platform/utils.h"
 
 namespace dart {
 namespace bin {
 
 int Process::global_exit_code_ = 0;
 Mutex* Process::global_exit_code_mutex_ = new Mutex();
 Process::ExitHook Process::exit_hook_ = NULL;
 
 // ProcessInfo is used to map a process id to the file descriptor for
 // the pipe used to communicate the exit code of the process to Dart.
 // ProcessInfo objects are kept in the static singly-linked
 // ProcessInfoList.
 class ProcessInfo {
  public:
-  ProcessInfo(pid_t pid, intptr_t fd) : pid_(pid), fd_(fd) { }
+  ProcessInfo(pid_t pid, intptr_t fd) : pid_(pid), fd_(fd) {}
   ~ProcessInfo() {
     int closed = TEMP_FAILURE_RETRY(close(fd_));
     if (closed != 0) {
       FATAL("Failed to close process exit code pipe");
     }
   }
   pid_t pid() { return pid_; }
   intptr_t fd() { return fd_; }
   ProcessInfo* next() { return next_; }
   void set_next(ProcessInfo* info) { next_ = info; }
@@ skipping 143 matching lines @@
         int negative = 0;
         if (WIFEXITED(status)) {
           exit_code = WEXITSTATUS(status);
         }
         if (WIFSIGNALED(status)) {
           exit_code = WTERMSIG(status);
           negative = 1;
         }
         intptr_t exit_code_fd = ProcessInfoList::LookupProcessExitFd(pid);
         if (exit_code_fd != 0) {
-          int message[2] = { exit_code, negative };
+          int message[2] = {exit_code, negative};
           ssize_t result =
               FDUtils::WriteToBlocking(exit_code_fd, &message, sizeof(message));
           // If the process has been closed, the read end of the exit
           // pipe has been closed. It is therefore not a problem that
           // write fails with a broken pipe error. Other errors should
           // not happen.
           if ((result != -1) && (result != sizeof(message))) {
             FATAL("Failed to write entire process exit message");
           } else if ((result == -1) && (errno != EPIPE)) {
             FATAL1("Failed to write exit code: %d", errno);
@@ skipping 334 matching lines @@
     return 0;
   }
 
 
   int ReadExecResult() {
     int child_errno;
     int bytes_read = -1;
     // Read exec result from child. If no data is returned the exec was
     // successful and the exec call closed the pipe. Otherwise the errno
     // is written to the pipe.
-    bytes_read = FDUtils::ReadFromBlocking(
-        exec_control_[0], &child_errno, sizeof(child_errno));
+    bytes_read = FDUtils::ReadFromBlocking(exec_control_[0], &child_errno,
+                                           sizeof(child_errno));
     if (bytes_read == sizeof(child_errno)) {
       ReadChildError();
       return child_errno;
     } else if (bytes_read == -1) {
       return errno;
     }
     return 0;
   }
 
 
-  int ReadDetachedExecResult(pid_t *pid) {
+  int ReadDetachedExecResult(pid_t* pid) {
     int child_errno;
     int bytes_read = -1;
     // Read exec result from child. If only pid data is returned the exec was
     // successful and the exec call closed the pipe. Otherwise the errno
     // is written to the pipe as well.
     int result[2];
     bytes_read =
         FDUtils::ReadFromBlocking(exec_control_[0], result, sizeof(result));
     if (bytes_read == sizeof(int)) {
       *pid = result[0];
@@ skipping 42 matching lines @@
 
   void SetupDetachedWithStdio() {
     // Close all open file descriptors except for
     // exec_control_[1], write_out_[0], read_in_[1] and
     // read_err_[1].
     int max_fds = sysconf(_SC_OPEN_MAX);
     if (max_fds == -1) {
       max_fds = _POSIX_OPEN_MAX;
     }
     for (int fd = 0; fd < max_fds; fd++) {
-      if ((fd != exec_control_[1]) &&
-          (fd != write_out_[0]) &&
-          (fd != read_in_[1]) &&
-          (fd != read_err_[1])) {
+      if ((fd != exec_control_[1]) && (fd != write_out_[0]) &&
+          (fd != read_in_[1]) && (fd != read_err_[1])) {
         VOID_TEMP_FAILURE_RETRY(close(fd));
       }
     }
 
     if (TEMP_FAILURE_RETRY(dup2(write_out_[0], STDIN_FILENO)) == -1) {
       ReportChildError();
     }
     VOID_TEMP_FAILURE_RETRY(close(write_out_[0]));
 
     if (TEMP_FAILURE_RETRY(dup2(read_in_[1], STDOUT_FILENO)) == -1) {
@@ skipping 29 matching lines @@
   }
 
 
   void ReportChildError() {
     // In the case of failure in the child process write the errno and
     // the OS error message to the exec control pipe and exit.
     int child_errno = errno;
     const int kBufferSize = 1024;
     char os_error_message[kBufferSize];
     Utils::StrError(errno, os_error_message, kBufferSize);
-    int bytes_written = FDUtils::WriteToBlocking(
-        exec_control_[1], &child_errno, sizeof(child_errno));
+    int bytes_written = FDUtils::WriteToBlocking(exec_control_[1], &child_errno,
+                                                 sizeof(child_errno));
     if (bytes_written == sizeof(child_errno)) {
-      FDUtils::WriteToBlocking(
-          exec_control_[1], os_error_message, strlen(os_error_message) + 1);
+      FDUtils::WriteToBlocking(exec_control_[1], os_error_message,
+                               strlen(os_error_message) + 1);
     }
     VOID_TEMP_FAILURE_RETRY(close(exec_control_[1]));
     exit(1);
   }
 
 
   void ReportPid(int pid) {
     // In the case of starting a detached process the actual pid of that process
     // is communicated using the exec control pipe.
     int bytes_written =
@@ skipping 28 matching lines @@
 
 
   void CloseAllPipes() {
     ClosePipe(exec_control_);
     ClosePipe(read_in_);
     ClosePipe(read_err_);
     ClosePipe(write_out_);
   }
 
 
-  int read_in_[2];  // Pipe for stdout to child process.
-  int read_err_[2];  // Pipe for stderr to child process.
-  int write_out_[2];  // Pipe for stdin to child process.
+  int read_in_[2];       // Pipe for stdout to child process.
+  int read_err_[2];      // Pipe for stderr to child process.
+  int write_out_[2];     // Pipe for stdin to child process.
   int exec_control_[2];  // Pipe to get the result from exec.
 
   char** program_arguments_;
   char** program_environment_;
 
   const char* path_;
   const char* working_directory_;
   ProcessStartMode mode_;
   intptr_t* in_;
   intptr_t* out_;
@@ skipping 13 matching lines @@
                    const char* working_directory,
                    char* environment[],
                    intptr_t environment_length,
                    ProcessStartMode mode,
                    intptr_t* in,
                    intptr_t* out,
                    intptr_t* err,
                    intptr_t* id,
                    intptr_t* exit_event,
                    char** os_error_message) {
-  ProcessStarter starter(path,
-                         arguments,
-                         arguments_length,
-                         working_directory,
-                         environment,
-                         environment_length,
-                         mode,
-                         in,
-                         out,
-                         err,
-                         id,
-                         exit_event,
-                         os_error_message);
+  ProcessStarter starter(path, arguments, arguments_length, working_directory,
+                         environment, environment_length, mode, in, out, err,
+                         id, exit_event, os_error_message);
   return starter.Start();
 }
 
 
-class BufferList: public BufferListBase {
+class BufferList : public BufferListBase {
  public:
   BufferList() {}
 
   bool Read(int fd, intptr_t available) {
     // Read all available bytes.
     while (available > 0) {
       if (free_size_ == 0) {
         Allocate();
       }
       ASSERT(free_size_ > 0);
       ASSERT(free_size_ <= kBufferSize);
       size_t block_size = dart::Utils::Minimum(free_size_, available);
-      ssize_t bytes = TEMP_FAILURE_RETRY(read(
-          fd,
-          reinterpret_cast<void*>(FreeSpaceAddress()),
-          block_size));
+      ssize_t bytes = TEMP_FAILURE_RETRY(
+          read(fd, reinterpret_cast<void*>(FreeSpaceAddress()), block_size));
       if (bytes < 0) {
         return false;
       }
       data_size_ += bytes;
       free_size_ -= bytes;
       available -= bytes;
     }
     return true;
   }
 
@@ skipping 59 matching lines @@
           if (fds[i].fd == out) {
             if (!out_data.Read(out, avail)) {
               return CloseProcessBuffers(fds);
             }
           } else if (fds[i].fd == err) {
             if (!err_data.Read(err, avail)) {
               return CloseProcessBuffers(fds);
             }
           } else if (fds[i].fd == exit_event) {
             if (avail == 8) {
-              intptr_t b = TEMP_FAILURE_RETRY(read(fds[i].fd,
-                                                   exit_code_data.bytes, 8));
+              intptr_t b =
+                  TEMP_FAILURE_RETRY(read(fds[i].fd, exit_code_data.bytes, 8));
               if (b != 8) {
                 return CloseProcessBuffers(fds);
               }
             }
           } else {
             UNREACHABLE();
           }
         }
       }
       if (((fds[i].revents & POLLHUP) != 0) ||
@@ skipping 18 matching lines @@
     exit_code = -exit_code;
   }
   result->set_exit_code(exit_code);
 
   return true;
 }
 
 
 static int SignalMap(intptr_t id) {
   switch (static_cast<ProcessSignals>(id)) {
-    case kSighup: return SIGHUP;
-    case kSigint: return SIGINT;
-    case kSigquit: return SIGQUIT;
-    case kSigill: return SIGILL;
-    case kSigtrap: return SIGTRAP;
-    case kSigabrt: return SIGABRT;
-    case kSigbus: return SIGBUS;
-    case kSigfpe: return SIGFPE;
-    case kSigkill: return SIGKILL;
-    case kSigusr1: return SIGUSR1;
-    case kSigsegv: return SIGSEGV;
-    case kSigusr2: return SIGUSR2;
-    case kSigpipe: return SIGPIPE;
-    case kSigalrm: return SIGALRM;
-    case kSigterm: return SIGTERM;
-    case kSigchld: return SIGCHLD;
-    case kSigcont: return SIGCONT;
-    case kSigstop: return SIGSTOP;
-    case kSigtstp: return SIGTSTP;
-    case kSigttin: return SIGTTIN;
-    case kSigttou: return SIGTTOU;
-    case kSigurg: return SIGURG;
-    case kSigxcpu: return SIGXCPU;
-    case kSigxfsz: return SIGXFSZ;
-    case kSigvtalrm: return SIGVTALRM;
-    case kSigprof: return SIGPROF;
-    case kSigwinch: return SIGWINCH;
-    case kSigpoll: return -1;
-    case kSigsys: return SIGSYS;
+    case kSighup:
+      return SIGHUP;
+    case kSigint:
+      return SIGINT;
+    case kSigquit:
+      return SIGQUIT;
+    case kSigill:
+      return SIGILL;
+    case kSigtrap:
+      return SIGTRAP;
+    case kSigabrt:
+      return SIGABRT;
+    case kSigbus:
+      return SIGBUS;
+    case kSigfpe:
+      return SIGFPE;
+    case kSigkill:
+      return SIGKILL;
+    case kSigusr1:
+      return SIGUSR1;
+    case kSigsegv:
+      return SIGSEGV;
+    case kSigusr2:
+      return SIGUSR2;
+    case kSigpipe:
+      return SIGPIPE;
+    case kSigalrm:
+      return SIGALRM;
+    case kSigterm:
+      return SIGTERM;
+    case kSigchld:
+      return SIGCHLD;
+    case kSigcont:
+      return SIGCONT;
+    case kSigstop:
+      return SIGSTOP;
+    case kSigtstp:
+      return SIGTSTP;
+    case kSigttin:
+      return SIGTTIN;
+    case kSigttou:
+      return SIGTTOU;
+    case kSigurg:
+      return SIGURG;
+    case kSigxcpu:
+      return SIGXCPU;
+    case kSigxfsz:
+      return SIGXFSZ;
+    case kSigvtalrm:
+      return SIGVTALRM;
+    case kSigprof:
+      return SIGPROF;
+    case kSigwinch:
+      return SIGWINCH;
+    case kSigpoll:
+      return -1;
+    case kSigsys:
+      return SIGSYS;
   }
   return -1;
 }
 
 
 bool Process::Kill(intptr_t id, int signal) {
   return (TEMP_FAILURE_RETRY(kill(id, SignalMap(signal))) != -1);
 }
 
 
 void Process::TerminateExitCodeHandler() {
   ExitCodeHandler::TerminateExitCodeThread();
 }
 
 
 intptr_t Process::CurrentProcessId() {
   return static_cast<intptr_t>(getpid());
 }
 
 
 static Mutex* signal_mutex = new Mutex();
 static SignalInfo* signal_handlers = NULL;
 static const int kSignalsCount = 7;
 static const int kSignals[kSignalsCount] = {
-  SIGHUP,
-  SIGINT,
-  SIGTERM,
-  SIGUSR1,
-  SIGUSR2,
-  SIGWINCH,
-  SIGQUIT  // Allow VMService to listen on SIGQUIT.
+    SIGHUP, SIGINT, SIGTERM, SIGUSR1, SIGUSR2, SIGWINCH,
+    SIGQUIT  // Allow VMService to listen on SIGQUIT.
 };
 
 
 SignalInfo::~SignalInfo() {
   VOID_TEMP_FAILURE_RETRY(close(fd_));
 }
 
 
 static void SignalHandler(int signal) {
   MutexLocker lock(signal_mutex);
@@ skipping 20 matching lines @@
       break;
     }
   }
   if (!found) {
     return -1;
   }
   int fds[2];
   if (NO_RETRY_EXPECTED(pipe(fds)) != 0) {
     return -1;
   }
-  if (!FDUtils::SetCloseOnExec(fds[0]) ||
-      !FDUtils::SetCloseOnExec(fds[1]) ||
+  if (!FDUtils::SetCloseOnExec(fds[0]) || !FDUtils::SetCloseOnExec(fds[1]) ||
       !FDUtils::SetNonBlocking(fds[0])) {
     VOID_TEMP_FAILURE_RETRY(close(fds[0]));
     VOID_TEMP_FAILURE_RETRY(close(fds[1]));
     return -1;
   }
   ThreadSignalBlocker blocker(kSignalsCount, kSignals);
   MutexLocker lock(signal_mutex);
   SignalInfo* handler = signal_handlers;
   bool listen = true;
   while (handler != NULL) {
@@ skipping 58 matching lines @@
     VOID_NO_RETRY_EXPECTED(sigaction(signal, &act, NULL));
   }
 }
 
 }  // namespace bin
 }  // namespace dart
 
 #endif  // defined(TARGET_OS_MACOS)
 
 #endif  // !defined(DART_IO_DISABLED)