Migrate ProcessesEventRouter to the new task manager

chrome/browser/task_management/providers/web_contents/web_contents_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/web_contents/web_contents_task_provider.h"
 
 #include "base/bind.h"
 #include "base/macros.h"
 #include "base/stl_util.h"
 #include "chrome/browser/task_management/providers/web_contents/subframe_task.h"
 #include "chrome/browser/task_management/providers/web_contents/web_contents_tags_manager.h"
 #include "content/public/browser/render_frame_host.h"
 #include "content/public/browser/render_process_host.h"
+#include "content/public/browser/render_widget_host.h"
 #include "content/public/browser/web_contents.h"
 #include "content/public/browser/web_contents_observer.h"
 
 using content::RenderFrameHost;
+using content::RenderWidgetHost;
 using content::SiteInstance;
 using content::WebContents;
 
 namespace task_management {
 
 // Defines an entry for each WebContents that will be tracked by the provider.
 // The entry is used to observe certain events in its corresponding WebContents
 // and then it notifies the provider or the render task (representing the
 // WebContents) of these events.
 // The entry owns the created tasks representing the WebContents, and it is
@@ skipping 17 matching lines @@
   // entry.
   RendererTask* GetTaskForFrame(RenderFrameHost* render_frame_host) const;
 
   // content::WebContentsObserver:
   void RenderFrameDeleted(RenderFrameHost* render_frame_host) override;
   void RenderFrameHostChanged(RenderFrameHost* old_host,
                               RenderFrameHost* new_host) override;
   void RenderViewReady() override;
   void WebContentsDestroyed() override;
   void RenderProcessGone(base::TerminationStatus status) override;
+  void OnRendererUnresponsive(RenderWidgetHost* render_widget_host) override;
   void DidNavigateMainFrame(
       const content::LoadCommittedDetails& details,
       const content::FrameNavigateParams& params) override;
   void TitleWasSet(content::NavigationEntry* entry, bool explicit_set) override;
 
  private:
   // Defines a callback for WebContents::ForEachFrame() to create a
   // corresponding task for the given |render_frame_host| and notifying the
   // provider's observer of the new task.
   void CreateTaskForFrame(RenderFrameHost* render_frame_host);
@@ skipping 41 matching lines @@
   DCHECK(web_contents()->GetMainFrame());
   web_contents()->ForEachFrame(base::Bind(&WebContentsEntry::CreateTaskForFrame,
                                           base::Unretained(this)));
 }
 
 void WebContentsEntry::ClearAllTasks(bool notify_observer) {
   for (auto& pair : frames_by_site_instance_) {
     FramesList& frames_list = pair.second;
     DCHECK(!frames_list.empty());
     RendererTask* task = tasks_by_frames_[frames_list[0]];
+
+    task->set_termination_status(web_contents()->GetCrashedStatus());
+    task->set_termination_error_code(web_contents()->GetCrashedErrorCode());
+
     if (notify_observer)
       provider_->NotifyObserverTaskRemoved(task);
     delete task;
   }
 
   frames_by_site_instance_.clear();
   tasks_by_frames_.clear();
   main_frame_site_instance_ = nullptr;
 }
 
@@ skipping 23 matching lines @@
 
 void WebContentsEntry::WebContentsDestroyed() {
   ClearAllTasks(true);
   provider_->DeleteEntry(web_contents());
 }
 
 void WebContentsEntry::RenderProcessGone(base::TerminationStatus status) {
   ClearAllTasks(true);
 }
 
+void WebContentsEntry::OnRendererUnresponsive(
+    RenderWidgetHost* render_widget_host) {
+  auto itr = tasks_by_frames_.find(web_contents()->GetMainFrame());
+  if (itr == tasks_by_frames_.end())
+    return;
+
+  DCHECK_EQ(render_widget_host->GetProcess(),
+            web_contents()->GetMainFrame()->GetProcess());
+
+  provider_->NotifyObserverTaskUnresponsive(itr->second);
+}
+
 void WebContentsEntry::DidNavigateMainFrame(
     const content::LoadCommittedDetails& details,
     const content::FrameNavigateParams& params) {
   auto itr = tasks_by_frames_.find(web_contents()->GetMainFrame());
   if (itr == tasks_by_frames_.end()) {
     // TODO(afakhry): Validate whether this actually happens in practice.
     NOTREACHED();
     return;
   }
 
@@ skipping 208 matching lines @@
 
   WebContentsEntry* entry = itr->second;
   entries_map_.erase(itr);
 
   // The entry we're about to delete is our caller, however its' still fine to
   // delete it.
   delete entry;
 }
 
 }  // namespace task_management