| 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 |