[Chromecast] Remove usage of nonreentrant functions.

chromecast/crash/linux/synchronized_minidump_manager_unittest.cc

 // Copyright 2015 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 "chromecast/crash/linux/synchronized_minidump_manager.h"
 
 #include <fcntl.h>
 #include <stdint.h>
 #include <stdio.h>  // perror
 #include <stdlib.h>
@@ skipping 239 matching lines @@
 
   // Verify the lockfile is untouched.
   ScopedVector<DumpInfo> dumps;
   ASSERT_TRUE(FetchDumps(lockfile_.value(), &dumps));
   ASSERT_EQ(0u, dumps.size());
 }
 
 TEST_F(SynchronizedMinidumpManagerTest,
        AddEntryToLockFile_SucceedsWithValidEntries) {
   // Sample parameters.
-  time_t now = time(0);
+  base::Time now = base::Time::Now();
   MinidumpParams params;
   params.process_name = "process";
 
   // Write the first entry.
   SynchronizedMinidumpManagerSimple manager;
   manager.SetDumpInfoToWrite(
       base::WrapUnique(new DumpInfo("dump1", "log1", now, params)));
   ASSERT_EQ(0, manager.DoWorkLocked());
   ASSERT_EQ(0, manager.add_entry_return_code());
 
   // Test that the manager was successful in logging the entry.
   ScopedVector<DumpInfo> dumps;
   ASSERT_TRUE(FetchDumps(lockfile_.value(), &dumps));
   ASSERT_EQ(1u, dumps.size());
 
   // Write the second entry.
   manager.SetDumpInfoToWrite(
       base::WrapUnique(new DumpInfo("dump2", "log2", now, params)));
   ASSERT_EQ(0, manager.DoWorkLocked());
   ASSERT_EQ(0, manager.add_entry_return_code());
 
   // Test that the second entry is also valid.
   ASSERT_TRUE(FetchDumps(lockfile_.value(), &dumps));
   ASSERT_EQ(2u, dumps.size());
 }
 
 TEST_F(SynchronizedMinidumpManagerTest,
-       AcquireLockFile_FailsWhenNonBlockingAndFileLocked) {
-  ASSERT_TRUE(CreateFiles(lockfile_.value(), metadata_.value()));
-  // Lock the lockfile here. Note that the Chromium base::File tools permit
-  // multiple locks on the same process to succeed, so we must use POSIX system
-  // calls to accomplish this.
-  int fd = open(lockfile_.value().c_str(), O_RDWR | O_CREAT, 0660);
-  ASSERT_GE(fd, 0);
-  ASSERT_EQ(0, flock(fd, LOCK_EX));
-
-  SynchronizedMinidumpManagerSimple manager;
-  manager.set_non_blocking(true);
-  ASSERT_EQ(-1, manager.DoWorkLocked());
-  ASSERT_FALSE(manager.work_done());
-
-  // Test that the manager was not able to log the crash dump.
-  ScopedVector<DumpInfo> dumps;
-  ASSERT_TRUE(FetchDumps(lockfile_.value(), &dumps));
-  ASSERT_EQ(0u, dumps.size());
-}
-
-TEST_F(SynchronizedMinidumpManagerTest,
        AcquireLockFile_WaitsForOtherThreadWhenBlocking) {
   // Create some parameters for a minidump.
-  time_t now = time(0);
+  base::Time now = base::Time::Now();
   MinidumpParams params;
   params.process_name = "process";
 
   // Create a manager that grabs the lock then sleeps. Post a DoWork task to
   // another thread. |sleepy_manager| will grab the lock and hold it for
   // |sleep_time_ms|. It will then write a dump and release the lock.
   const int sleep_time_ms = 100;
   SleepySynchronizedMinidumpManagerSimple sleepy_manager(sleep_time_ms);
   sleepy_manager.SetDumpInfoToWrite(
       base::WrapUnique(new DumpInfo("dump", "log", now, params)));
   base::Thread sleepy_thread("sleepy");
   sleepy_thread.Start();
   sleepy_thread.task_runner()->PostTask(
       FROM_HERE,
       base::Bind(&DoWorkLockedTask, base::Unretained(&sleepy_manager)));
 
   // Meanwhile, this thread should wait brielfy to allow the other thread to
   // grab the lock.
   const int concurrency_delay = 50;
   base::PlatformThread::Sleep(
       base::TimeDelta::FromMilliseconds(concurrency_delay));
 
   // |sleepy_manager| has the lock by now, but has not released it. Attempt to
   // grab it. DoWorkLocked() should block until |manager| has a chance to write
   // the dump.
   SynchronizedMinidumpManagerSimple manager;
   manager.SetDumpInfoToWrite(
       base::WrapUnique(new DumpInfo("dump", "log", now, params)));
-  manager.set_non_blocking(false);
 
   EXPECT_EQ(0, manager.DoWorkLocked());
   EXPECT_EQ(0, manager.add_entry_return_code());
   EXPECT_TRUE(manager.work_done());
 
   // Check that the other manager was also successful.
   EXPECT_EQ(0, sleepy_manager.add_entry_return_code());
   EXPECT_TRUE(sleepy_manager.work_done());
 
   // Test that both entries were logged.
   ScopedVector<DumpInfo> dumps;
   ASSERT_TRUE(FetchDumps(lockfile_.value(), &dumps));
   EXPECT_EQ(2u, dumps.size());
 }
 
 // TODO(slan): These tests are passing but forking them is creating duplicates
 // of all tests in this thread. Figure out how to lock the file more cleanly
 // from another process.
 TEST_F(SynchronizedMinidumpManagerTest,
-       DISABLED_AcquireLockFile_FailsWhenNonBlockingAndLockedFromOtherProcess) {
-  // Fork the process.
-  pid_t pid = base::ForkWithFlags(0u, nullptr, nullptr);
-  if (pid != 0) {
-    // The child process should instantiate a manager which immediately grabs
-    // the lock, and falls aleep for some period of time, then writes a dump,
-    // and finally releases the lock.
-    SleepySynchronizedMinidumpManagerSimple sleepy_manager(100);
-    ASSERT_EQ(0, sleepy_manager.DoWorkLocked());
-    ASSERT_TRUE(sleepy_manager.work_done());
-    return;
-  }
-
-  // Meanwhile, this process should wait brielfy to allow the other thread to
-  // grab the lock.
-  base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(50));
-
-  SynchronizedMinidumpManagerSimple manager;
-  manager.set_non_blocking(true);
-  ASSERT_EQ(-1, manager.DoWorkLocked());
-  ASSERT_FALSE(manager.work_done());
-
-  // Test that the manager was not able to log the crash dump.
-  ScopedVector<DumpInfo> dumps;
-  ASSERT_TRUE(FetchDumps(lockfile_.value(), &dumps));
-  ASSERT_EQ(0u, dumps.size());
-}
-
-// TODO(slan): These tests are passing but forking them is creating duplicates
-// of all tests in this thread. Figure out how to lock the file more cleanly
-// from another process.
-TEST_F(SynchronizedMinidumpManagerTest,
        DISABLED_AcquireLockFile_WaitsForOtherProcessWhenBlocking) {
   // Create some parameters for a minidump.
-  time_t now = time(0);
+  base::Time now = base::Time::Now();
   MinidumpParams params;
   params.process_name = "process";
 
   // Fork the process.
   pid_t pid = base::ForkWithFlags(0u, nullptr, nullptr);
   if (pid != 0) {
     // The child process should instantiate a manager which immediately grabs
     // the lock, and falls aleep for some period of time, then writes a dump,
     // and finally releases the lock.
     SleepySynchronizedMinidumpManagerSimple sleepy_manager(100);
     sleepy_manager.SetDumpInfoToWrite(
         base::WrapUnique(new DumpInfo("dump", "log", now, params)));
     ASSERT_EQ(0, sleepy_manager.DoWorkLocked());
     ASSERT_TRUE(sleepy_manager.work_done());
     return;
   }
 
   // Meanwhile, this process should wait brielfy to allow the other thread to
   // grab the lock.
   const int concurrency_delay = 50;
   base::PlatformThread::Sleep(
       base::TimeDelta::FromMilliseconds(concurrency_delay));
 
   // |sleepy_manager| has the lock by now, but has not released it. Attempt to
   // grab it. DoWorkLocked() should block until |manager| has a chance to write
   // the dump.
   SynchronizedMinidumpManagerSimple manager;
   manager.SetDumpInfoToWrite(
       base::WrapUnique(new DumpInfo("dump", "log", now, params)));
-  manager.set_non_blocking(false);
 
   EXPECT_EQ(0, manager.DoWorkLocked());
   EXPECT_EQ(0, manager.add_entry_return_code());
   EXPECT_TRUE(manager.work_done());
 
   // Test that both entries were logged.
   ScopedVector<DumpInfo> dumps;
   ASSERT_TRUE(FetchDumps(lockfile_.value(), &dumps));
   EXPECT_EQ(2u, dumps.size());
 }
 
 TEST_F(SynchronizedMinidumpManagerTest,
        Upload_SucceedsWhenDumpLimitsNotExceeded) {
   // Sample parameters.
-  time_t now = time(0);
+  base::Time now = base::Time::Now();
   MinidumpParams params;
   params.process_name = "process";
 
   FakeSynchronizedMinidumpUploader uploader;
   SynchronizedMinidumpManagerSimple producer;
   producer.SetDumpInfoToWrite(
       base::WrapUnique(new DumpInfo("dump1", "log1", now, params)));
 
   const int max_dumps = SynchronizedMinidumpManager::kRatelimitPeriodMaxDumps;
   produce_dumps(producer, max_dumps);
   consume_dumps(uploader, max_dumps);
 }
 
 TEST_F(SynchronizedMinidumpManagerTest, Upload_FailsWhenTooManyRecentDumps) {
   // Sample parameters.
-  time_t now = time(0);
+  base::Time now = base::Time::Now();
   MinidumpParams params;
   params.process_name = "process";
 
   FakeSynchronizedMinidumpUploader uploader;
   SynchronizedMinidumpManagerSimple producer;
   producer.SetDumpInfoToWrite(
       base::WrapUnique(new DumpInfo("dump1", "log1", now, params)));
 
   const int max_dumps = SynchronizedMinidumpManager::kRatelimitPeriodMaxDumps;
   produce_dumps(producer, max_dumps + 1);
   consume_dumps(uploader, max_dumps);
 
   // Should fail with too many dumps
   ASSERT_EQ(0, uploader.DoWorkLocked());
   ASSERT_FALSE(uploader.can_upload_return_val());
 }
 
 TEST_F(SynchronizedMinidumpManagerTest, UploadSucceedsAfterRateLimitPeriodEnd) {
   // Sample parameters.
-  time_t now = time(0);
+  base::Time now = base::Time::Now();
   MinidumpParams params;
   params.process_name = "process";
 
   FakeSynchronizedMinidumpUploader uploader;
   SynchronizedMinidumpManagerSimple producer;
   producer.SetDumpInfoToWrite(
       base::WrapUnique(new DumpInfo("dump1", "log1", now, params)));
 
   const int iters = 3;
   const int max_dumps = SynchronizedMinidumpManager::kRatelimitPeriodMaxDumps;
 
   for (int i = 0; i < iters; ++i) {
     produce_dumps(producer, max_dumps + 1);
     consume_dumps(uploader, max_dumps);
 
     // Should fail with too many dumps
     ASSERT_EQ(0, uploader.DoWorkLocked());
     ASSERT_FALSE(uploader.can_upload_return_val());
 
     int64_t period = SynchronizedMinidumpManager::kRatelimitPeriodSeconds;
+    time_t now_time_t = now.ToTimeT();
 
     // Half period shouldn't trigger reset
     produce_dumps(producer, 1);
-    SetRatelimitPeriodStart(metadata_.value(), now - period / 2);
+    SetRatelimitPeriodStart(metadata_.value(), now_time_t - period / 2);
     ASSERT_EQ(0, uploader.DoWorkLocked());
     ASSERT_FALSE(uploader.can_upload_return_val());
 
     // Set period starting time to trigger a reset
-    SetRatelimitPeriodStart(metadata_.value(), now - period);
+    SetRatelimitPeriodStart(metadata_.value(), now_time_t - period);
   }
 
   produce_dumps(producer, 1);
   consume_dumps(uploader, 1);
 }
 
 TEST_F(SynchronizedMinidumpManagerTest, HasDumpsWithoutDumps) {
   FakeSynchronizedMinidumpUploader uploader;
   ASSERT_FALSE(uploader.HasDumps());
 }
 
 TEST_F(SynchronizedMinidumpManagerTest, HasDumpsWithDumps) {
   // Sample parameters.
-  time_t now = time(0);
+  base::Time now = base::Time::Now();
   MinidumpParams params;
   params.process_name = "process";
 
   SynchronizedMinidumpManagerSimple producer;
   FakeSynchronizedMinidumpUploader uploader;
 
   producer.SetDumpInfoToWrite(
       base::WrapUnique(new DumpInfo("dump1", "log1", now, params)));
 
   const int kNumDumps = 3;
@@ skipping 18 matching lines @@
   const base::FilePath path =
       base::FilePath(manager.dump_path()).Append("hello123");
   const char kFileContents[] = "foobar";
   ASSERT_EQ(static_cast<int>(sizeof(kFileContents)),
             WriteFile(path, kFileContents, sizeof(kFileContents)));
 
   ASSERT_TRUE(manager.HasDumps());
 }
 
 }  // namespace chromecast