base/process_util_unittest.cc

   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
   3 // found in the LICENSE file.
   4
   5 #define _CRT_SECURE_NO_WARNINGS
   6
   7 #include <limits>
   8
   9 #include "base/command_line.h"
  10 #include "base/debug/alias.h"
  11 #include "base/debug/stack_trace.h"
  12 #include "base/files/file_path.h"
  13 #include "base/logging.h"
  14 #include "base/memory/scoped_ptr.h"
  15 #include "base/path_service.h"
  16 #include "base/posix/eintr_wrapper.h"
  17 #include "base/process_util.h"
  18 #include "base/test/multiprocess_test.h"
  19 #include "base/test/test_timeouts.h"
  20 #include "base/third_party/dynamic_annotations/dynamic_annotations.h"
  21 #include "base/threading/platform_thread.h"
  22 #include "base/threading/thread.h"
  23 #include "base/utf_string_conversions.h"
  24 #include "testing/gtest/include/gtest/gtest.h"
  25 #include "testing/multiprocess_func_list.h"
  26
  27 #if defined(OS_LINUX)
  28 #include <glib.h>
  29 #include <malloc.h>
  30 #include <sched.h>
  31 #endif
  32 #if defined(OS_POSIX)
  33 #include <dlfcn.h>
  34 #include <errno.h>
  35 #include <fcntl.h>
  36 #include <signal.h>
  37 #include <sys/resource.h>
  38 #include <sys/socket.h>
  39 #include <sys/wait.h>
  40 #endif
  41 #if defined(OS_WIN)
  42 #include <windows.h>
  43 #endif
  44 #if defined(OS_MACOSX)
  45 #include <mach/vm_param.h>
  46 #include <malloc/malloc.h>
  47 #include "base/process_util_unittest_mac.h"
  48 #endif
  49
  50 using base::FilePath;
  51
  52 namespace {
  53
  54 #if defined(OS_WIN)
  55 const wchar_t kProcessName[] = L"base_unittests.exe";
  56 #else
  57 const wchar_t kProcessName[] = L"base_unittests";
  58 #endif  // defined(OS_WIN)
  59
  60 #if defined(OS_ANDROID)
  61 const char kShellPath[] = "/system/bin/sh";
  62 const char kPosixShell[] = "sh";
  63 #else
  64 const char kShellPath[] = "/bin/sh";
  65 const char kPosixShell[] = "bash";
  66 #endif
  67
  68 const char kSignalFileSlow[] = "SlowChildProcess.die";
  69 const char kSignalFileCrash[] = "CrashingChildProcess.die";
  70 const char kSignalFileKill[] = "KilledChildProcess.die";
  71
  72 #if defined(OS_WIN)
  73 const int kExpectedStillRunningExitCode = 0x102;
  74 const int kExpectedKilledExitCode = 1;
  75 #else
  76 const int kExpectedStillRunningExitCode = 0;
  77 #endif
  78
  79 #if defined(OS_WIN)
  80 // HeapQueryInformation function pointer.
  81 typedef BOOL (WINAPI* HeapQueryFn)  \
  82     (HANDLE, HEAP_INFORMATION_CLASS, PVOID, SIZE_T, PSIZE_T);
  83 #endif
  84
  85 // Sleeps until file filename is created.
  86 void WaitToDie(const char* filename) {
  87   FILE* fp;
  88   do {
  89     base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(10));
  90     fp = fopen(filename, "r");
  91   } while (!fp);
  92   fclose(fp);
  93 }
  94
  95 // Signals children they should die now.
  96 void SignalChildren(const char* filename) {
  97   FILE* fp = fopen(filename, "w");
  98   fclose(fp);
  99 }
 100
 101 // Using a pipe to the child to wait for an event was considered, but
 102 // there were cases in the past where pipes caused problems (other
 103 // libraries closing the fds, child deadlocking). This is a simple
 104 // case, so it's not worth the risk.  Using wait loops is discouraged
 105 // in most instances.
 106 base::TerminationStatus WaitForChildTermination(base::ProcessHandle handle,
 107                                                 int* exit_code) {
 108   // Now we wait until the result is something other than STILL_RUNNING.
 109   base::TerminationStatus status = base::TERMINATION_STATUS_STILL_RUNNING;
 110   const base::TimeDelta kInterval = base::TimeDelta::FromMilliseconds(20);
 111   base::TimeDelta waited;
 112   do {
 113     status = base::GetTerminationStatus(handle, exit_code);
 114     base::PlatformThread::Sleep(kInterval);
 115     waited += kInterval;
 116   } while (status == base::TERMINATION_STATUS_STILL_RUNNING &&
 117 // Waiting for more time for process termination on android devices.
 118 #if defined(OS_ANDROID)
 119            waited < TestTimeouts::large_test_timeout());
 120 #else
 121            waited < TestTimeouts::action_max_timeout());
 122 #endif
 123
 124   return status;
 125 }
 126
 127 }  // namespace
 128
 129 class ProcessUtilTest : public base::MultiProcessTest {
 130  public:
 131 #if defined(OS_POSIX)
 132   // Spawn a child process that counts how many file descriptors are open.
 133   int CountOpenFDsInChild();
 134 #endif
 135   // Converts the filename to a platform specific filepath.
 136   // On Android files can not be created in arbitrary directories.
 137   static std::string GetSignalFilePath(const char* filename);
 138 };
 139
 140 std::string ProcessUtilTest::GetSignalFilePath(const char* filename) {
 141 #if !defined(OS_ANDROID)
 142   return filename;
 143 #else
 144   FilePath tmp_dir;
 145   PathService::Get(base::DIR_CACHE, &tmp_dir);
 146   tmp_dir = tmp_dir.Append(filename);
 147   return tmp_dir.value();
 148 #endif
 149 }
 150
 151 MULTIPROCESS_TEST_MAIN(SimpleChildProcess) {
 152   return 0;
 153 }
 154
 155 TEST_F(ProcessUtilTest, SpawnChild) {
 156   base::ProcessHandle handle = this->SpawnChild("SimpleChildProcess", false);
 157   ASSERT_NE(base::kNullProcessHandle, handle);
 158   EXPECT_TRUE(base::WaitForSingleProcess(
 159                   handle, TestTimeouts::action_max_timeout()));
 160   base::CloseProcessHandle(handle);
 161 }
 162
 163 MULTIPROCESS_TEST_MAIN(SlowChildProcess) {
 164   WaitToDie(ProcessUtilTest::GetSignalFilePath(kSignalFileSlow).c_str());
 165   return 0;
 166 }
 167
 168 TEST_F(ProcessUtilTest, KillSlowChild) {
 169   const std::string signal_file =
 170       ProcessUtilTest::GetSignalFilePath(kSignalFileSlow);
 171   remove(signal_file.c_str());
 172   base::ProcessHandle handle = this->SpawnChild("SlowChildProcess", false);
 173   ASSERT_NE(base::kNullProcessHandle, handle);
 174   SignalChildren(signal_file.c_str());
 175   EXPECT_TRUE(base::WaitForSingleProcess(
 176                   handle, TestTimeouts::action_max_timeout()));
 177   base::CloseProcessHandle(handle);
 178   remove(signal_file.c_str());
 179 }
 180
 181 // Times out on Linux and Win, flakes on other platforms, http://crbug.com/95058
 182 TEST_F(ProcessUtilTest, DISABLED_GetTerminationStatusExit) {
 183   const std::string signal_file =
 184       ProcessUtilTest::GetSignalFilePath(kSignalFileSlow);
 185   remove(signal_file.c_str());
 186   base::ProcessHandle handle = this->SpawnChild("SlowChildProcess", false);
 187   ASSERT_NE(base::kNullProcessHandle, handle);
 188
 189   int exit_code = 42;
 190   EXPECT_EQ(base::TERMINATION_STATUS_STILL_RUNNING,
 191             base::GetTerminationStatus(handle, &exit_code));
 192   EXPECT_EQ(kExpectedStillRunningExitCode, exit_code);
 193
 194   SignalChildren(signal_file.c_str());
 195   exit_code = 42;
 196   base::TerminationStatus status =
 197       WaitForChildTermination(handle, &exit_code);
 198   EXPECT_EQ(base::TERMINATION_STATUS_NORMAL_TERMINATION, status);
 199   EXPECT_EQ(0, exit_code);
 200   base::CloseProcessHandle(handle);
 201   remove(signal_file.c_str());
 202 }
 203
 204 #if defined(OS_WIN)
 205 // TODO(cpu): figure out how to test this in other platforms.
 206 TEST_F(ProcessUtilTest, GetProcId) {
 207   base::ProcessId id1 = base::GetProcId(GetCurrentProcess());
 208   EXPECT_NE(0ul, id1);
 209   base::ProcessHandle handle = this->SpawnChild("SimpleChildProcess", false);
 210   ASSERT_NE(base::kNullProcessHandle, handle);
 211   base::ProcessId id2 = base::GetProcId(handle);
 212   EXPECT_NE(0ul, id2);
 213   EXPECT_NE(id1, id2);
 214   base::CloseProcessHandle(handle);
 215 }
 216
 217 TEST_F(ProcessUtilTest, GetModuleFromAddress) {
 218   // Since the unit tests are their own EXE, this should be
 219   // equivalent to the EXE's HINSTANCE.
 220   //
 221   // kExpectedKilledExitCode is a constant in this file and
 222   // therefore within the unit test EXE.
 223   EXPECT_EQ(::GetModuleHandle(NULL),
 224             base::GetModuleFromAddress(
 225                 const_cast<int*>(&kExpectedKilledExitCode)));
 226
 227   // Any address within the kernel32 module should return
 228   // kernel32's HMODULE.  Our only assumption here is that
 229   // kernel32 is larger than 4 bytes.
 230   HMODULE kernel32 = ::GetModuleHandle(L"kernel32.dll");
 231   HMODULE kernel32_from_address =
 232       base::GetModuleFromAddress(reinterpret_cast<DWORD*>(kernel32) + 1);
 233   EXPECT_EQ(kernel32, kernel32_from_address);
 234 }
 235 #endif
 236
 237 #if !defined(OS_MACOSX)
 238 // This test is disabled on Mac, since it's flaky due to ReportCrash
 239 // taking a variable amount of time to parse and load the debug and
 240 // symbol data for this unit test's executable before firing the
 241 // signal handler.
 242 //
 243 // TODO(gspencer): turn this test process into a very small program
 244 // with no symbols (instead of using the multiprocess testing
 245 // framework) to reduce the ReportCrash overhead.
 246
 247 MULTIPROCESS_TEST_MAIN(CrashingChildProcess) {
 248   WaitToDie(ProcessUtilTest::GetSignalFilePath(kSignalFileCrash).c_str());
 249 #if defined(OS_POSIX)
 250   // Have to disable to signal handler for segv so we can get a crash
 251   // instead of an abnormal termination through the crash dump handler.
 252   ::signal(SIGSEGV, SIG_DFL);
 253 #endif
 254   // Make this process have a segmentation fault.
 255   volatile int* oops = NULL;
 256   *oops = 0xDEAD;
 257   return 1;
 258 }
 259
 260 // This test intentionally crashes, so we don't need to run it under
 261 // AddressSanitizer.
 262 // TODO(jschuh): crbug.com/175753 Fix this in Win64 bots.
 263 #if defined(ADDRESS_SANITIZER) || (defined(OS_WIN) && defined(ARCH_CPU_X86_64))
 264 #define MAYBE_GetTerminationStatusCrash DISABLED_GetTerminationStatusCrash
 265 #else
 266 #define MAYBE_GetTerminationStatusCrash GetTerminationStatusCrash
 267 #endif
 268 TEST_F(ProcessUtilTest, MAYBE_GetTerminationStatusCrash) {
 269   const std::string signal_file =
 270     ProcessUtilTest::GetSignalFilePath(kSignalFileCrash);
 271   remove(signal_file.c_str());
 272   base::ProcessHandle handle = this->SpawnChild("CrashingChildProcess",
 273                                                 false);
 274   ASSERT_NE(base::kNullProcessHandle, handle);
 275
 276   int exit_code = 42;
 277   EXPECT_EQ(base::TERMINATION_STATUS_STILL_RUNNING,
 278             base::GetTerminationStatus(handle, &exit_code));
 279   EXPECT_EQ(kExpectedStillRunningExitCode, exit_code);
 280
 281   SignalChildren(signal_file.c_str());
 282   exit_code = 42;
 283   base::TerminationStatus status =
 284       WaitForChildTermination(handle, &exit_code);
 285   EXPECT_EQ(base::TERMINATION_STATUS_PROCESS_CRASHED, status);
 286
 287 #if defined(OS_WIN)
 288   EXPECT_EQ(0xc0000005, exit_code);
 289 #elif defined(OS_POSIX)
 290   int signaled = WIFSIGNALED(exit_code);
 291   EXPECT_NE(0, signaled);
 292   int signal = WTERMSIG(exit_code);
 293   EXPECT_EQ(SIGSEGV, signal);
 294 #endif
 295   base::CloseProcessHandle(handle);
 296
 297   // Reset signal handlers back to "normal".
 298   base::debug::EnableInProcessStackDumping();
 299   remove(signal_file.c_str());
 300 }
 301 #endif  // !defined(OS_MACOSX)
 302
 303 MULTIPROCESS_TEST_MAIN(KilledChildProcess) {
 304   WaitToDie(ProcessUtilTest::GetSignalFilePath(kSignalFileKill).c_str());
 305 #if defined(OS_WIN)
 306   // Kill ourselves.
 307   HANDLE handle = ::OpenProcess(PROCESS_ALL_ACCESS, 0, ::GetCurrentProcessId());
 308   ::TerminateProcess(handle, kExpectedKilledExitCode);
 309 #elif defined(OS_POSIX)
 310   // Send a SIGKILL to this process, just like the OOM killer would.
 311   ::kill(getpid(), SIGKILL);
 312 #endif
 313   return 1;
 314 }
 315
 316 TEST_F(ProcessUtilTest, GetTerminationStatusKill) {
 317   const std::string signal_file =
 318     ProcessUtilTest::GetSignalFilePath(kSignalFileKill);
 319   remove(signal_file.c_str());
 320   base::ProcessHandle handle = this->SpawnChild("KilledChildProcess",
 321                                                 false);
 322   ASSERT_NE(base::kNullProcessHandle, handle);
 323
 324   int exit_code = 42;
 325   EXPECT_EQ(base::TERMINATION_STATUS_STILL_RUNNING,
 326             base::GetTerminationStatus(handle, &exit_code));
 327   EXPECT_EQ(kExpectedStillRunningExitCode, exit_code);
 328
 329   SignalChildren(signal_file.c_str());
 330   exit_code = 42;
 331   base::TerminationStatus status =
 332       WaitForChildTermination(handle, &exit_code);
 333   EXPECT_EQ(base::TERMINATION_STATUS_PROCESS_WAS_KILLED, status);
 334 #if defined(OS_WIN)
 335   EXPECT_EQ(kExpectedKilledExitCode, exit_code);
 336 #elif defined(OS_POSIX)
 337   int signaled = WIFSIGNALED(exit_code);
 338   EXPECT_NE(0, signaled);
 339   int signal = WTERMSIG(exit_code);
 340   EXPECT_EQ(SIGKILL, signal);
 341 #endif
 342   base::CloseProcessHandle(handle);
 343   remove(signal_file.c_str());
 344 }
 345
 346 // Ensure that the priority of a process is restored correctly after
 347 // backgrounding and restoring.
 348 // Note: a platform may not be willing or able to lower the priority of
 349 // a process. The calls to SetProcessBackground should be noops then.
 350 TEST_F(ProcessUtilTest, SetProcessBackgrounded) {
 351   base::ProcessHandle handle = this->SpawnChild("SimpleChildProcess", false);
 352   base::Process process(handle);
 353   int old_priority = process.GetPriority();
 354 #if defined(OS_WIN)
 355   EXPECT_TRUE(process.SetProcessBackgrounded(true));
 356   EXPECT_TRUE(process.IsProcessBackgrounded());
 357   EXPECT_TRUE(process.SetProcessBackgrounded(false));
 358   EXPECT_FALSE(process.IsProcessBackgrounded());
 359 #else
 360   process.SetProcessBackgrounded(true);
 361   process.SetProcessBackgrounded(false);
 362 #endif
 363   int new_priority = process.GetPriority();
 364   EXPECT_EQ(old_priority, new_priority);
 365 }
 366
 367 // Same as SetProcessBackgrounded but to this very process. It uses
 368 // a different code path at least for Windows.
 369 TEST_F(ProcessUtilTest, SetProcessBackgroundedSelf) {
 370   base::Process process(base::Process::Current().handle());
 371   int old_priority = process.GetPriority();
 372 #if defined(OS_WIN)
 373   EXPECT_TRUE(process.SetProcessBackgrounded(true));
 374   EXPECT_TRUE(process.IsProcessBackgrounded());
 375   EXPECT_TRUE(process.SetProcessBackgrounded(false));
 376   EXPECT_FALSE(process.IsProcessBackgrounded());
 377 #else
 378   process.SetProcessBackgrounded(true);
 379   process.SetProcessBackgrounded(false);
 380 #endif
 381   int new_priority = process.GetPriority();
 382   EXPECT_EQ(old_priority, new_priority);
 383 }
 384
 385 #if defined(OS_LINUX) || defined(OS_ANDROID)
 386 TEST_F(ProcessUtilTest, GetSystemMemoryInfo) {
 387   base::SystemMemoryInfoKB info;
 388   EXPECT_TRUE(base::GetSystemMemoryInfo(&info));
 389
 390   // Ensure each field received a value.
 391   EXPECT_GT(info.total, 0);
 392   EXPECT_GT(info.free, 0);
 393   EXPECT_GT(info.buffers, 0);
 394   EXPECT_GT(info.cached, 0);
 395   EXPECT_GT(info.active_anon, 0);
 396   EXPECT_GT(info.inactive_anon, 0);
 397   EXPECT_GT(info.active_file, 0);
 398   EXPECT_GT(info.inactive_file, 0);
 399
 400   // All the values should be less than the total amount of memory.
 401   EXPECT_LT(info.free, info.total);
 402   EXPECT_LT(info.buffers, info.total);
 403   EXPECT_LT(info.cached, info.total);
 404   EXPECT_LT(info.active_anon, info.total);
 405   EXPECT_LT(info.inactive_anon, info.total);
 406   EXPECT_LT(info.active_file, info.total);
 407   EXPECT_LT(info.inactive_file, info.total);
 408
 409 #if defined(OS_CHROMEOS)
 410   // Chrome OS exposes shmem.
 411   EXPECT_GT(info.shmem, 0);
 412   EXPECT_LT(info.shmem, info.total);
 413   // Chrome unit tests are not run on actual Chrome OS hardware, so gem_objects
 414   // and gem_size cannot be tested here.
 415 #endif
 416 }
 417 #endif  // defined(OS_LINUX) || defined(OS_ANDROID)
 418
 419 // TODO(estade): if possible, port these 2 tests.
 420 #if defined(OS_WIN)
 421 TEST_F(ProcessUtilTest, EnableLFH) {
 422   ASSERT_TRUE(base::EnableLowFragmentationHeap());
 423   if (IsDebuggerPresent()) {
 424     // Under these conditions, LFH can't be enabled. There's no point to test
 425     // anything.
 426     const char* no_debug_env = getenv("_NO_DEBUG_HEAP");
 427     if (!no_debug_env || strcmp(no_debug_env, "1"))
 428       return;
 429   }
 430   HMODULE kernel32 = GetModuleHandle(L"kernel32.dll");
 431   ASSERT_TRUE(kernel32 != NULL);
 432   HeapQueryFn heap_query = reinterpret_cast<HeapQueryFn>(GetProcAddress(
 433       kernel32,
 434       "HeapQueryInformation"));
 435
 436   // On Windows 2000, the function is not exported. This is not a reason to
 437   // fail but we won't be able to retrieves information about the heap, so we
 438   // should stop here.
 439   if (heap_query == NULL)
 440     return;
 441
 442   HANDLE heaps[1024] = { 0 };
 443   unsigned number_heaps = GetProcessHeaps(1024, heaps);
 444   EXPECT_GT(number_heaps, 0u);
 445   for (unsigned i = 0; i < number_heaps; ++i) {
 446     ULONG flag = 0;
 447     SIZE_T length;
 448     ASSERT_NE(0, heap_query(heaps[i],
 449                             HeapCompatibilityInformation,
 450                             &flag,
 451                             sizeof(flag),
 452                             &length));
 453     // If flag is 0, the heap is a standard heap that does not support
 454     // look-asides. If flag is 1, the heap supports look-asides. If flag is 2,
 455     // the heap is a low-fragmentation heap (LFH). Note that look-asides are not
 456     // supported on the LFH.
 457
 458     // We don't have any documented way of querying the HEAP_NO_SERIALIZE flag.
 459     EXPECT_LE(flag, 2u);
 460     EXPECT_NE(flag, 1u);
 461   }
 462 }
 463
 464 TEST_F(ProcessUtilTest, CalcFreeMemory) {
 465   scoped_ptr<base::ProcessMetrics> metrics(
 466       base::ProcessMetrics::CreateProcessMetrics(::GetCurrentProcess()));
 467   ASSERT_TRUE(NULL != metrics.get());
 468
 469   // Typical values here is ~1900 for total and ~1000 for largest. Obviously
 470   // it depends in what other tests have done to this process.
 471   base::FreeMBytes free_mem1 = {0};
 472   EXPECT_TRUE(metrics->CalculateFreeMemory(&free_mem1));
 473   EXPECT_LT(10u, free_mem1.total);
 474   EXPECT_LT(10u, free_mem1.largest);
 475   EXPECT_GT(2048u, free_mem1.total);
 476   EXPECT_GT(2048u, free_mem1.largest);
 477   EXPECT_GE(free_mem1.total, free_mem1.largest);
 478   EXPECT_TRUE(NULL != free_mem1.largest_ptr);
 479
 480   // Allocate 20M and check again. It should have gone down.
 481   const int kAllocMB = 20;
 482   scoped_ptr<char[]> alloc(new char[kAllocMB * 1024 * 1024]);
 483   size_t expected_total = free_mem1.total - kAllocMB;
 484   size_t expected_largest = free_mem1.largest;
 485
 486   base::FreeMBytes free_mem2 = {0};
 487   EXPECT_TRUE(metrics->CalculateFreeMemory(&free_mem2));
 488   EXPECT_GE(free_mem2.total, free_mem2.largest);
 489   EXPECT_GE(expected_total, free_mem2.total);
 490   EXPECT_GE(expected_largest, free_mem2.largest);
 491   EXPECT_TRUE(NULL != free_mem2.largest_ptr);
 492 }
 493
 494 TEST_F(ProcessUtilTest, GetAppOutput) {
 495   // Let's create a decently long message.
 496   std::string message;
 497   for (int i = 0; i < 1025; i++) {  // 1025 so it does not end on a kilo-byte
 498                                     // boundary.
 499     message += "Hello!";
 500   }
 501   // cmd.exe's echo always adds a \r\n to its output.
 502   std::string expected(message);
 503   expected += "\r\n";
 504
 505   FilePath cmd(L"cmd.exe");
 506   CommandLine cmd_line(cmd);
 507   cmd_line.AppendArg("/c");
 508   cmd_line.AppendArg("echo " + message + "");
 509   std::string output;
 510   ASSERT_TRUE(base::GetAppOutput(cmd_line, &output));
 511   EXPECT_EQ(expected, output);
 512
 513   // Let's make sure stderr is ignored.
 514   CommandLine other_cmd_line(cmd);
 515   other_cmd_line.AppendArg("/c");
 516   // http://msdn.microsoft.com/library/cc772622.aspx
 517   cmd_line.AppendArg("echo " + message + " >&2");
 518   output.clear();
 519   ASSERT_TRUE(base::GetAppOutput(other_cmd_line, &output));
 520   EXPECT_EQ("", output);
 521 }
 522
 523 TEST_F(ProcessUtilTest, LaunchAsUser) {
 524   base::UserTokenHandle token;
 525   ASSERT_TRUE(OpenProcessToken(GetCurrentProcess(), TOKEN_ALL_ACCESS, &token));
 526   std::wstring cmdline =
 527       this->MakeCmdLine("SimpleChildProcess", false).GetCommandLineString();
 528   base::LaunchOptions options;
 529   options.as_user = token;
 530   EXPECT_TRUE(base::LaunchProcess(cmdline, options, NULL));
 531 }
 532
 533 #endif  // defined(OS_WIN)
 534
 535 #if defined(OS_MACOSX)
 536
 537 // For the following Mac tests:
 538 // Note that base::EnableTerminationOnHeapCorruption() is called as part of
 539 // test suite setup and does not need to be done again, else mach_override
 540 // will fail.
 541
 542 #if !defined(ADDRESS_SANITIZER)
 543 // The following code tests the system implementation of malloc() thus no need
 544 // to test it under AddressSanitizer.
 545 TEST_F(ProcessUtilTest, MacMallocFailureDoesNotTerminate) {
 546   // Test that ENOMEM doesn't crash via CrMallocErrorBreak two ways: the exit
 547   // code and lack of the error string. The number of bytes is one less than
 548   // MALLOC_ABSOLUTE_MAX_SIZE, more than which the system early-returns NULL and
 549   // does not call through malloc_error_break(). See the comment at
 550   // EnableTerminationOnOutOfMemory() for more information.
 551   void* buf = NULL;
 552   ASSERT_EXIT(
 553       {
 554         base::EnableTerminationOnOutOfMemory();
 555
 556         buf = malloc(std::numeric_limits<size_t>::max() - (2 * PAGE_SIZE) - 1);
 557       },
 558       testing::KilledBySignal(SIGTRAP),
 559       "\\*\\*\\* error: can't allocate region.*"
 560           "(Terminating process due to a potential for future heap "
 561           "corruption){0}");
 562
 563   base::debug::Alias(buf);
 564 }
 565 #endif  // !defined(ADDRESS_SANITIZER)
 566
 567 TEST_F(ProcessUtilTest, MacTerminateOnHeapCorruption) {
 568   // Assert that freeing an unallocated pointer will crash the process.
 569   char buf[3];
 570   asm("" : "=r" (buf));  // Prevent clang from being too smart.
 571 #if ARCH_CPU_64_BITS
 572   // On 64 bit Macs, the malloc system automatically abort()s on heap corruption
 573   // but does not output anything.
 574   ASSERT_DEATH(free(buf), "");
 575 #elif defined(ADDRESS_SANITIZER)
 576   // AddressSanitizer replaces malloc() and prints a different error message on
 577   // heap corruption.
 578   ASSERT_DEATH(free(buf), "attempting free on address which "
 579       "was not malloc\\(\\)-ed");
 580 #else
 581   ASSERT_DEATH(free(buf), "being freed.*"
 582       "\\*\\*\\* set a breakpoint in malloc_error_break to debug.*"
 583       "Terminating process due to a potential for future heap corruption");
 584 #endif  // ARCH_CPU_64_BITS || defined(ADDRESS_SANITIZER)
 585 }
 586
 587 #endif  // defined(OS_MACOSX)
 588
 589 #if defined(OS_POSIX)
 590
 591 namespace {
 592
 593 // Returns the maximum number of files that a process can have open.
 594 // Returns 0 on error.
 595 int GetMaxFilesOpenInProcess() {
 596   struct rlimit rlim;
 597   if (getrlimit(RLIMIT_NOFILE, &rlim) != 0) {
 598     return 0;
 599   }
 600
 601   // rlim_t is a uint64 - clip to maxint. We do this since FD #s are ints
 602   // which are all 32 bits on the supported platforms.
 603   rlim_t max_int = static_cast<rlim_t>(std::numeric_limits<int32>::max());
 604   if (rlim.rlim_cur > max_int) {
 605     return max_int;
 606   }
 607
 608   return rlim.rlim_cur;
 609 }
 610
 611 const int kChildPipe = 20;  // FD # for write end of pipe in child process.
 612
 613 }  // namespace
 614
 615 MULTIPROCESS_TEST_MAIN(ProcessUtilsLeakFDChildProcess) {
 616   // This child process counts the number of open FDs, it then writes that
 617   // number out to a pipe connected to the parent.
 618   int num_open_files = 0;
 619   int write_pipe = kChildPipe;
 620   int max_files = GetMaxFilesOpenInProcess();
 621   for (int i = STDERR_FILENO + 1; i < max_files; i++) {
 622     if (i != kChildPipe) {
 623       int fd;
 624       if ((fd = HANDLE_EINTR(dup(i))) != -1) {
 625         close(fd);
 626         num_open_files += 1;
 627       }
 628     }
 629   }
 630
 631   int written = HANDLE_EINTR(write(write_pipe, &num_open_files,
 632                                    sizeof(num_open_files)));
 633   DCHECK_EQ(static_cast<size_t>(written), sizeof(num_open_files));
 634   int ret = HANDLE_EINTR(close(write_pipe));
 635   DPCHECK(ret == 0);
 636
 637   return 0;
 638 }
 639
 640 int ProcessUtilTest::CountOpenFDsInChild() {
 641   int fds[2];
 642   if (pipe(fds) < 0)
 643     NOTREACHED();
 644
 645   base::FileHandleMappingVector fd_mapping_vec;
 646   fd_mapping_vec.push_back(std::pair<int, int>(fds[1], kChildPipe));
 647   base::ProcessHandle handle = this->SpawnChild(
 648       "ProcessUtilsLeakFDChildProcess", fd_mapping_vec, false);
 649   CHECK(handle);
 650   int ret = HANDLE_EINTR(close(fds[1]));
 651   DPCHECK(ret == 0);
 652
 653   // Read number of open files in client process from pipe;
 654   int num_open_files = -1;
 655   ssize_t bytes_read =
 656       HANDLE_EINTR(read(fds[0], &num_open_files, sizeof(num_open_files)));
 657   CHECK_EQ(bytes_read, static_cast<ssize_t>(sizeof(num_open_files)));
 658
 659 #if defined(THREAD_SANITIZER) || defined(USE_HEAPCHECKER)
 660   // Compiler-based ThreadSanitizer makes this test slow.
 661   CHECK(base::WaitForSingleProcess(handle, base::TimeDelta::FromSeconds(3)));
 662 #else
 663   CHECK(base::WaitForSingleProcess(handle, base::TimeDelta::FromSeconds(1)));
 664 #endif
 665   base::CloseProcessHandle(handle);
 666   ret = HANDLE_EINTR(close(fds[0]));
 667   DPCHECK(ret == 0);
 668
 669   return num_open_files;
 670 }
 671
 672 #if defined(ADDRESS_SANITIZER) || defined(THREAD_SANITIZER)
 673 // ProcessUtilTest.FDRemapping is flaky when ran under xvfb-run on Precise.
 674 // The problem is 100% reproducible with both ASan and TSan.
 675 // See http://crbug.com/136720.
 676 #define MAYBE_FDRemapping DISABLED_FDRemapping
 677 #else
 678 #define MAYBE_FDRemapping FDRemapping
 679 #endif
 680 TEST_F(ProcessUtilTest, MAYBE_FDRemapping) {
 681   int fds_before = CountOpenFDsInChild();
 682
 683   // open some dummy fds to make sure they don't propagate over to the
 684   // child process.
 685   int dev_null = open("/dev/null", O_RDONLY);
 686   int sockets[2];
 687   socketpair(AF_UNIX, SOCK_STREAM, 0, sockets);
 688
 689   int fds_after = CountOpenFDsInChild();
 690
 691   ASSERT_EQ(fds_after, fds_before);
 692
 693   int ret;
 694   ret = HANDLE_EINTR(close(sockets[0]));
 695   DPCHECK(ret == 0);
 696   ret = HANDLE_EINTR(close(sockets[1]));
 697   DPCHECK(ret == 0);
 698   ret = HANDLE_EINTR(close(dev_null));
 699   DPCHECK(ret == 0);
 700 }
 701
 702 namespace {
 703
 704 std::string TestLaunchProcess(const base::EnvironmentVector& env_changes,
 705                               const int clone_flags) {
 706   std::vector<std::string> args;
 707   base::FileHandleMappingVector fds_to_remap;
 708
 709   args.push_back(kPosixShell);
 710   args.push_back("-c");
 711   args.push_back("echo $BASE_TEST");
 712
 713   int fds[2];
 714   PCHECK(pipe(fds) == 0);
 715
 716   fds_to_remap.push_back(std::make_pair(fds[1], 1));
 717   base::LaunchOptions options;
 718   options.wait = true;
 719   options.environ = &env_changes;
 720   options.fds_to_remap = &fds_to_remap;
 721 #if defined(OS_LINUX)
 722   options.clone_flags = clone_flags;
 723 #else
 724   CHECK_EQ(0, clone_flags);
 725 #endif  // OS_LINUX
 726   EXPECT_TRUE(base::LaunchProcess(args, options, NULL));
 727   PCHECK(HANDLE_EINTR(close(fds[1])) == 0);
 728
 729   char buf[512];
 730   const ssize_t n = HANDLE_EINTR(read(fds[0], buf, sizeof(buf)));
 731   PCHECK(n > 0);
 732
 733   PCHECK(HANDLE_EINTR(close(fds[0])) == 0);
 734
 735   return std::string(buf, n);
 736 }
 737
 738 const char kLargeString[] =
 739     "0123456789012345678901234567890123456789012345678901234567890123456789"
 740     "0123456789012345678901234567890123456789012345678901234567890123456789"
 741     "0123456789012345678901234567890123456789012345678901234567890123456789"
 742     "0123456789012345678901234567890123456789012345678901234567890123456789"
 743     "0123456789012345678901234567890123456789012345678901234567890123456789"
 744     "0123456789012345678901234567890123456789012345678901234567890123456789"
 745     "0123456789012345678901234567890123456789012345678901234567890123456789";
 746
 747 }  // namespace
 748
 749 TEST_F(ProcessUtilTest, LaunchProcess) {
 750   base::EnvironmentVector env_changes;
 751   const int no_clone_flags = 0;
 752
 753   env_changes.push_back(std::make_pair(std::string("BASE_TEST"),
 754                                        std::string("bar")));
 755   EXPECT_EQ("bar\n", TestLaunchProcess(env_changes, no_clone_flags));
 756   env_changes.clear();
 757
 758   EXPECT_EQ(0, setenv("BASE_TEST", "testing", 1 /* override */));
 759   EXPECT_EQ("testing\n", TestLaunchProcess(env_changes, no_clone_flags));
 760
 761   env_changes.push_back(
 762       std::make_pair(std::string("BASE_TEST"), std::string()));
 763   EXPECT_EQ("\n", TestLaunchProcess(env_changes, no_clone_flags));
 764
 765   env_changes[0].second = "foo";
 766   EXPECT_EQ("foo\n", TestLaunchProcess(env_changes, no_clone_flags));
 767
 768   env_changes.clear();
 769   EXPECT_EQ(0, setenv("BASE_TEST", kLargeString, 1 /* override */));
 770   EXPECT_EQ(std::string(kLargeString) + "\n",
 771             TestLaunchProcess(env_changes, no_clone_flags));
 772
 773   env_changes.push_back(std::make_pair(std::string("BASE_TEST"),
 774                                        std::string("wibble")));
 775   EXPECT_EQ("wibble\n", TestLaunchProcess(env_changes, no_clone_flags));
 776
 777 #if defined(OS_LINUX)
 778   // Test a non-trival value for clone_flags.
 779   // Don't test on Valgrind as it has limited support for clone().
 780   if (!RunningOnValgrind()) {
 781     EXPECT_EQ("wibble\n", TestLaunchProcess(env_changes, CLONE_FS | SIGCHLD));
 782   }
 783 #endif
 784 }
 785
 786 TEST_F(ProcessUtilTest, AlterEnvironment) {
 787   const char* const empty[] = { NULL };
 788   const char* const a2[] = { "A=2", NULL };
 789   base::EnvironmentVector changes;
 790   char** e;
 791
 792   e = base::AlterEnvironment(changes, empty);
 793   EXPECT_TRUE(e[0] == NULL);
 794   delete[] e;
 795
 796   changes.push_back(std::make_pair(std::string("A"), std::string("1")));
 797   e = base::AlterEnvironment(changes, empty);
 798   EXPECT_EQ(std::string("A=1"), e[0]);
 799   EXPECT_TRUE(e[1] == NULL);
 800   delete[] e;
 801
 802   changes.clear();
 803   changes.push_back(std::make_pair(std::string("A"), std::string()));
 804   e = base::AlterEnvironment(changes, empty);
 805   EXPECT_TRUE(e[0] == NULL);
 806   delete[] e;
 807
 808   changes.clear();
 809   e = base::AlterEnvironment(changes, a2);
 810   EXPECT_EQ(std::string("A=2"), e[0]);
 811   EXPECT_TRUE(e[1] == NULL);
 812   delete[] e;
 813
 814   changes.clear();
 815   changes.push_back(std::make_pair(std::string("A"), std::string("1")));
 816   e = base::AlterEnvironment(changes, a2);
 817   EXPECT_EQ(std::string("A=1"), e[0]);
 818   EXPECT_TRUE(e[1] == NULL);
 819   delete[] e;
 820
 821   changes.clear();
 822   changes.push_back(std::make_pair(std::string("A"), std::string()));
 823   e = base::AlterEnvironment(changes, a2);
 824   EXPECT_TRUE(e[0] == NULL);
 825   delete[] e;
 826 }
 827
 828 TEST_F(ProcessUtilTest, GetAppOutput) {
 829   std::string output;
 830
 831 #if defined(OS_ANDROID)
 832   std::vector<std::string> argv;
 833   argv.push_back("sh");  // Instead of /bin/sh, force path search to find it.
 834   argv.push_back("-c");
 835
 836   argv.push_back("exit 0");
 837   EXPECT_TRUE(base::GetAppOutput(CommandLine(argv), &output));
 838   EXPECT_STREQ("", output.c_str());
 839
 840   argv[2] = "exit 1";
 841   EXPECT_FALSE(base::GetAppOutput(CommandLine(argv), &output));
 842   EXPECT_STREQ("", output.c_str());
 843
 844   argv[2] = "echo foobar42";
 845   EXPECT_TRUE(base::GetAppOutput(CommandLine(argv), &output));
 846   EXPECT_STREQ("foobar42\n", output.c_str());
 847 #else
 848   EXPECT_TRUE(base::GetAppOutput(CommandLine(FilePath("true")), &output));
 849   EXPECT_STREQ("", output.c_str());
 850
 851   EXPECT_FALSE(base::GetAppOutput(CommandLine(FilePath("false")), &output));
 852
 853   std::vector<std::string> argv;
 854   argv.push_back("/bin/echo");
 855   argv.push_back("-n");
 856   argv.push_back("foobar42");
 857   EXPECT_TRUE(base::GetAppOutput(CommandLine(argv), &output));
 858   EXPECT_STREQ("foobar42", output.c_str());
 859 #endif  // defined(OS_ANDROID)
 860 }
 861
 862 TEST_F(ProcessUtilTest, GetAppOutputRestricted) {
 863   // Unfortunately, since we can't rely on the path, we need to know where
 864   // everything is. So let's use /bin/sh, which is on every POSIX system, and
 865   // its built-ins.
 866   std::vector<std::string> argv;
 867   argv.push_back(std::string(kShellPath));  // argv[0]
 868   argv.push_back("-c");  // argv[1]
 869
 870   // On success, should set |output|. We use |/bin/sh -c 'exit 0'| instead of
 871   // |true| since the location of the latter may be |/bin| or |/usr/bin| (and we
 872   // need absolute paths).
 873   argv.push_back("exit 0");   // argv[2]; equivalent to "true"
 874   std::string output = "abc";
 875   EXPECT_TRUE(base::GetAppOutputRestricted(CommandLine(argv), &output, 100));
 876   EXPECT_STREQ("", output.c_str());
 877
 878   argv[2] = "exit 1";  // equivalent to "false"
 879   output = "before";
 880   EXPECT_FALSE(base::GetAppOutputRestricted(CommandLine(argv),
 881                                             &output, 100));
 882   EXPECT_STREQ("", output.c_str());
 883
 884   // Amount of output exactly equal to space allowed.
 885   argv[2] = "echo 123456789";  // (the sh built-in doesn't take "-n")
 886   output.clear();
 887   EXPECT_TRUE(base::GetAppOutputRestricted(CommandLine(argv), &output, 10));
 888   EXPECT_STREQ("123456789\n", output.c_str());
 889
 890   // Amount of output greater than space allowed.
 891   output.clear();
 892   EXPECT_TRUE(base::GetAppOutputRestricted(CommandLine(argv), &output, 5));
 893   EXPECT_STREQ("12345", output.c_str());
 894
 895   // Amount of output less than space allowed.
 896   output.clear();
 897   EXPECT_TRUE(base::GetAppOutputRestricted(CommandLine(argv), &output, 15));
 898   EXPECT_STREQ("123456789\n", output.c_str());
 899
 900   // Zero space allowed.
 901   output = "abc";
 902   EXPECT_TRUE(base::GetAppOutputRestricted(CommandLine(argv), &output, 0));
 903   EXPECT_STREQ("", output.c_str());
 904 }
 905
 906 #if !defined(OS_MACOSX) && !defined(OS_OPENBSD)
 907 // TODO(benwells): GetAppOutputRestricted should terminate applications
 908 // with SIGPIPE when we have enough output. http://crbug.com/88502
 909 TEST_F(ProcessUtilTest, GetAppOutputRestrictedSIGPIPE) {
 910   std::vector<std::string> argv;
 911   std::string output;
 912
 913   argv.push_back(std::string(kShellPath));  // argv[0]
 914   argv.push_back("-c");
 915 #if defined(OS_ANDROID)
 916   argv.push_back("while echo 12345678901234567890; do :; done");
 917   EXPECT_TRUE(base::GetAppOutputRestricted(CommandLine(argv), &output, 10));
 918   EXPECT_STREQ("1234567890", output.c_str());
 919 #else
 920   argv.push_back("yes");
 921   EXPECT_TRUE(base::GetAppOutputRestricted(CommandLine(argv), &output, 10));
 922   EXPECT_STREQ("y\ny\ny\ny\ny\n", output.c_str());
 923 #endif
 924 }
 925 #endif
 926
 927 TEST_F(ProcessUtilTest, GetAppOutputRestrictedNoZombies) {
 928   std::vector<std::string> argv;
 929
 930   argv.push_back(std::string(kShellPath));  // argv[0]
 931   argv.push_back("-c");  // argv[1]
 932   argv.push_back("echo 123456789012345678901234567890");  // argv[2]
 933
 934   // Run |GetAppOutputRestricted()| 300 (> default per-user processes on Mac OS
 935   // 10.5) times with an output buffer big enough to capture all output.
 936   for (int i = 0; i < 300; i++) {
 937     std::string output;
 938     EXPECT_TRUE(base::GetAppOutputRestricted(CommandLine(argv), &output, 100));
 939     EXPECT_STREQ("123456789012345678901234567890\n", output.c_str());
 940   }
 941
 942   // Ditto, but with an output buffer too small to capture all output.
 943   for (int i = 0; i < 300; i++) {
 944     std::string output;
 945     EXPECT_TRUE(base::GetAppOutputRestricted(CommandLine(argv), &output, 10));
 946     EXPECT_STREQ("1234567890", output.c_str());
 947   }
 948 }
 949
 950 TEST_F(ProcessUtilTest, GetAppOutputWithExitCode) {
 951   // Test getting output from a successful application.
 952   std::vector<std::string> argv;
 953   std::string output;
 954   int exit_code;
 955   argv.push_back(std::string(kShellPath));  // argv[0]
 956   argv.push_back("-c");  // argv[1]
 957   argv.push_back("echo foo");  // argv[2];
 958   EXPECT_TRUE(base::GetAppOutputWithExitCode(CommandLine(argv), &output,
 959                                              &exit_code));
 960   EXPECT_STREQ("foo\n", output.c_str());
 961   EXPECT_EQ(exit_code, 0);
 962
 963   // Test getting output from an application which fails with a specific exit
 964   // code.
 965   output.clear();
 966   argv[2] = "echo foo; exit 2";
 967   EXPECT_TRUE(base::GetAppOutputWithExitCode(CommandLine(argv), &output,
 968                                              &exit_code));
 969   EXPECT_STREQ("foo\n", output.c_str());
 970   EXPECT_EQ(exit_code, 2);
 971 }
 972
 973 TEST_F(ProcessUtilTest, GetParentProcessId) {
 974   base::ProcessId ppid = base::GetParentProcessId(base::GetCurrentProcId());
 975   EXPECT_EQ(ppid, getppid());
 976 }
 977
 978 #if defined(OS_LINUX) || defined(OS_ANDROID)
 979 TEST_F(ProcessUtilTest, ParseProcStatCPU) {
 980   // /proc/self/stat for a process running "top".
 981   const char kTopStat[] = "960 (top) S 16230 960 16230 34818 960 "
 982       "4202496 471 0 0 0 "
 983       "12 16 0 0 "  // <- These are the goods.
 984       "20 0 1 0 121946157 15077376 314 18446744073709551615 4194304 "
 985       "4246868 140733983044336 18446744073709551615 140244213071219 "
 986       "0 0 0 138047495 0 0 0 17 1 0 0 0 0 0";
 987   EXPECT_EQ(12 + 16, base::ParseProcStatCPU(kTopStat));
 988
 989   // cat /proc/self/stat on a random other machine I have.
 990   const char kSelfStat[] = "5364 (cat) R 5354 5364 5354 34819 5364 "
 991       "0 142 0 0 0 "
 992       "0 0 0 0 "  // <- No CPU, apparently.
 993       "16 0 1 0 1676099790 2957312 114 4294967295 134512640 134528148 "
 994       "3221224832 3221224344 3086339742 0 0 0 0 0 0 0 17 0 0 0";
 995
 996   EXPECT_EQ(0, base::ParseProcStatCPU(kSelfStat));
 997 }
 998
 999 // Disable on Android because base_unittests runs inside a Dalvik VM that
