Show all system process in the task_manager.

chrome/browser/task_management/providers/arc/arc_process_task_provider.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 "chrome/browser/task_management/providers/arc/arc_process_task_provider.h"
 
 #include <stddef.h>
 
 #include <queue>
 #include <set>
 #include <utility>
 #include <vector>
 
+#include "base/callback.h"
 #include "base/logging.h"
 #include "base/process/process.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "base/trace_event/trace_event.h"
 #include "chrome/browser/chromeos/arc/arc_process.h"
 #include "chrome/browser/chromeos/arc/arc_process_service.h"
 #include "components/arc/common/process.mojom.h"
 
 namespace task_management {
 
 namespace {
 
-const int kUpdateProcessListDelaySeconds = 1;
+const int kUpdateAppProcessListDelaySeconds = 1;
+const int kUpdateSystemProcessListDelaySeconds = 3;
 
 }  // namespace
 
 using std::set;
 using arc::ArcProcess;
 using base::Process;
 using base::ProcessId;
 
 ArcProcessTaskProvider::ArcProcessTaskProvider()
     : is_updating_(false), weak_ptr_factory_(this) {}
 
 ArcProcessTaskProvider::~ArcProcessTaskProvider() {}
 
 Task* ArcProcessTaskProvider::GetTaskOfUrlRequest(int origin_pid,
                                                   int child_id,
                                                   int route_id) {
   // ARC tasks are not associated with any URL request.
   return nullptr;
 }
 
-void ArcProcessTaskProvider::OnUpdateProcessList(
+void ArcProcessTaskProvider::UpdateProcessList(
+    std::map<base::ProcessId, std::unique_ptr<ArcProcessTask>>& pid_to_task,

[Luis Héctor Chávez, 2016/07/15 16:19:42]

conding guidelines say that parameters should either be const-references or raw
pointers. Make this a pointer since you need to modify it.

[Hsu-Cheng, 2016/07/27 08:08:00]

Done.

     const std::vector<ArcProcess>& processes) {
-  TRACE_EVENT0("browser", "ArcProcessTaskProvider::OnUpdateProcessList");
-
   if (!is_updating_)
     return;
 
   // NB: |processes| can be already stale here because it is sent via IPC, and
   // we can never avoid that. See also the comment at the declaration of
   // ArcProcessTaskProvider.
 
   set<ProcessId> nspid_to_remove;

[Luis Héctor Chávez, 2016/07/15 16:19:42]

std::unordered_set?

[Hsu-Cheng, 2016/07/27 08:07:59]

Done.

-  for (const auto& entry : nspid_to_task_)
+  for (const auto& entry : pid_to_task)
     nspid_to_remove.insert(entry.first);
 
   for (const auto& entry : processes) {
     if (nspid_to_remove.erase(entry.nspid()) == 0) {
       // New arc process.
-      std::unique_ptr<ArcProcessTask>& task = nspid_to_task_[entry.nspid()];
+      std::unique_ptr<ArcProcessTask>& task = pid_to_task[entry.nspid()];

[Luis Héctor Chávez, 2016/07/15 16:19:42]

const? Same in L79

[Hsu-Cheng, 2016/07/27 08:08:00]

'task' invokes reset() below

       // After calling NotifyObserverTaskAdded(), the raw pointer of |task| is
       // remebered somewhere else. One should not (implicitly) delete the
       // referenced object before calling NotifyObserverTaskRemoved() first
       // (crbug.com/587707).
       DCHECK(!task.get()) <<
           "Task with the same pid should not be added twice.";
       task.reset(new ArcProcessTask(entry.pid(), entry.nspid(),
                                     entry.process_name(), entry.process_state(),
                                     entry.packages()));
       NotifyObserverTaskAdded(task.get());
     } else {
       // Update process state of existing process.
-      std::unique_ptr<ArcProcessTask>& task = nspid_to_task_[entry.nspid()];
+      std::unique_ptr<ArcProcessTask>& task = pid_to_task[entry.nspid()];
       DCHECK(task.get());
       task->SetProcessState(entry.process_state());
     }
   }
 
   for (const auto& entry : nspid_to_remove) {
     // Stale arc process.
-    NotifyObserverTaskRemoved(nspid_to_task_[entry].get());
-    nspid_to_task_.erase(entry);
+    NotifyObserverTaskRemoved(pid_to_task[entry].get());
+    pid_to_task.erase(entry);
   }
-  ScheduleNextRequest();
 }
 
-void ArcProcessTaskProvider::RequestProcessList() {
+void ArcProcessTaskProvider::OnUpdateProcessList(
+    std::map<base::ProcessId, std::unique_ptr<ArcProcessTask>>& pid_to_task,
+    const std::vector<ArcProcess>& processes,
+    const base::Closure& scheduler) {
+  TRACE_EVENT0("browser", "ArcProcessTaskProvider::OnUpdateProcessList");
+
+  UpdateProcessList(pid_to_task, processes);
+  scheduler.Run();
+}
+
+void ArcProcessTaskProvider::OnUpdateAppProcessList(
+    const std::vector<ArcProcess>& processes) {
+  OnUpdateProcessList(
+      nspid_to_task_,
+      processes,
+      base::Bind(&ArcProcessTaskProvider::ScheduleNextAppRequest,
+                 weak_ptr_factory_.GetWeakPtr()));

[cylee1, 2016/07/15 23:17:03]

I'm still hesitated that if you need WeakPtr since there's no thread switching.
Unretained(this) is enough?
The same for other places

Also I don't understand why you need to pass in the scheduler since
OnUpdateProcessList is a synchronous function ! Just

OnUpdateProcessList(..,..);
ScheduleNextAppRequest(); 

?

[Hsu-Cheng, 2016/07/27 08:08:00]

Removed the scheduler (and also the WeakPtr)

+}
+
+void ArcProcessTaskProvider::OnUpdateSystemProcessList(
+    const std::vector<ArcProcess>& processes) {
+  OnUpdateProcessList(
+      nspid_to_sys_task_,
+      processes,
+      base::Bind(&ArcProcessTaskProvider::ScheduleNextSystemRequest,
+                 weak_ptr_factory_.GetWeakPtr()));
+}
+
+void ArcProcessTaskProvider::RequestAppProcessList() {
   arc::ArcProcessService* arc_process_service =
       arc::ArcProcessService::Get();
-  auto callback = base::Bind(&ArcProcessTaskProvider::OnUpdateProcessList,
+  auto callback = base::Bind(&ArcProcessTaskProvider::OnUpdateAppProcessList,
                              weak_ptr_factory_.GetWeakPtr());
   if (!arc_process_service ||
-      !arc_process_service->RequestProcessList(callback)) {
+      !arc_process_service->RequestAppProcessList(callback)) {
     VLOG(2) << "ARC process instance is not ready.";
-    // Update with the empty ARC process list.
-    // Note that this can happen in the middle of the session if the user has
-    // just opted out from ARC.
-    callback.Run(std::vector<ArcProcess>());
+    ScheduleNextAppRequest();
+    return;
   }
 }
 
+void ArcProcessTaskProvider::RequestSystemProcessList() {
+  arc::ArcProcessService* arc_process_service =
+      arc::ArcProcessService::Get();
+  auto callback = base::Bind(&ArcProcessTaskProvider::OnUpdateSystemProcessList,

[Luis Héctor Chávez, 2016/07/15 16:19:42]

unused?

[Hsu-Cheng, 2016/07/27 08:07:59]

Done.

+                             weak_ptr_factory_.GetWeakPtr());
+  if (!arc_process_service) {
+    VLOG(2) << "ARC process instance is not ready.";
+    ScheduleNextSystemRequest();
+    return;
+  }
+  arc_process_service->RequestSystemProcessList(

[Luis Héctor Chávez, 2016/07/15 16:19:42]

be consistent: either have both this and RequestAppProcessList() retry when
arc_process_service->RequestXxxProcessList() fails or neither.

[cylee1, 2016/07/15 23:17:03]

RequestSystemProcessList never fail however (returns void). It doesn't talk to
Android via IPC so the failure case is difference ...

[Luis Héctor Chávez, 2016/07/15 23:43:46]

oh sorry, didn't notice that. disregard this then.

[Hsu-Cheng, 2016/07/27 08:08:00]

Acknowledged.

+      base::Bind(&ArcProcessTaskProvider::OnUpdateSystemProcessList,
+                 weak_ptr_factory_.GetWeakPtr()));
+}
+
 void ArcProcessTaskProvider::StartUpdating() {
   is_updating_ = true;
-  RequestProcessList();
+  RequestAppProcessList();
+  RequestSystemProcessList();
 }
 
 void ArcProcessTaskProvider::StopUpdating() {
   is_updating_ = false;
   nspid_to_task_.clear();
+  nspid_to_sys_task_.clear();
 }
 
-void ArcProcessTaskProvider::ScheduleNextRequest() {
+void ArcProcessTaskProvider::ScheduleNextRequest(const base::Closure& task,
+                                                 const int delaySeconds) {
   if (!is_updating_)
     return;
   // TODO(nya): Remove this timer once ARC starts to send us UpdateProcessList
   // message when the process list changed. As of today, ARC does not send
-  // the process list unless we request it by RequestProcessList message.
+  // the process list unless we request it by RequestAppProcessList message.
   base::ThreadTaskRunnerHandle::Get()->PostDelayedTask(
-      FROM_HERE,
-      base::Bind(&ArcProcessTaskProvider::RequestProcessList,
+      FROM_HERE, task, base::TimeDelta::FromSeconds(delaySeconds));
+}
+
+void ArcProcessTaskProvider::ScheduleNextAppRequest() {
+  ScheduleNextRequest(
+      base::Bind(&ArcProcessTaskProvider::RequestAppProcessList,
                  weak_ptr_factory_.GetWeakPtr()),
-      base::TimeDelta::FromSeconds(kUpdateProcessListDelaySeconds));
+      kUpdateAppProcessListDelaySeconds);
+}
+
+void ArcProcessTaskProvider::ScheduleNextSystemRequest() {
+  ScheduleNextRequest(
+      base::Bind(&ArcProcessTaskProvider::RequestSystemProcessList,
+                 weak_ptr_factory_.GetWeakPtr()),
+      kUpdateSystemProcessListDelaySeconds);
 }
 
 }  // namespace task_management