Cleanup orphaned testserver processes on posix.

chrome/test/test_launcher/out_of_proc_test_runner.cc

 // Copyright (c) 2010 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include <string>
 
 #include "base/command_line.h"
 #include "base/logging.h"
 #include "base/process_util.h"
 #include "base/string_number_conversions.h"
@@ skipping 71 matching lines @@
     // tests unless this flag was specified to the browser test executable.
     new_cmd_line.AppendSwitch("gtest_also_run_disabled_tests");
     new_cmd_line.AppendSwitchASCII("gtest_filter", test_name);
     new_cmd_line.AppendSwitch(kChildProcessFlag);
 
     // Do not let the child ignore failures.  We need to propagate the
     // failure status back to the parent.
     new_cmd_line.AppendSwitch(base::TestSuite::kStrictFailureHandling);
 
     base::ProcessHandle process_handle;
+#if defined(OS_POSIX)
+    // On POSIX, we launch the test in a new process group with pgid equal to
+    // its pid. Any child processes that the test may create will inherit the
+    // same pgid. This way, if the test is abruptly terminated, we can clean up
+    // any orphaned child processes it may have left behind.
+    base::environment_vector no_env;
+    base::file_handle_mapping_vector no_files;
+    if (!base::LaunchAppInNewProcessGroup(new_cmd_line.argv(), no_env, no_files,
+                                          false, &process_handle))
+#else
     if (!base::LaunchApp(new_cmd_line, false, false, &process_handle))
+#endif
       return false;
 
     int test_terminate_timeout_ms = kDefaultTestTimeoutMs;
     if (cmd_line->HasSwitch(kTestTerminateTimeoutFlag)) {
       std::string timeout_str =
           cmd_line->GetSwitchValueASCII(kTestTerminateTimeoutFlag);
       int timeout;
       base::StringToInt(timeout_str, &timeout);
       test_terminate_timeout_ms = std::max(test_terminate_timeout_ms, timeout);
     }
 
     int exit_code = 0;
     if (!base::WaitForExitCodeWithTimeout(process_handle, &exit_code,
                                           test_terminate_timeout_ms)) {
       LOG(ERROR) << "Test timeout (" << test_terminate_timeout_ms
                  << " ms) exceeded for " << test_name;
 
       exit_code = -1;  // Set a non-zero exit code to signal a failure.
 
       // Ensure that the process terminates.
       base::KillProcess(process_handle, -1, true);
+
+#if defined(OS_POSIX)
+      // On POSIX, we need to clean up any child processes that the test might
+      // have created. On windows, child processes are automatically cleaned up
+      // using JobObjects.
+      base::KillProcessGroup(process_handle);
+#endif
     }
 
     return exit_code == 0;
   }
 
  private:
   DISALLOW_COPY_AND_ASSIGN(OutOfProcTestRunner);
 };
 
 class OutOfProcTestRunnerFactory : public tests::TestRunnerFactory {
@@ skipping 105 matching lines @@
       exit_code = 1;
       break;
     }
 
     // Special value "-1" means "repeat indefinitely".
     if (cycles != -1)
       cycles--;
   }
   return exit_code;
 }