1000 // starts and stop threads (crbug.com/175563).
1001 #if !defined(OS_ANDROID)
1002 TEST_F(ProcessUtilTest, GetNumberOfThreads) {
1003   const base::ProcessHandle current = base::GetCurrentProcessHandle();
1004   const int initial_threads = base::GetNumberOfThreads(current);
1005   ASSERT_GT(initial_threads, 0);
1006   const int kNumAdditionalThreads = 10;
1007   {
1008     scoped_ptr<base::Thread> my_threads[kNumAdditionalThreads];
1009     for (int i = 0; i < kNumAdditionalThreads; ++i) {
1010       my_threads[i].reset(new base::Thread("GetNumberOfThreadsTest"));
1011       my_threads[i]->Start();
1012       ASSERT_EQ(base::GetNumberOfThreads(current), initial_threads + 1 + i);
1013     }
1014   }
1015   // The Thread destructor will stop them.
1016   ASSERT_EQ(initial_threads, base::GetNumberOfThreads(current));
1017 }
1018 #endif  // !defined(OS_ANDROID)
1019
1020 #endif  // defined(OS_LINUX) || defined(OS_ANDROID)
1021
1022 // TODO(port): port those unit tests.
1023 bool IsProcessDead(base::ProcessHandle child) {
1024   // waitpid() will actually reap the process which is exactly NOT what we
1025   // want to test for.  The good thing is that if it can't find the process
1026   // we'll get a nice value for errno which we can test for.
1027   const pid_t result = HANDLE_EINTR(waitpid(child, NULL, WNOHANG));
1028   return result == -1 && errno == ECHILD;
1029 }
1030
1031 TEST_F(ProcessUtilTest, DelayedTermination) {
1032   base::ProcessHandle child_process =
1033       SpawnChild("process_util_test_never_die", false);
1034   ASSERT_TRUE(child_process);
1035   base::EnsureProcessTerminated(child_process);
1036   base::WaitForSingleProcess(child_process, base::TimeDelta::FromSeconds(5));
1037
1038   // Check that process was really killed.
1039   EXPECT_TRUE(IsProcessDead(child_process));
1040   base::CloseProcessHandle(child_process);
1041 }
1042
1043 MULTIPROCESS_TEST_MAIN(process_util_test_never_die) {
1044   while (1) {
1045     sleep(500);
1046   }
1047   return 0;
1048 }
1049
1050 TEST_F(ProcessUtilTest, ImmediateTermination) {
1051   base::ProcessHandle child_process =
1052       SpawnChild("process_util_test_die_immediately", false);
1053   ASSERT_TRUE(child_process);
1054   // Give it time to die.
1055   sleep(2);
1056   base::EnsureProcessTerminated(child_process);
1057
1058   // Check that process was really killed.
1059   EXPECT_TRUE(IsProcessDead(child_process));
1060   base::CloseProcessHandle(child_process);
1061 }
1062
1063 MULTIPROCESS_TEST_MAIN(process_util_test_die_immediately) {
1064   return 0;
1065 }
1066
1067 #endif  // defined(OS_POSIX)
1068
1069 // Android doesn't implement set_new_handler, so we can't use the
1070 // OutOfMemoryTest cases.
1071 // OpenBSD does not support these tests either.
1072 // AddressSanitizer and ThreadSanitizer define the malloc()/free()/etc.
1073 // functions so that they don't crash if the program is out of memory, so the
1074 // OOM tests aren't supposed to work.
1075 // TODO(vandebo) make this work on Windows too.
1076 #if !defined(OS_ANDROID) && !defined(OS_OPENBSD) && \
1077     !defined(OS_WIN) && \
1078     !defined(ADDRESS_SANITIZER) && !defined(THREAD_SANITIZER)
1079
1080 #if defined(USE_TCMALLOC)
1081 extern "C" {
1082 int tc_set_new_mode(int mode);
1083 }
1084 #endif  // defined(USE_TCMALLOC)
1085
1086 class OutOfMemoryDeathTest : public testing::Test {
1087  public:
1088   OutOfMemoryDeathTest()
1089       : value_(NULL),
1090         // Make test size as large as possible minus a few pages so
1091         // that alignment or other rounding doesn't make it wrap.
1092         test_size_(std::numeric_limits<std::size_t>::max() - 12 * 1024),
1093         signed_test_size_(std::numeric_limits<ssize_t>::max()) {
1094   }
1095
1096 #if defined(USE_TCMALLOC)
1097   virtual void SetUp() OVERRIDE {
1098     tc_set_new_mode(1);
1099   }
1100
1101   virtual void TearDown() OVERRIDE {
1102     tc_set_new_mode(0);
1103   }
1104 #endif  // defined(USE_TCMALLOC)
1105
1106   void SetUpInDeathAssert() {
1107     // Must call EnableTerminationOnOutOfMemory() because that is called from
1108     // chrome's main function and therefore hasn't been called yet.
1109     // Since this call may result in another thread being created and death
1110     // tests shouldn't be started in a multithread environment, this call
1111     // should be done inside of the ASSERT_DEATH.
1112     base::EnableTerminationOnOutOfMemory();
1113   }
1114
1115   void* value_;
1116   size_t test_size_;
1117   ssize_t signed_test_size_;
1118 };
1119
1120 TEST_F(OutOfMemoryDeathTest, New) {
1121   ASSERT_DEATH({
1122       SetUpInDeathAssert();
1123       value_ = operator new(test_size_);
1124     }, "");
1125 }
1126
1127 TEST_F(OutOfMemoryDeathTest, NewArray) {
1128   ASSERT_DEATH({
1129       SetUpInDeathAssert();
1130       value_ = new char[test_size_];
1131     }, "");
1132 }
1133
1134 TEST_F(OutOfMemoryDeathTest, Malloc) {
1135   ASSERT_DEATH({
1136       SetUpInDeathAssert();
1137       value_ = malloc(test_size_);
1138     }, "");
1139 }
1140
1141 TEST_F(OutOfMemoryDeathTest, Realloc) {
1142   ASSERT_DEATH({
1143       SetUpInDeathAssert();
1144       value_ = realloc(NULL, test_size_);
1145     }, "");
1146 }
1147
1148 TEST_F(OutOfMemoryDeathTest, Calloc) {
1149   ASSERT_DEATH({
1150       SetUpInDeathAssert();
1151       value_ = calloc(1024, test_size_ / 1024L);
1152     }, "");
1153 }
1154
1155 TEST_F(OutOfMemoryDeathTest, Valloc) {
1156   ASSERT_DEATH({
1157       SetUpInDeathAssert();
1158       value_ = valloc(test_size_);
1159     }, "");
1160 }
1161
1162 #if defined(OS_LINUX)
1163 TEST_F(OutOfMemoryDeathTest, Pvalloc) {
1164   ASSERT_DEATH({
1165       SetUpInDeathAssert();
1166       value_ = pvalloc(test_size_);
1167     }, "");
1168 }
1169
1170 TEST_F(OutOfMemoryDeathTest, Memalign) {
1171   ASSERT_DEATH({
1172       SetUpInDeathAssert();
1173       value_ = memalign(4, test_size_);
1174     }, "");
1175 }
1176
1177 TEST_F(OutOfMemoryDeathTest, ViaSharedLibraries) {
1178   // g_try_malloc is documented to return NULL on failure. (g_malloc is the
1179   // 'safe' default that crashes if allocation fails). However, since we have
1180   // hopefully overridden malloc, even g_try_malloc should fail. This tests
1181   // that the run-time symbol resolution is overriding malloc for shared
1182   // libraries as well as for our code.
1183   ASSERT_DEATH({
1184       SetUpInDeathAssert();
1185       value_ = g_try_malloc(test_size_);
1186     }, "");
1187 }
1188 #endif  // OS_LINUX
1189
1190 // Android doesn't implement posix_memalign().
1191 #if defined(OS_POSIX) && !defined(OS_ANDROID)
1192 TEST_F(OutOfMemoryDeathTest, Posix_memalign) {
1193   // Grab the return value of posix_memalign to silence a compiler warning
1194   // about unused return values. We don't actually care about the return
1195   // value, since we're asserting death.
1196   ASSERT_DEATH({
1197       SetUpInDeathAssert();
1198       EXPECT_EQ(ENOMEM, posix_memalign(&value_, 8, test_size_));
1199     }, "");
1200 }
1201 #endif  // defined(OS_POSIX) && !defined(OS_ANDROID)
1202
1203 #if defined(OS_MACOSX)
1204
1205 // Purgeable zone tests
1206
1207 TEST_F(OutOfMemoryDeathTest, MallocPurgeable) {
1208   malloc_zone_t* zone = malloc_default_purgeable_zone();
1209   ASSERT_DEATH({
1210       SetUpInDeathAssert();
1211       value_ = malloc_zone_malloc(zone, test_size_);
1212     }, "");
1213 }
1214
1215 TEST_F(OutOfMemoryDeathTest, ReallocPurgeable) {
1216   malloc_zone_t* zone = malloc_default_purgeable_zone();
1217   ASSERT_DEATH({
1218       SetUpInDeathAssert();
1219       value_ = malloc_zone_realloc(zone, NULL, test_size_);
1220     }, "");
1221 }
1222
1223 TEST_F(OutOfMemoryDeathTest, CallocPurgeable) {
1224   malloc_zone_t* zone = malloc_default_purgeable_zone();
1225   ASSERT_DEATH({
1226       SetUpInDeathAssert();
1227       value_ = malloc_zone_calloc(zone, 1024, test_size_ / 1024L);
1228     }, "");
1229 }
1230
1231 TEST_F(OutOfMemoryDeathTest, VallocPurgeable) {
1232   malloc_zone_t* zone = malloc_default_purgeable_zone();
1233   ASSERT_DEATH({
1234       SetUpInDeathAssert();
1235       value_ = malloc_zone_valloc(zone, test_size_);
1236     }, "");
1237 }
1238
1239 TEST_F(OutOfMemoryDeathTest, PosixMemalignPurgeable) {
1240   malloc_zone_t* zone = malloc_default_purgeable_zone();
1241   ASSERT_DEATH({
1242       SetUpInDeathAssert();
1243       value_ = malloc_zone_memalign(zone, 8, test_size_);
1244     }, "");
1245 }
1246
1247 // Since these allocation functions take a signed size, it's possible that
1248 // calling them just once won't be enough to exhaust memory. In the 32-bit
1249 // environment, it's likely that these allocation attempts will fail because
1250 // not enough contiguous address space is available. In the 64-bit environment,
1251 // it's likely that they'll fail because they would require a preposterous
1252 // amount of (virtual) memory.
1253
1254 TEST_F(OutOfMemoryDeathTest, CFAllocatorSystemDefault) {
1255   ASSERT_DEATH({
1256       SetUpInDeathAssert();
1257       while ((value_ =
1258               base::AllocateViaCFAllocatorSystemDefault(signed_test_size_))) {}
1259     }, "");
1260 }
1261
1262 TEST_F(OutOfMemoryDeathTest, CFAllocatorMalloc) {
1263   ASSERT_DEATH({
1264       SetUpInDeathAssert();
1265       while ((value_ =
1266               base::AllocateViaCFAllocatorMalloc(signed_test_size_))) {}
1267     }, "");
1268 }
1269
1270 TEST_F(OutOfMemoryDeathTest, CFAllocatorMallocZone) {
1271   ASSERT_DEATH({
1272       SetUpInDeathAssert();
1273       while ((value_ =
1274               base::AllocateViaCFAllocatorMallocZone(signed_test_size_))) {}
1275     }, "");
1276 }
1277
1278 #if !defined(ARCH_CPU_64_BITS)
1279
1280 // See process_util_unittest_mac.mm for an explanation of why this test isn't
1281 // run in the 64-bit environment.
1282
1283 TEST_F(OutOfMemoryDeathTest, PsychoticallyBigObjCObject) {
1284   ASSERT_DEATH({
1285       SetUpInDeathAssert();
1286       while ((value_ = base::AllocatePsychoticallyBigObjCObject())) {}
1287     }, "");
1288 }
1289
1290 #endif  // !ARCH_CPU_64_BITS
1291 #endif  // OS_MACOSX
1292
1293 #endif  // !defined(OS_ANDROID) && !defined(OS_OPENBSD) &&
1294         // !defined(OS_WIN) && !defined(ADDRESS_SANITIZER)