Port messages sent by WebIDBFactoryImpl to Mojo.

ipc/ipc_sync_message_filter.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 "ipc/ipc_sync_message_filter.h"
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/macros.h"
@@ skipping 154 matching lines @@
   }
 
   return pending_message.send_result;
 }
 
 void SyncMessageFilter::OnFilterAdded(Channel* channel) {
   std::vector<std::unique_ptr<Message>> pending_messages;
   {
     base::AutoLock auto_lock(lock_);
     channel_ = channel;
+    Channel::AssociatedInterfaceSupport* support =
+        channel_->GetAssociatedInterfaceSupport();
+    if (support)
+      channel_associated_group_ = *support->GetAssociatedGroup();
+
     io_task_runner_ = base::ThreadTaskRunnerHandle::Get();
     shutdown_watcher_.StartWatching(
         shutdown_event_,
         base::Bind(&SyncMessageFilter::OnShutdownEventSignaled, this));
     io_message_loop_observer_->StartOnIOThread();
     std::swap(pending_messages_, pending_messages);
   }
   for (auto& msg : pending_messages)
     SendOnIOThread(msg.release());
 }
@@ skipping 78 matching lines @@
 }
 
 void SyncMessageFilter::OnIOMessageLoopDestroyed() {
   // Since we use an async WaitableEventWatcher to watch the shutdown event
   // from the IO thread, we can't forward the shutdown signal after the IO
   // message loop is destroyed. Since that destruction indicates shutdown
   // anyway, we manually signal the shutdown event in this case.
   shutdown_mojo_event_.Signal();
 }
 
+void SyncMessageFilter::GetGenericRemoteAssociatedInterface(
+    const std::string& interface_name,
+    mojo::ScopedInterfaceEndpointHandle handle) {
+  base::AutoLock auto_lock(lock_);
+  DCHECK(io_task_runner_);
+  DCHECK(io_task_runner_->BelongsToCurrentThread());
+  if (!channel_)
+    return;
+
+  Channel::AssociatedInterfaceSupport* support =
+      channel_->GetAssociatedInterfaceSupport();
+  support->GetGenericRemoteAssociatedInterface(interface_name,
+                                               std::move(handle));
+}
+
 }  // namespace IPC