Move OomKillsMonitor from a single-threaded SequencedWorkerPool to a non-joinable thread.

components/arc/metrics/oom_kills_monitor.cc

 // Copyright 2016 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 "components/arc/metrics/oom_kills_monitor.h"
 
 #include <errno.h>
 #include <fcntl.h>
 #include <stdio.h>
 
@@ skipping 15 matching lines @@
 #include "third_party/re2/src/re2/re2.h"
 #include "third_party/re2/src/re2/stringpiece.h"
 
 namespace arc {
 
 using base::StringPiece;
 
 using base::SequencedWorkerPool;
 using base::TimeDelta;
 
-OomKillsMonitor::OomKillsMonitor()
-    : worker_pool_(
-          new SequencedWorkerPool(1, "oom_kills_monitor")) {}
+namespace {
 
-OomKillsMonitor::~OomKillsMonitor() {
-  Stop();
-}
-
-void OomKillsMonitor::Start() {
-  auto task_runner = worker_pool_->GetTaskRunnerWithShutdownBehavior(
-      SequencedWorkerPool::CONTINUE_ON_SHUTDOWN);
-  task_runner->PostTask(
-      FROM_HERE, base::Bind(&OomKillsMonitor::Run, worker_pool_));
-}
-
-void OomKillsMonitor::Stop() {
-  worker_pool_->Shutdown();
-}
-
-namespace {
+base::LazyInstance<OomKillsMonitor>::Leaky g_instance =
+    LAZY_INSTANCE_INITIALIZER;
 
 int64_t GetTimestamp(const StringPiece& line) {
   std::vector<StringPiece> fields = base::SplitStringPiece(
       line, ",", base::TRIM_WHITESPACE, base::SPLIT_WANT_ALL);
 
   int64_t timestamp = -1;
   // Timestamp is the third field in a line of /dev/kmsg.
   if (fields.size() < 3 || !base::StringToInt64(fields[2], &timestamp))
     return -1;
   return timestamp;
@@ skipping 81 matching lines @@
 
     if (GetTimeDelta(line, &last_timestamp, &time_delta)) {
       UMA_HISTOGRAM_OOM_KILL_TIME_INTERVAL(
           "Arc.LowMemoryKiller.TimeDelta", time_delta);
     }
   }
 }
 
 }  // namespace
 
+OomKillsMonitor::OomKillsMonitorHandle::OomKillsMonitorHandle(
+    OomKillsMonitor* outer) : outer_(outer) { DCHECK(outer_); }
+
+OomKillsMonitor::OomKillsMonitorHandle::~OomKillsMonitorHandle() {
+  outer_->is_shutting_down_.Set();
+}
+
+OomKillsMonitor::OomKillsMonitor()
+    : worker_thread_("oom_kills_monitor") {}
+
 // static
-void OomKillsMonitor::Run(
-    scoped_refptr<base::SequencedWorkerPool> worker_pool) {
+void OomKillsMonitor::StartMonitoring() {
+  OomKillsMonitor* instance = g_instance.Pointer();
+
+  DCHECK(!instance->IsRunning());
+
+  base::Thread::Options thread_options;
+  thread_options.joinable = false;
+  instance->StartWithOptions(thread_options);
+}

[Luis Héctor Chávez, 2016/08/01 15:48:14]

return OomKillsMonitorHandle(instance); ?

[gab, 2016/08/04 22:42:36]

Yea I was trying to do this on my Windows machine... clearly a failure looking
at the bots. Sprung up my CrOS build on Linux now :-)

+
+void OomKillsMonitor::Run() {
   base::ScopedFILE kmsg_handle(
       base::OpenFile(base::FilePath("/dev/kmsg"), "r"));
   if (!kmsg_handle) {
     LOG(WARNING) << "Open /dev/kmsg failed: " << base::safe_strerror(errno);
     return;
   }
   // Skip kernel messages prior to the instantiation of this object to avoid
   // double reporting.
   fseek(kmsg_handle.get(), 0, SEEK_END);
 
   static const int kMaxBufSize = 512;
   char buf[kMaxBufSize];
 
   while (fgets(buf, kMaxBufSize, kmsg_handle.get())) {
-    if (worker_pool->IsShutdownInProgress()) {
+    if (is_shutting_down_.IsSet()) {
       DVLOG(1) << "Chrome is shutting down, exit now.";
       break;
     }
     const StringPiece buf_string(buf);
     LogOOMKill(buf_string);
     LogLowMemoryKill(buf_string);
   }
 }
 
 }  // namespace arc