Port messages sent by WebIDBFactoryImpl to Mojo.

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

 /*
  * Copyright (C) 2010 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 24 matching lines @@
 #include "core/dom/DOMException.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/dom/ExecutionContext.h"
 #include "core/events/EventQueue.h"
 #include "modules/IndexedDBNames.h"
 #include "modules/indexeddb/IDBCursorWithValue.h"
 #include "modules/indexeddb/IDBDatabase.h"
 #include "modules/indexeddb/IDBEventDispatcher.h"
 #include "modules/indexeddb/IDBTracing.h"
 #include "modules/indexeddb/IDBValue.h"
+#include "modules/indexeddb/WebIDBCallbacksImpl.h"
 #include "platform/SharedBuffer.h"
 #include "public/platform/WebBlobInfo.h"
 #include <memory>
 
 using blink::WebIDBCursor;
 
 namespace blink {
 
 IDBRequest* IDBRequest::create(ScriptState* scriptState, IDBAny* source, IDBTransaction* transaction)
 {
@@ skipping 69 matching lines @@
 const String& IDBRequest::readyState() const
 {
     DCHECK(m_readyState == PENDING || m_readyState == DONE);
 
     if (m_readyState == PENDING)
         return IndexedDBNames::pending;
 
     return IndexedDBNames::done;
 }
 
+std::unique_ptr<WebIDBCallbacks> IDBRequest::createWebCallbacks()
+{
+    DCHECK(!m_webCallbacks);
+    std::unique_ptr<WebIDBCallbacks> callbacks = WebIDBCallbacksImpl::create(this);
+    m_webCallbacks = callbacks.get();
+    return callbacks;
+}
+
+void IDBRequest::webCallbacksDestroyed()
+{
+    DCHECK(m_webCallbacks);
+    m_webCallbacks = nullptr;
+}
+
 void IDBRequest::abort()
 {
     DCHECK(!m_requestAborted);
     if (m_contextStopped || !getExecutionContext())
         return;
     DCHECK(m_readyState == PENDING || m_readyState == DONE);
     if (m_readyState == DONE)
         return;
 
     EventQueue* eventQueue = getExecutionContext()->getEventQueue();
@@ skipping 252 matching lines @@
         }
     }
 
     m_enqueuedEvents.clear();
     if (m_source)
         m_source->contextWillBeDestroyed();
     if (m_result)
         m_result->contextWillBeDestroyed();
     if (m_pendingCursor)
         m_pendingCursor->contextWillBeDestroyed();
+    if (m_webCallbacks) {
+        m_webCallbacks->detach();
+        m_webCallbacks = nullptr;
+    }
 }
 
 const AtomicString& IDBRequest::interfaceName() const
 {
     return EventTargetNames::IDBRequest;
 }
 
 ExecutionContext* IDBRequest::getExecutionContext() const
 {
     return ActiveDOMObject::getExecutionContext();
@@ skipping 119 matching lines @@
 
 void IDBRequest::dequeueEvent(Event* event)
 {
     for (size_t i = 0; i < m_enqueuedEvents.size(); ++i) {
         if (m_enqueuedEvents[i].get() == event)
             m_enqueuedEvents.remove(i);
     }
 }
 
 } // namespace blink