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

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: fix clang-enforced style violations 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 180 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