Switch chrome and chromiumDRT over to using the new WebKit API for dispatching events.

content/renderer/render_thread_impl.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/renderer/render_thread_impl.h"
 
 #include <algorithm>
 #include <limits>
 #include <map>
 #include <vector>
@@ skipping 39 matching lines @@
 #include "content/renderer/media/audio_input_message_filter.h"
 #include "content/renderer/media/audio_message_filter.h"
 #include "content/renderer/media/media_stream_center.h"
 #include "content/renderer/media/video_capture_impl_manager.h"
 #include "content/renderer/media/video_capture_message_filter.h"
 #include "content/renderer/plugin_channel_host.h"
 #include "content/renderer/render_process_impl.h"
 #include "content/renderer/render_view_impl.h"
 #include "content/renderer/renderer_webkitplatformsupport_impl.h"
 #include "content/renderer/renderer_webstoragearea_impl.h"
+#include "content/renderer/renderer_webstoragenamespace_impl.h"
 #include "grit/content_resources.h"
 #include "ipc/ipc_channel_handle.h"
 #include "ipc/ipc_platform_file.h"
 #include "media/base/media.h"
 #include "net/base/net_errors.h"
 #include "net/base/net_util.h"
 #include "third_party/tcmalloc/chromium/src/gperftools/malloc_extension.h"
 #include "third_party/WebKit/Source/WebKit/chromium/public/WebColorName.h"
 #include "third_party/WebKit/Source/WebKit/chromium/public/WebCompositor.h"
 #include "third_party/WebKit/Source/WebKit/chromium/public/WebDatabase.h"
@@ skipping 736 matching lines @@
 }
 
 void RenderThreadImpl::OnSetZoomLevelForCurrentURL(const std::string& host,
                                                    double zoom_level) {
   RenderViewZoomer zoomer(host, zoom_level);
   content::RenderView::ForEach(&zoomer);
 }
 
 void RenderThreadImpl::OnDOMStorageEvent(
     const DOMStorageMsg_Event_Params& params) {
-  if (!dom_storage_event_dispatcher_.get()) {
-    EnsureWebKitInitialized();
-    dom_storage_event_dispatcher_.reset(WebStorageEventDispatcher::create());
+  EnsureWebKitInitialized();
+
+  bool originated_in_process = params.connection_id != 0;
+  RendererWebStorageAreaImpl* originating_area = NULL;
+  if (originated_in_process) {
+    originating_area = RendererWebStorageAreaImpl::FromConnectionId(
+        params.connection_id);
   }
 
-  // TODO(michaeln): Return early until webkit/webcore is modified to not
-  // raise LocalStorage events internally. Looks like i have some multi-side
-  // patch engineering in front of me todo.
-  if (params.connection_id)
-    return;
-
-  // TODO(michaeln): fix the webkit api so we don't need to convert from
-  // string types to url types and to pass in the 'area' which
-  // caused this event to occur and to get rid of the is_local param.
-  // RendererWebStorageAreaImpl* originating_area =
-  //     RendererWebStorageAreaImpl::FromConnectionId(params.connection_id);
-
-  // SessionStorage events are always raised internally by webkit/webcore.
-  const bool kIsLocalStorage = true;
-  dom_storage_event_dispatcher_->dispatchStorageEvent(
-      params.key,
-      params.old_value,
-      params.new_value,
-      UTF8ToUTF16(params.origin.spec()),
-      params.page_url,
-      kIsLocalStorage);
+  if (params.namespace_id == dom_storage::kLocalStorageNamespaceId) {
+    WebStorageEventDispatcher::dispatchLocalStorageEvent(
+        params.key,
+        params.old_value,
+        params.new_value,
+        params.origin,
+        params.page_url,
+        originating_area,
+        originated_in_process);
+  } else if (originated_in_process) {
+    // TODO(michaeln): For now, we only raise session storage events into the
+    // process which caused the event to occur. However there are cases where
+    // sessions can span process boundaries, so there are correctness issues.
+    RendererWebStorageNamespaceImpl
+        session_namespace_for_event_dispatch(params.namespace_id);
+    WebStorageEventDispatcher::dispatchSessionStorageEvent(
+        params.key,
+        params.old_value,
+        params.new_value,
+        params.origin,
+        params.page_url,
+        session_namespace_for_event_dispatch,
+        originating_area,
+        originated_in_process);
+  }
 }
 
 bool RenderThreadImpl::OnControlMessageReceived(const IPC::Message& msg) {
   ObserverListBase<RenderProcessObserver>::Iterator it(observers_);
   RenderProcessObserver* observer;
   while ((observer = it.GetNext()) != NULL) {
     if (observer->OnControlMessageReceived(msg))
       return true;
   }
 
@@ skipping 146 matching lines @@
 
 scoped_refptr<base::MessageLoopProxy>
 RenderThreadImpl::GetFileThreadMessageLoopProxy() {
   DCHECK(message_loop() == MessageLoop::current());
   if (!file_thread_.get()) {
     file_thread_.reset(new base::Thread("Renderer::FILE"));
     file_thread_->Start();
   }
   return file_thread_->message_loop_proxy();
 }