MHTMLGenerationManager handles the death of a render process.

content/browser/download/mhtml_generation_manager.cc

 // Copyright (c) 2012 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 "content/browser/download/mhtml_generation_manager.h"
 
 #include "base/bind.h"
 #include "base/platform_file.h"
 #include "content/browser/renderer_host/render_process_host_impl.h"
 #include "content/browser/renderer_host/render_view_host_impl.h"
@@ skipping 32 matching lines @@
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   static int id_counter = 0;
 
   int job_id = id_counter++;
   Job job;
   job.file_path = file;
   job.process_id = web_contents->GetRenderProcessHost()->GetID();
   job.routing_id = web_contents->GetRenderViewHost()->GetRoutingID();
   job.callback = callback;
   id_to_job_[job_id] = job;
+  if (!registrar_.IsRegistered(
+          this,
+          NOTIFICATION_RENDERER_PROCESS_TERMINATED,
+          Source<RenderProcessHost>(web_contents->GetRenderProcessHost()))) {
+    registrar_.Add(
+        this,
+        NOTIFICATION_RENDERER_PROCESS_TERMINATED,
+        Source<RenderProcessHost>(web_contents->GetRenderProcessHost()));
+  }
 
   base::ProcessHandle renderer_process =
       web_contents->GetRenderProcessHost()->GetHandle();
   BrowserThread::PostTask(BrowserThread::FILE, FROM_HERE,
       base::Bind(&MHTMLGenerationManager::CreateFile, base::Unretained(this),
                  job_id, file, renderer_process));
 }
 
 void MHTMLGenerationManager::MHTMLGenerated(int job_id, int64 mhtml_data_size) {
   JobFinished(job_id, mhtml_data_size);
@@ skipping 66 matching lines @@
                  job.browser_file));
 
   id_to_job_.erase(job_id);
 }
 
 void MHTMLGenerationManager::CloseFile(base::PlatformFile file) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
   base::ClosePlatformFile(file);
 }
 
+void MHTMLGenerationManager::Observe(int type,
+                                     const NotificationSource& source,
+                                     const NotificationDetails& details) {
+  DCHECK(type == NOTIFICATION_RENDERER_PROCESS_TERMINATED);
+  RenderProcessHost* host = Source<RenderProcessHost>(source).ptr();
+  registrar_.Remove(
+      this,
+      NOTIFICATION_RENDERER_PROCESS_TERMINATED,
+      source);
+  std::set<int> job_to_delete;
+  for (IDToJobMap::iterator it = id_to_job_.begin(); it != id_to_job_.end();
+       ++it) {
+    if (it->second.process_id == host->GetID())
+      job_to_delete.insert(it->first);
+  }
+  for (std::set<int>::iterator it = job_to_delete.begin();
+       it != job_to_delete.end();
+       ++it) {
+    JobFinished(*it, -1);
+  }
+}
+
 }  // namespace content