OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 "content/renderer/render_thread_impl.h" | 5 #include "content/renderer/render_thread_impl.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <limits> | 8 #include <limits> |
9 #include <map> | 9 #include <map> |
10 #include <vector> | 10 #include <vector> |
(...skipping 187 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
198 #if defined(OS_MACOSX) | 198 #if defined(OS_MACOSX) |
199 process_metrics_.reset(base::ProcessMetrics::CreateProcessMetrics(handle, | 199 process_metrics_.reset(base::ProcessMetrics::CreateProcessMetrics(handle, |
200 NULL)); | 200 NULL)); |
201 #else | 201 #else |
202 process_metrics_.reset(base::ProcessMetrics::CreateProcessMetrics(handle)); | 202 process_metrics_.reset(base::ProcessMetrics::CreateProcessMetrics(handle)); |
203 #endif | 203 #endif |
204 process_metrics_->GetCPUUsage(); // Initialize CPU usage counters. | 204 process_metrics_->GetCPUUsage(); // Initialize CPU usage counters. |
205 task_factory_.reset(new ScopedRunnableMethodFactory<RenderThreadImpl>(this)); | 205 task_factory_.reset(new ScopedRunnableMethodFactory<RenderThreadImpl>(this)); |
206 | 206 |
207 appcache_dispatcher_.reset(new AppCacheDispatcher(Get())); | 207 appcache_dispatcher_.reset(new AppCacheDispatcher(Get())); |
208 indexed_db_dispatcher_.reset(new IndexedDBDispatcher()); | |
209 | 208 |
210 db_message_filter_ = new DBMessageFilter(); | 209 db_message_filter_ = new DBMessageFilter(); |
211 AddFilter(db_message_filter_.get()); | 210 AddFilter(db_message_filter_.get()); |
212 | 211 |
213 vc_manager_ = new VideoCaptureImplManager(); | 212 vc_manager_ = new VideoCaptureImplManager(); |
214 AddFilter(vc_manager_->video_capture_message_filter()); | 213 AddFilter(vc_manager_->video_capture_message_filter()); |
215 | 214 |
216 audio_input_message_filter_ = new AudioInputMessageFilter(); | 215 audio_input_message_filter_ = new AudioInputMessageFilter(); |
217 AddFilter(audio_input_message_filter_.get()); | 216 AddFilter(audio_input_message_filter_.get()); |
218 | 217 |
(...skipping 483 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
702 ObserverListBase<RenderProcessObserver>::Iterator it(observers_); | 701 ObserverListBase<RenderProcessObserver>::Iterator it(observers_); |
703 RenderProcessObserver* observer; | 702 RenderProcessObserver* observer; |
704 while ((observer = it.GetNext()) != NULL) { | 703 while ((observer = it.GetNext()) != NULL) { |
705 if (observer->OnControlMessageReceived(msg)) | 704 if (observer->OnControlMessageReceived(msg)) |
706 return true; | 705 return true; |
707 } | 706 } |
708 | 707 |
709 // Some messages are handled by delegates. | 708 // Some messages are handled by delegates. |
710 if (appcache_dispatcher_->OnMessageReceived(msg)) | 709 if (appcache_dispatcher_->OnMessageReceived(msg)) |
711 return true; | 710 return true; |
712 if (indexed_db_dispatcher_->OnMessageReceived(msg)) | |
713 return true; | |
714 | 711 |
715 bool handled = true; | 712 bool handled = true; |
716 IPC_BEGIN_MESSAGE_MAP(RenderThreadImpl, msg) | 713 IPC_BEGIN_MESSAGE_MAP(RenderThreadImpl, msg) |
717 IPC_MESSAGE_HANDLER(ViewMsg_SetZoomLevelForCurrentURL, | 714 IPC_MESSAGE_HANDLER(ViewMsg_SetZoomLevelForCurrentURL, |
718 OnSetZoomLevelForCurrentURL) | 715 OnSetZoomLevelForCurrentURL) |
719 IPC_MESSAGE_HANDLER(ViewMsg_SetNextPageID, OnSetNextPageID) | 716 IPC_MESSAGE_HANDLER(ViewMsg_SetNextPageID, OnSetNextPageID) |
720 IPC_MESSAGE_HANDLER(ViewMsg_SetCSSColors, OnSetCSSColors) | 717 IPC_MESSAGE_HANDLER(ViewMsg_SetCSSColors, OnSetCSSColors) |
721 // TODO(port): removed from render_messages_internal.h; | 718 // TODO(port): removed from render_messages_internal.h; |
722 // is there a new non-windows message I should add here? | 719 // is there a new non-windows message I should add here? |
723 IPC_MESSAGE_HANDLER(ViewMsg_New, OnCreateNewView) | 720 IPC_MESSAGE_HANDLER(ViewMsg_New, OnCreateNewView) |
(...skipping 123 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
847 | 844 |
848 scoped_refptr<base::MessageLoopProxy> | 845 scoped_refptr<base::MessageLoopProxy> |
849 RenderThreadImpl::GetFileThreadMessageLoopProxy() { | 846 RenderThreadImpl::GetFileThreadMessageLoopProxy() { |
850 DCHECK(message_loop() == MessageLoop::current()); | 847 DCHECK(message_loop() == MessageLoop::current()); |
851 if (!file_thread_.get()) { | 848 if (!file_thread_.get()) { |
852 file_thread_.reset(new base::Thread("Renderer::FILE")); | 849 file_thread_.reset(new base::Thread("Renderer::FILE")); |
853 file_thread_->Start(); | 850 file_thread_->Start(); |
854 } | 851 } |
855 return file_thread_->message_loop_proxy(); | 852 return file_thread_->message_loop_proxy(); |
856 } | 853 } |
OLD | NEW |