Fail all started requests if the utility process crashes or fails to start.

chrome/browser/image_decoder.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 "chrome/browser/image_decoder.h"
 
 #include "base/bind.h"
 #include "base/thread_task_runner_handle.h"
 #include "chrome/browser/browser_process.h"
 #include "chrome/common/chrome_utility_messages.h"
@@ skipping 159 matching lines @@
   if ((base::TimeTicks::Now() - last_request_)
       < base::TimeDelta::FromSeconds(kBatchModeTimeoutSeconds)) {
     return;
   }
 
   if (utility_process_host_) {
     utility_process_host_->EndBatchMode();
     utility_process_host_.reset();
   }
   batch_mode_timer_.Stop();
+
+  // There could be outstanding request that are taking too long. Fail these so
+  // that there aren't any dangling requests.
+  FailAllRequests();
+}
+
+void ImageDecoder::FailAllRequests() {
+  RequestMap requests;
+  {
+    base::AutoLock lock(map_lock_);
+    requests = image_request_id_map_;
+  }
+
+  // Since |OnProcessCrashed| and |OnProcessLaunchFailed| are run asynchronously
+  // from the actual event, it's possible for a new utility process to have been
+  // created and sent requests by the time these functions are run. This results
+  // in failing requests that are unaffected by the crash. Although not ideal,
+  // this is valid and simpler than tracking which request is sent to which
+  // utility process, and whether the request has been sent at all.
+  for (const auto& request : requests)
+    OnDecodeImageFailed(request.first);
+}
+
+void ImageDecoder::OnProcessCrashed(int exit_code) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  FailAllRequests();
+}
+
+void ImageDecoder::OnProcessLaunchFailed() {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  FailAllRequests();
 }
 
 bool ImageDecoder::OnMessageReceived(
     const IPC::Message& message) {
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(ImageDecoder, message)
     IPC_MESSAGE_HANDLER(ChromeUtilityHostMsg_DecodeImage_Succeeded,
                         OnDecodeImageSucceeded)
     IPC_MESSAGE_HANDLER(ChromeUtilityHostMsg_DecodeImage_Failed,
                         OnDecodeImageFailed)
@@ skipping 56 matching lines @@
     auto it = image_request_id_map_.find(request_id);
     if (it == image_request_id_map_.end())
       return;
     image_request = it->second;
     image_request_id_map_.erase(it);
   }
 
   DCHECK(image_request->task_runner()->RunsTasksOnCurrentThread());
   image_request->OnDecodeImageFailed();
 }