Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(213)

Side by Side Diff: content/renderer/render_thread_impl.cc

Issue 8747002: Dispatch IndexedDB IPC messages to worker threads (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: remove some includes Created 9 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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 24 matching lines...) Expand all
35 #include "content/common/view_messages.h" 35 #include "content/common/view_messages.h"
36 #include "content/common/web_database_observer_impl.h" 36 #include "content/common/web_database_observer_impl.h"
37 #include "content/public/common/content_switches.h" 37 #include "content/public/common/content_switches.h"
38 #include "content/public/common/renderer_preferences.h" 38 #include "content/public/common/renderer_preferences.h"
39 #include "content/public/renderer/content_renderer_client.h" 39 #include "content/public/renderer/content_renderer_client.h"
40 #include "content/public/renderer/render_process_observer.h" 40 #include "content/public/renderer/render_process_observer.h"
41 #include "content/public/renderer/render_view_visitor.h" 41 #include "content/public/renderer/render_view_visitor.h"
42 #include "content/renderer/devtools_agent_filter.h" 42 #include "content/renderer/devtools_agent_filter.h"
43 #include "content/renderer/gpu/compositor_thread.h" 43 #include "content/renderer/gpu/compositor_thread.h"
44 #include "content/renderer/gpu/gpu_channel_host.h" 44 #include "content/renderer/gpu/gpu_channel_host.h"
45 #include "content/renderer/indexed_db_dispatcher.h" 45 #include "content/renderer/indexed_db_dispatcher.h"
michaeln 2011/12/14 02:15:53 can this include be removed now?
dgrogan 2011/12/15 02:47:44 Done.
46 #include "content/renderer/media/audio_input_message_filter.h" 46 #include "content/renderer/media/audio_input_message_filter.h"
47 #include "content/renderer/media/audio_message_filter.h" 47 #include "content/renderer/media/audio_message_filter.h"
48 #include "content/renderer/media/video_capture_impl_manager.h" 48 #include "content/renderer/media/video_capture_impl_manager.h"
49 #include "content/renderer/media/video_capture_message_filter.h" 49 #include "content/renderer/media/video_capture_message_filter.h"
50 #include "content/renderer/plugin_channel_host.h" 50 #include "content/renderer/plugin_channel_host.h"
51 #include "content/renderer/render_process_impl.h" 51 #include "content/renderer/render_process_impl.h"
52 #include "content/renderer/render_view_impl.h" 52 #include "content/renderer/render_view_impl.h"
53 #include "content/renderer/renderer_webidbfactory_impl.h" 53 #include "content/renderer/renderer_webidbfactory_impl.h"
54 #include "content/renderer/renderer_webkitplatformsupport_impl.h" 54 #include "content/renderer/renderer_webkitplatformsupport_impl.h"
55 #include "ipc/ipc_channel_handle.h" 55 #include "ipc/ipc_channel_handle.h"
(...skipping 135 matching lines...) Expand 10 before | Expand all | Expand 10 after
191 notify_webkit_of_modal_loop_ = true; 191 notify_webkit_of_modal_loop_ = true;
192 plugin_refresh_allowed_ = true; 192 plugin_refresh_allowed_ = true;
193 widget_count_ = 0; 193 widget_count_ = 0;
194 hidden_widget_count_ = 0; 194 hidden_widget_count_ = 0;
195 idle_notification_delay_in_ms_ = kInitialIdleHandlerDelayMs; 195 idle_notification_delay_in_ms_ = kInitialIdleHandlerDelayMs;
196 idle_notifications_to_skip_ = 0; 196 idle_notifications_to_skip_ = 0;
197 compositor_initialized_ = false; 197 compositor_initialized_ = false;
198 task_factory_.reset(new ScopedRunnableMethodFactory<RenderThreadImpl>(this)); 198 task_factory_.reset(new ScopedRunnableMethodFactory<RenderThreadImpl>(this));
199 199
200 appcache_dispatcher_.reset(new AppCacheDispatcher(Get())); 200 appcache_dispatcher_.reset(new AppCacheDispatcher(Get()));
201 indexed_db_dispatcher_.reset(new IndexedDBDispatcher());
202 201
203 db_message_filter_ = new DBMessageFilter(); 202 db_message_filter_ = new DBMessageFilter();
204 AddFilter(db_message_filter_.get()); 203 AddFilter(db_message_filter_.get());
205 204
206 vc_manager_ = new VideoCaptureImplManager(); 205 vc_manager_ = new VideoCaptureImplManager();
207 AddFilter(vc_manager_->video_capture_message_filter()); 206 AddFilter(vc_manager_->video_capture_message_filter());
208 207
209 audio_input_message_filter_ = new AudioInputMessageFilter(); 208 audio_input_message_filter_ = new AudioInputMessageFilter();
210 AddFilter(audio_input_message_filter_.get()); 209 AddFilter(audio_input_message_filter_.get());
211 210
(...skipping 489 matching lines...) Expand 10 before | Expand all | Expand 10 after
701 ObserverListBase<RenderProcessObserver>::Iterator it(observers_); 700 ObserverListBase<RenderProcessObserver>::Iterator it(observers_);
702 RenderProcessObserver* observer; 701 RenderProcessObserver* observer;
703 while ((observer = it.GetNext()) != NULL) { 702 while ((observer = it.GetNext()) != NULL) {
704 if (observer->OnControlMessageReceived(msg)) 703 if (observer->OnControlMessageReceived(msg))
705 return true; 704 return true;
706 } 705 }
707 706
708 // Some messages are handled by delegates. 707 // Some messages are handled by delegates.
709 if (appcache_dispatcher_->OnMessageReceived(msg)) 708 if (appcache_dispatcher_->OnMessageReceived(msg))
710 return true; 709 return true;
711 if (indexed_db_dispatcher_->OnMessageReceived(msg))
712 return true;
713 710
714 bool handled = true; 711 bool handled = true;
715 IPC_BEGIN_MESSAGE_MAP(RenderThreadImpl, msg) 712 IPC_BEGIN_MESSAGE_MAP(RenderThreadImpl, msg)
716 IPC_MESSAGE_HANDLER(ViewMsg_SetZoomLevelForCurrentURL, 713 IPC_MESSAGE_HANDLER(ViewMsg_SetZoomLevelForCurrentURL,
717 OnSetZoomLevelForCurrentURL) 714 OnSetZoomLevelForCurrentURL)
718 IPC_MESSAGE_HANDLER(ViewMsg_SetNextPageID, OnSetNextPageID) 715 IPC_MESSAGE_HANDLER(ViewMsg_SetNextPageID, OnSetNextPageID)
719 IPC_MESSAGE_HANDLER(ViewMsg_SetCSSColors, OnSetCSSColors) 716 IPC_MESSAGE_HANDLER(ViewMsg_SetCSSColors, OnSetCSSColors)
720 // TODO(port): removed from render_messages_internal.h; 717 // TODO(port): removed from render_messages_internal.h;
721 // is there a new non-windows message I should add here? 718 // is there a new non-windows message I should add here?
722 IPC_MESSAGE_HANDLER(ViewMsg_New, OnCreateNewView) 719 IPC_MESSAGE_HANDLER(ViewMsg_New, OnCreateNewView)
(...skipping 134 matching lines...) Expand 10 before | Expand all | Expand 10 after
857 854
858 scoped_refptr<base::MessageLoopProxy> 855 scoped_refptr<base::MessageLoopProxy>
859 RenderThreadImpl::GetFileThreadMessageLoopProxy() { 856 RenderThreadImpl::GetFileThreadMessageLoopProxy() {
860 DCHECK(message_loop() == MessageLoop::current()); 857 DCHECK(message_loop() == MessageLoop::current());
861 if (!file_thread_.get()) { 858 if (!file_thread_.get()) {
862 file_thread_.reset(new base::Thread("Renderer::FILE")); 859 file_thread_.reset(new base::Thread("Renderer::FILE"));
863 file_thread_->Start(); 860 file_thread_->Start();
864 } 861 }
865 return file_thread_->message_loop_proxy(); 862 return file_thread_->message_loop_proxy();
866 } 863 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698