Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "android_webview/browser/aw_browser_terminator.h" | 5 #include "android_webview/browser/aw_browser_terminator.h" |
| 6 | 6 |
| 7 #include <unistd.h> | 7 #include <unistd.h> |
| 8 | 8 |
| 9 #include "android_webview/browser/aw_render_process_gone_delegate.h" | |
| 9 #include "android_webview/common/aw_descriptors.h" | 10 #include "android_webview/common/aw_descriptors.h" |
| 10 #include "base/bind.h" | 11 #include "base/bind.h" |
| 11 #include "base/logging.h" | 12 #include "base/logging.h" |
| 12 #include "base/stl_util.h" | 13 #include "base/stl_util.h" |
| 13 #include "base/sync_socket.h" | 14 #include "base/sync_socket.h" |
| 14 #include "content/public/browser/browser_thread.h" | 15 #include "content/public/browser/browser_thread.h" |
| 15 #include "content/public/browser/child_process_data.h" | 16 #include "content/public/browser/child_process_data.h" |
| 16 #include "content/public/browser/notification_service.h" | 17 #include "content/public/browser/notification_service.h" |
| 17 #include "content/public/browser/notification_types.h" | 18 #include "content/public/browser/notification_types.h" |
| 18 #include "content/public/browser/render_process_host.h" | 19 #include "content/public/browser/render_process_host.h" |
| 20 #include "content/public/browser/render_view_host.h" | |
| 21 #include "content/public/browser/render_widget_host.h" | |
| 22 #include "content/public/browser/render_widget_host_iterator.h" | |
| 23 #include "content/public/browser/web_contents.h" | |
| 19 | 24 |
| 20 using content::BrowserThread; | 25 using content::BrowserThread; |
| 21 | 26 |
| 22 namespace android_webview { | 27 namespace android_webview { |
| 23 | 28 |
| 29 namespace { | |
| 30 | |
| 31 void GetAwRenderProcessGoneDelegatesForRenderProcess( | |
| 32 int render_process_id, | |
| 33 std::vector<AwRenderProcessGoneDelegate*>* delegates) { | |
| 34 content::RenderProcessHost* rph = | |
| 35 content::RenderProcessHost::FromID(render_process_id); | |
| 36 if (!rph) | |
| 37 return; | |
| 38 | |
| 39 std::unique_ptr<content::RenderWidgetHostIterator> widgets( | |
| 40 content::RenderWidgetHost::GetRenderWidgetHosts()); | |
| 41 while (content::RenderWidgetHost* widget = widgets->GetNextHost()) { | |
| 42 content::RenderViewHost* view = content::RenderViewHost::From(widget); | |
| 43 if (view && rph == view->GetProcess()) { | |
| 44 content::WebContents* wc = content::WebContents::FromRenderViewHost(view); | |
| 45 if (wc) { | |
| 46 AwRenderProcessGoneDelegate* delegate = | |
| 47 AwRenderProcessGoneDelegate::FromWebContents(wc); | |
| 48 if (delegate) | |
| 49 delegates->push_back(delegate); | |
| 50 } | |
| 51 } | |
| 52 } | |
| 53 } | |
| 54 | |
| 55 void OnRenderProcessGone(int child_process_id) { | |
| 56 DCHECK_CURRENTLY_ON(BrowserThread::UI); | |
| 57 std::vector<AwRenderProcessGoneDelegate*> delegates; | |
| 58 GetAwRenderProcessGoneDelegatesForRenderProcess(child_process_id, &delegates); | |
| 59 for (auto delegate : delegates) | |
| 60 delegate->OnRenderProcessGone(child_process_id); | |
| 61 } | |
| 62 | |
| 63 void OnRenderProcessGoneDetail(int child_process_id, bool crashed) { | |
| 64 DCHECK_CURRENTLY_ON(BrowserThread::UI); | |
| 65 std::vector<AwRenderProcessGoneDelegate*> delegates; | |
| 66 GetAwRenderProcessGoneDelegatesForRenderProcess(child_process_id, &delegates); | |
| 67 for (auto delegate : delegates) { | |
| 68 if (!delegate->OnRenderProcessGoneDetail(child_process_id, crashed)) { | |
| 69 // Keeps this log unchanged, CTS test uses it to detect crash. | |
| 70 LOG(FATAL) << "Render process's abnormal termination wasn't handled by" | |
|
Tobias Sargeant
2017/01/19 17:28:03
When you rebase, you'll need
crash_reporter::Supp
michaelbai
2017/01/19 17:33:31
Thanks
| |
| 71 << " all associated webviews, triggering application crash"; | |
| 72 } | |
| 73 } | |
| 74 } | |
| 75 | |
| 76 } // namespace | |
| 77 | |
| 24 AwBrowserTerminator::AwBrowserTerminator() {} | 78 AwBrowserTerminator::AwBrowserTerminator() {} |
| 25 | 79 |
| 26 AwBrowserTerminator::~AwBrowserTerminator() {} | 80 AwBrowserTerminator::~AwBrowserTerminator() {} |
| 27 | 81 |
| 28 void AwBrowserTerminator::OnChildStart(int child_process_id, | 82 void AwBrowserTerminator::OnChildStart(int child_process_id, |
| 29 content::FileDescriptorInfo* mappings) { | 83 content::FileDescriptorInfo* mappings) { |
| 30 DCHECK_CURRENTLY_ON(content::BrowserThread::PROCESS_LAUNCHER); | 84 DCHECK_CURRENTLY_ON(content::BrowserThread::PROCESS_LAUNCHER); |
| 31 | 85 |
| 32 base::AutoLock auto_lock(child_process_id_to_pipe_lock_); | 86 base::AutoLock auto_lock(child_process_id_to_pipe_lock_); |
| 33 DCHECK(!ContainsKey(child_process_id_to_pipe_, child_process_id)); | 87 DCHECK(!ContainsKey(child_process_id_to_pipe_, child_process_id)); |
| 34 | 88 |
| 35 auto local_pipe = base::MakeUnique<base::SyncSocket>(); | 89 auto local_pipe = base::MakeUnique<base::SyncSocket>(); |
| 36 auto child_pipe = base::MakeUnique<base::SyncSocket>(); | 90 auto child_pipe = base::MakeUnique<base::SyncSocket>(); |
| 37 if (base::SyncSocket::CreatePair(local_pipe.get(), child_pipe.get())) { | 91 if (base::SyncSocket::CreatePair(local_pipe.get(), child_pipe.get())) { |
| 38 child_process_id_to_pipe_[child_process_id] = std::move(local_pipe); | 92 child_process_id_to_pipe_[child_process_id] = std::move(local_pipe); |
| 39 mappings->Transfer(kAndroidWebViewCrashSignalDescriptor, | 93 mappings->Transfer(kAndroidWebViewCrashSignalDescriptor, |
| 40 base::ScopedFD(dup(child_pipe->handle()))); | 94 base::ScopedFD(dup(child_pipe->handle()))); |
| 41 } | 95 } |
| 42 } | 96 } |
| 43 | 97 |
| 44 void AwBrowserTerminator::ProcessTerminationStatus( | 98 void AwBrowserTerminator::ProcessTerminationStatus( |
| 99 int child_process_id, | |
| 45 std::unique_ptr<base::SyncSocket> pipe) { | 100 std::unique_ptr<base::SyncSocket> pipe) { |
| 101 bool crashed = false; | |
| 102 | |
| 103 // If the child process hasn't written anything into the pipe. This implies | |
| 104 // that it was terminated via SIGKILL by the low memory killer. | |
| 46 if (pipe->Peek() >= sizeof(int)) { | 105 if (pipe->Peek() >= sizeof(int)) { |
| 47 int exit_code; | 106 int exit_code; |
| 48 pipe->Receive(&exit_code, sizeof(exit_code)); | 107 pipe->Receive(&exit_code, sizeof(exit_code)); |
| 49 LOG(FATAL) << "Renderer process crash detected (code " << exit_code | 108 LOG(ERROR) << "Renderer process crash detected (code " << exit_code << ")."; |
| 50 << "). Terminating browser."; | 109 crashed = true; |
| 51 } else { | |
| 52 // The child process hasn't written anything into the pipe. This implies | |
| 53 // that it was terminated via SIGKILL by the low memory killer, and thus we | |
| 54 // need to perform a clean exit. | |
| 55 exit(0); | |
| 56 } | 110 } |
| 111 | |
| 112 BrowserThread::PostTask( | |
| 113 BrowserThread::UI, FROM_HERE, | |
| 114 base::Bind(&OnRenderProcessGoneDetail, child_process_id, crashed)); | |
| 57 } | 115 } |
| 58 | 116 |
| 59 void AwBrowserTerminator::OnChildExit( | 117 void AwBrowserTerminator::OnChildExit( |
| 60 int child_process_id, | 118 int child_process_id, |
| 61 base::ProcessHandle pid, | 119 base::ProcessHandle pid, |
| 62 content::ProcessType process_type, | 120 content::ProcessType process_type, |
| 63 base::TerminationStatus termination_status, | 121 base::TerminationStatus termination_status, |
| 64 base::android::ApplicationState app_state) { | 122 base::android::ApplicationState app_state) { |
| 65 std::unique_ptr<base::SyncSocket> pipe; | 123 std::unique_ptr<base::SyncSocket> pipe; |
| 66 | 124 |
| 67 { | 125 { |
| 68 base::AutoLock auto_lock(child_process_id_to_pipe_lock_); | 126 base::AutoLock auto_lock(child_process_id_to_pipe_lock_); |
| 69 const auto& iter = child_process_id_to_pipe_.find(child_process_id); | 127 const auto& iter = child_process_id_to_pipe_.find(child_process_id); |
| 70 if (iter == child_process_id_to_pipe_.end()) { | 128 if (iter == child_process_id_to_pipe_.end()) { |
| 71 // We might get a NOTIFICATION_RENDERER_PROCESS_TERMINATED and a | 129 // We might get a NOTIFICATION_RENDERER_PROCESS_TERMINATED and a |
| 72 // NOTIFICATION_RENDERER_PROCESS_CLOSED. | 130 // NOTIFICATION_RENDERER_PROCESS_CLOSED. |
| 73 return; | 131 return; |
| 74 } | 132 } |
| 75 pipe = std::move(iter->second); | 133 pipe = std::move(iter->second); |
| 76 child_process_id_to_pipe_.erase(iter); | 134 child_process_id_to_pipe_.erase(iter); |
| 77 } | 135 } |
| 78 if (termination_status == base::TERMINATION_STATUS_NORMAL_TERMINATION) | 136 if (termination_status == base::TERMINATION_STATUS_NORMAL_TERMINATION) |
| 79 return; | 137 return; |
| 138 OnRenderProcessGone(child_process_id); | |
| 80 DCHECK(pipe->handle() != base::SyncSocket::kInvalidHandle); | 139 DCHECK(pipe->handle() != base::SyncSocket::kInvalidHandle); |
| 81 BrowserThread::PostTask( | 140 BrowserThread::PostTask( |
| 82 BrowserThread::FILE, FROM_HERE, | 141 BrowserThread::FILE, FROM_HERE, |
| 83 base::Bind(&AwBrowserTerminator::ProcessTerminationStatus, | 142 base::Bind(&AwBrowserTerminator::ProcessTerminationStatus, |
| 143 child_process_id, | |
| 84 base::Passed(std::move(pipe)))); | 144 base::Passed(std::move(pipe)))); |
| 85 } | 145 } |
| 86 | 146 |
| 87 } // namespace breakpad | 147 } // namespace breakpad |
| OLD | NEW |