Port messages sent by WebIDBFactoryImpl to Mojo.

third_party/WebKit/Source/modules/indexeddb/IDBOpenDBRequest.cpp

 /*
  * Copyright (C) 2012 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  *
  * 1.  Redistributions of source code must retain the above copyright
  *     notice, this list of conditions and the following disclaimer.
  * 2.  Redistributions in binary form must reproduce the above copyright
@@ skipping 49 matching lines @@
   DCHECK(!resultAsAny());
 }
 
 IDBOpenDBRequest::~IDBOpenDBRequest() {}
 
 DEFINE_TRACE(IDBOpenDBRequest) {
   visitor->trace(m_databaseCallbacks);
   IDBRequest::trace(visitor);
 }
 
+void IDBOpenDBRequest::contextDestroyed() {
+  IDBRequest::contextDestroyed();
+  if (m_databaseCallbacks)
+    m_databaseCallbacks->detachWebCallbacks();
+}
+
 const AtomicString& IDBOpenDBRequest::interfaceName() const {
   return EventTargetNames::IDBOpenDBRequest;
 }
 
 void IDBOpenDBRequest::onBlocked(int64_t oldVersion) {
   IDB_TRACE("IDBOpenDBRequest::onBlocked()");
   if (!shouldEnqueueEvent())
     return;
   Nullable<unsigned long long> newVersionNullable =
       (m_version == IDBDatabaseMetadata::DefaultVersion)
           ? Nullable<unsigned long long>()
           : Nullable<unsigned long long>(m_version);
   enqueueEvent(IDBVersionChangeEvent::create(EventTypeNames::blocked,
                                              oldVersion, newVersionNullable));
 }
 
 void IDBOpenDBRequest::onUpgradeNeeded(int64_t oldVersion,
                                        std::unique_ptr<WebIDBDatabase> backend,
                                        const IDBDatabaseMetadata& metadata,
                                        WebIDBDataLoss dataLoss,
                                        String dataLossMessage) {
   IDB_TRACE("IDBOpenDBRequest::onUpgradeNeeded()");
-  if (m_contextStopped || !getExecutionContext()) {
-    std::unique_ptr<WebIDBDatabase> db = std::move(backend);
-    db->abort(m_transactionId);
-    db->close();
-    return;
-  }
   if (!shouldEnqueueEvent())
     return;
 
   DCHECK(m_databaseCallbacks);
 
   IDBDatabase* idbDatabase = IDBDatabase::create(
       getExecutionContext(), std::move(backend), m_databaseCallbacks.release());
   idbDatabase->setMetadata(metadata);
 
   if (oldVersion == IDBDatabaseMetadata::NoVersion) {
@@ skipping 10 matching lines @@
   if (m_version == IDBDatabaseMetadata::NoVersion)
     m_version = 1;
   enqueueEvent(IDBVersionChangeEvent::create(EventTypeNames::upgradeneeded,
                                              oldVersion, m_version, dataLoss,
                                              dataLossMessage));
 }
 
 void IDBOpenDBRequest::onSuccess(std::unique_ptr<WebIDBDatabase> backend,
                                  const IDBDatabaseMetadata& metadata) {
   IDB_TRACE("IDBOpenDBRequest::onSuccess()");
-  if (m_contextStopped || !getExecutionContext()) {
-    std::unique_ptr<WebIDBDatabase> db = std::move(backend);
-    if (db)
-      db->close();
-    return;
-  }
   if (!shouldEnqueueEvent())
     return;
 
   IDBDatabase* idbDatabase = nullptr;
   if (resultAsAny()) {
     // Previous onUpgradeNeeded call delivered the backend.
     DCHECK(!backend.get());
     idbDatabase = resultAsAny()->idbDatabase();
     DCHECK(idbDatabase);
     DCHECK(!m_databaseCallbacks);
@@ skipping 39 matching lines @@
     dequeueEvent(event);
     setResult(nullptr);
     onError(DOMException::create(AbortError, "The connection was closed."));
     return DispatchEventResult::CanceledBeforeDispatch;
   }
 
   return IDBRequest::dispatchEventInternal(event);
 }
 
 }  // namespace blink