Port messages sent by WebIDBCursorImpl to Mojo.

content/child/indexed_db/indexed_db_database_callbacks_impl.cc

 // Copyright 2016 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/child/indexed_db/indexed_db_database_callbacks_impl.h"
 
 #include "content/child/indexed_db/indexed_db_dispatcher.h"
-#include "content/child/thread_safe_sender.h"
 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBDatabaseCallbacks.h"
 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBDatabaseError.h"
 
 using blink::WebIDBDatabaseCallbacks;
 
 namespace content {
 
 namespace {
 
-void DeleteDatabaseCallbacks(WebIDBDatabaseCallbacks* callbacks,
-                             ThreadSafeSender* thread_safe_sender) {
-  IndexedDBDispatcher* dispatcher =
-      IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender);
-  dispatcher->UnregisterMojoOwnedDatabaseCallbacks(callbacks);
+void DeleteDatabaseCallbacks(WebIDBDatabaseCallbacks* callbacks) {
+  IndexedDBDispatcher::ThreadSpecificInstance()
+      ->UnregisterMojoOwnedDatabaseCallbacks(callbacks);
   delete callbacks;
 }
 
 }  // namespace
 
 IndexedDBDatabaseCallbacksImpl::IndexedDBDatabaseCallbacksImpl(
-    std::unique_ptr<WebIDBDatabaseCallbacks> callbacks,
-    scoped_refptr<ThreadSafeSender> thread_safe_sender)
+    std::unique_ptr<WebIDBDatabaseCallbacks> callbacks)
     : callback_runner_(base::ThreadTaskRunnerHandle::Get()),
-      thread_safe_sender_(thread_safe_sender),
       callbacks_(callbacks.release()) {
-  IndexedDBDispatcher* dispatcher =
-      IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get());
-  dispatcher->RegisterMojoOwnedDatabaseCallbacks(callbacks_);
+  IndexedDBDispatcher::ThreadSpecificInstance()
+      ->RegisterMojoOwnedDatabaseCallbacks(callbacks_);
 }
 
 IndexedDBDatabaseCallbacksImpl::~IndexedDBDatabaseCallbacksImpl() {
-  callback_runner_->PostTask(
-      FROM_HERE, base::Bind(&DeleteDatabaseCallbacks, callbacks_,
-                            base::RetainedRef(thread_safe_sender_)));
+  callback_runner_->PostTask(FROM_HERE,
+                             base::Bind(&DeleteDatabaseCallbacks, callbacks_));
 }
 
 void IndexedDBDatabaseCallbacksImpl::ForcedClose() {
   callback_runner_->PostTask(FROM_HERE,
                              base::Bind(&WebIDBDatabaseCallbacks::onForcedClose,
                                         base::Unretained(callbacks_)));
 }
 
 void IndexedDBDatabaseCallbacksImpl::VersionChange(int64_t old_version,
                                                    int64_t new_version) {
@@ skipping 12 matching lines @@
                             blink::WebIDBDatabaseError(code, message)));
 }
 
 void IndexedDBDatabaseCallbacksImpl::Complete(int64_t transaction_id) {
   callback_runner_->PostTask(
       FROM_HERE, base::Bind(&WebIDBDatabaseCallbacks::onComplete,
                             base::Unretained(callbacks_), transaction_id));
 }
 
 }  // namespace content