Port messages sent by WebIDBDatabaseImpl to Mojo.

content/child/indexed_db/webidbfactory_impl.cc

 // Copyright 2013 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/webidbfactory_impl.h"
 
 #include "content/child/child_thread_impl.h"
 #include "content/child/indexed_db/indexed_db_callbacks_impl.h"
 #include "content/child/indexed_db/indexed_db_database_callbacks_impl.h"
 #include "content/child/storage_util.h"
@@ skipping 54 matching lines @@
       thread_safe_sender_(std::move(thread_safe_sender)),
       io_runner_(std::move(io_runner)) {}
 
 WebIDBFactoryImpl::~WebIDBFactoryImpl() {
   io_runner_->DeleteSoon(FROM_HERE, io_helper_);
 }
 
 void WebIDBFactoryImpl::getDatabaseNames(WebIDBCallbacks* callbacks,
                                          const WebSecurityOrigin& origin) {
   auto callbacks_impl = base::MakeUnique<IndexedDBCallbacksImpl>(
-      base::WrapUnique(callbacks), thread_safe_sender_);
+      base::WrapUnique(callbacks), IndexedDBCallbacksImpl::kNoTransaction,
+      io_runner_, thread_safe_sender_);
   io_runner_->PostTask(FROM_HERE, base::Bind(&IOThreadHelper::GetDatabaseNames,
                                              base::Unretained(io_helper_),
                                              base::Passed(&callbacks_impl),
                                              url::Origin(origin)));
 }
 
 void WebIDBFactoryImpl::open(const WebString& name,
                              long long version,
                              long long transaction_id,
                              WebIDBCallbacks* callbacks,
                              WebIDBDatabaseCallbacks* database_callbacks,
                              const WebSecurityOrigin& origin) {
   auto callbacks_impl = base::MakeUnique<IndexedDBCallbacksImpl>(
-      base::WrapUnique(callbacks), thread_safe_sender_);
+      base::WrapUnique(callbacks), transaction_id, io_runner_,
+      thread_safe_sender_);
   auto database_callbacks_impl =
       base::MakeUnique<IndexedDBDatabaseCallbacksImpl>(
           base::WrapUnique(database_callbacks), thread_safe_sender_);
   io_runner_->PostTask(
       FROM_HERE,
       base::Bind(&IOThreadHelper::Open, base::Unretained(io_helper_),
                  WorkerThread::GetCurrentId(), base::string16(name), version,
                  transaction_id, base::Passed(&callbacks_impl),
                  base::Passed(&database_callbacks_impl), url::Origin(origin)));
 }
 
 void WebIDBFactoryImpl::deleteDatabase(const WebString& name,
                                        WebIDBCallbacks* callbacks,
                                        const WebSecurityOrigin& origin) {
   auto callbacks_impl = base::MakeUnique<IndexedDBCallbacksImpl>(
-      base::WrapUnique(callbacks), thread_safe_sender_);
+      base::WrapUnique(callbacks), IndexedDBCallbacksImpl::kNoTransaction,
+      io_runner_, thread_safe_sender_);
   io_runner_->PostTask(
       FROM_HERE,
       base::Bind(&IOThreadHelper::DeleteDatabase, base::Unretained(io_helper_),
                  base::string16(name), base::Passed(&callbacks_impl),
                  url::Origin(origin)));
 }
 
 WebIDBFactoryImpl::IOThreadHelper::IOThreadHelper(
     scoped_refptr<IPC::SyncMessageFilter> sync_message_filter)
     : sync_message_filter_(std::move(sync_message_filter)) {}
@@ skipping 49 matching lines @@
 
 void WebIDBFactoryImpl::IOThreadHelper::DeleteDatabase(
     const base::string16& name,
     std::unique_ptr<IndexedDBCallbacksImpl> callbacks,
     const url::Origin& origin) {
   GetService()->DeleteDatabase(GetCallbacksProxy(std::move(callbacks)), origin,
                                name);
 }
 
 }  // namespace content