Attachment 356268 Details for Bug 192270 – Patch

[patch] Patch

bug-192270-20181130172135.patch (text/plain), 12.96 KB, created by Sihui Liu on 2018-11-30 17:21:35 PST

(hide)

Description:

Filename:

MIME Type:

Creator: Sihui Liu

Created: 2018-11-30 17:21:35 PST

Size: 12.96 KB

patch

obsolete

>Subversion Revision: 238744
>diff --git a/Source/WebCore/ChangeLog b/Source/WebCore/ChangeLog
>index 0abaa4022a9a3f28c453869eeb5ffb1b79640132..36006e67184c9224621160859298d7f639ae3d9e 100644
>--- a/Source/WebCore/ChangeLog
>+++ b/Source/WebCore/ChangeLog
>@@ -1,3 +1,31 @@
>+2018-11-30  Sihui Liu  <sihui_liu@apple.com>
>+
>+        Let JSDOMGlobalObject in UniqueIDBDatabase be deleted if no database is using it
>+        https://bugs.webkit.org/show_bug.cgi?id=192270
>+
>+        Reviewed by NOBODY (OOPS!).
>+
>+        Optimized UniqueIDBDatabase to not keep Global object and its vm forever, because they are 
>+        only used for serialization and deserialization of JavaScript values in IDB.
>+
>+        No behavior change.
>+
>+        * Modules/indexeddb/server/MemoryObjectStore.cpp:
>+        (WebCore::IDBServer::MemoryObjectStore::updateIndexesForPutRecord):
>+        (WebCore::IDBServer::MemoryObjectStore::populateIndexWithExistingRecords):
>+        * Modules/indexeddb/server/MemoryObjectStore.h:
>+        * Modules/indexeddb/server/UniqueIDBDatabase.cpp:
>+        (WebCore::IDBServer::IDBSerializationContext::IDBSerializationContext):
>+        (WebCore::IDBServer::IDBSerializationContext::~IDBSerializationContext):
>+        (WebCore::IDBServer::IDBSerializationContext::vm):
>+        (WebCore::IDBServer::IDBSerializationContext::execState):
>+        (WebCore::IDBServer::UniqueIDBDatabase::UniqueIDBDatabase):
>+        (WebCore::IDBServer::UniqueIDBDatabase::sharedIDBSerializationContext):
>+        (WebCore::IDBServer::UniqueIDBDatabase::performPutOrAdd):
>+        (WebCore::IDBServer::UniqueIDBDatabase::databaseThreadVM): Deleted.
>+        (WebCore::IDBServer::UniqueIDBDatabase::databaseThreadExecState): Deleted.
>+        * Modules/indexeddb/server/UniqueIDBDatabase.h:
>+
> 2018-11-30  Basuke Suzuki  <basuke.suzuki@sony.com>
> 
>         [Curl] Add API for ProtectionSpace.
>diff --git a/Source/WebCore/Modules/indexeddb/server/MemoryObjectStore.cpp b/Source/WebCore/Modules/indexeddb/server/MemoryObjectStore.cpp
>index 5cded3e58815008c757a8f869172181640754352..71ab57777c5fccae6273b760629b9df456345894 100644
>--- a/Source/WebCore/Modules/indexeddb/server/MemoryObjectStore.cpp
>+++ b/Source/WebCore/Modules/indexeddb/server/MemoryObjectStore.cpp
>@@ -299,9 +299,10 @@ void MemoryObjectStore::updateIndexesForDeleteRecord(const IDBKeyData& value)
> 
> IDBError MemoryObjectStore::updateIndexesForPutRecord(const IDBKeyData& key, const ThreadSafeDataBuffer& value)
> {
>-    JSLockHolder locker(UniqueIDBDatabase::databaseThreadVM());
>+    UniqueIDBDatabase::sharedIDBSerializationContext(m_serializationContext);
>+    JSLockHolder locker(m_serializationContext->vm());
> 
>-    auto jsValue = deserializeIDBValueToJSValue(UniqueIDBDatabase::databaseThreadExecState(), value);
>+    auto jsValue = deserializeIDBValueToJSValue(m_serializationContext->execState(), value);
>     if (jsValue.isUndefinedOrNull())
>         return IDBError { };
> 
>@@ -310,7 +311,7 @@ IDBError MemoryObjectStore::updateIndexesForPutRecord(const IDBKeyData& key, con
> 
>     for (auto& index : m_indexesByName.values()) {
>         IndexKey indexKey;
>-        generateIndexKeyForValue(UniqueIDBDatabase::databaseThreadExecState(), index->info(), jsValue, indexKey);
>+        generateIndexKeyForValue(m_serializationContext->execState(), index->info(), jsValue, indexKey);
> 
>         if (indexKey.isNull())
>             continue;
>@@ -336,15 +337,16 @@ IDBError MemoryObjectStore::populateIndexWithExistingRecords(MemoryIndex& index)
>     if (!m_keyValueStore)
>         return IDBError { };
> 
>-    JSLockHolder locker(UniqueIDBDatabase::databaseThreadVM());
>+    UniqueIDBDatabase::sharedIDBSerializationContext(m_serializationContext);
>+    JSLockHolder locker(m_serializationContext->vm());
> 
>     for (auto iterator : *m_keyValueStore) {
>-        auto jsValue = deserializeIDBValueToJSValue(UniqueIDBDatabase::databaseThreadExecState(), iterator.value);
>+        auto jsValue = deserializeIDBValueToJSValue(m_serializationContext->execState(), iterator.value);
>         if (jsValue.isUndefinedOrNull())
>             return IDBError { };
> 
>         IndexKey indexKey;
>-        generateIndexKeyForValue(UniqueIDBDatabase::databaseThreadExecState(), index.info(), jsValue, indexKey);
>+        generateIndexKeyForValue(m_serializationContext->execState(), index.info(), jsValue, indexKey);
> 
>         if (indexKey.isNull())
>             continue;
>diff --git a/Source/WebCore/Modules/indexeddb/server/MemoryObjectStore.h b/Source/WebCore/Modules/indexeddb/server/MemoryObjectStore.h
>index 5b3d833e556f6cc917c08802a35c078116d87318..b2f4cbc28fcd6f534e4e359606e701b334c5b817 100644
>--- a/Source/WebCore/Modules/indexeddb/server/MemoryObjectStore.h
>+++ b/Source/WebCore/Modules/indexeddb/server/MemoryObjectStore.h
>@@ -32,6 +32,7 @@
> #include "MemoryIndex.h"
> #include "MemoryObjectStoreCursor.h"
> #include "ThreadSafeDataBuffer.h"
>+#include "UniqueIDBDatabase.h"
> #include <wtf/HashMap.h>
> #include <wtf/RefCounted.h>
> 
>@@ -128,6 +129,8 @@ private:
>     HashMap<uint64_t, RefPtr<MemoryIndex>> m_indexesByIdentifier;
>     HashMap<String, RefPtr<MemoryIndex>> m_indexesByName;
>     HashMap<IDBResourceIdentifier, std::unique_ptr<MemoryObjectStoreCursor>> m_cursors;
>+
>+    RefPtr<IDBSerializationContext> m_serializationContext;
> };
> 
> } // namespace IDBServer
>diff --git a/Source/WebCore/Modules/indexeddb/server/UniqueIDBDatabase.cpp b/Source/WebCore/Modules/indexeddb/server/UniqueIDBDatabase.cpp
>index fc07ef1451b97e075cd3a56f620093a349c0cbc9..6c8d6ac5e6387f5ff1c42e8de6fa90e2aa7e678c 100644
>--- a/Source/WebCore/Modules/indexeddb/server/UniqueIDBDatabase.cpp
>+++ b/Source/WebCore/Modules/indexeddb/server/UniqueIDBDatabase.cpp
>@@ -46,8 +46,6 @@
> #include "WebCoreJSClientData.h"
> #include <JavaScriptCore/AuxiliaryBarrierInlines.h>
> #include <JavaScriptCore/HeapInlines.h>
>-#include <JavaScriptCore/StrongInlines.h>
>-#include <JavaScriptCore/StructureInlines.h>
> #include <wtf/MainThread.h>
> #include <wtf/NeverDestroyed.h>
> #include <wtf/Scope.h>
>@@ -56,10 +54,40 @@ namespace WebCore {
> using namespace JSC;
> namespace IDBServer {
> 
>+IDBSerializationContext::IDBSerializationContext()
>+    : m_vm(JSC::VM::create())
>+{
>+    m_vm->heap.acquireAccess();
>+    JSVMClientData::initNormalWorld(m_vm.get());
>+    
>+    JSC::JSLockHolder locker(m_vm.get());
>+    m_globalDOMObject = JSC::Strong<JSDOMGlobalObject>(*m_vm, JSDOMGlobalObject::create(*m_vm, JSDOMGlobalObject::createStructure(*m_vm, JSC::jsNull()), normalWorld(*m_vm)));
>+}
>+    
>+IDBSerializationContext::~IDBSerializationContext()
>+{
>+    if (m_vm) {
>+        JSC::JSLockHolder locker(m_vm.get());
>+        m_globalDOMObject.clear();
>+        m_vm = nullptr;
>+    }
>+}
>+
>+VM& IDBSerializationContext::vm()
>+{
>+    return *m_vm;
>+}
>+
>+ExecState& IDBSerializationContext::execState()
>+{
>+    return *m_globalDOMObject.get()->globalExec();
>+}
>+
> UniqueIDBDatabase::UniqueIDBDatabase(IDBServer& server, const IDBDatabaseIdentifier& identifier)
>     : m_server(server)
>     , m_identifier(identifier)
>     , m_operationAndTransactionTimer(*this, &UniqueIDBDatabase::operationAndTransactionTimerFired)
>+    , m_serializationContext(nullptr)
> {
>     LOG(IndexedDB, "UniqueIDBDatabase::UniqueIDBDatabase() (%p) %s", this, m_identifier.debugString().utf8().data());
> }
>@@ -936,26 +964,16 @@ void UniqueIDBDatabase::putOrAdd(const IDBRequestData& requestData, const IDBKey
>     postDatabaseTask(createCrossThreadTask(*this, &UniqueIDBDatabase::performPutOrAdd, callbackID, requestData.transactionIdentifier(), requestData.objectStoreIdentifier(), keyData, value, overwriteMode));
> }
> 
>-VM& UniqueIDBDatabase::databaseThreadVM()
>+void UniqueIDBDatabase::sharedIDBSerializationContext(RefPtr<IDBSerializationContext>& context)
> {
>-    ASSERT(!isMainThread());
>-    static VM* vm = &VM::create().leakRef();
>-    if (!vm->heap.hasAccess()) {
>-        vm->heap.acquireAccess();
>-        JSVMClientData::initNormalWorld(vm);
>-    }
>-
>-    return *vm;
>-}
>-
>-ExecState& UniqueIDBDatabase::databaseThreadExecState()
>-{
>-    ASSERT(!isMainThread());
>-
>-    static NeverDestroyed<Strong<JSDOMGlobalObject>> domGlobalObject(databaseThreadVM(), JSDOMGlobalObject::create(databaseThreadVM(), JSDOMGlobalObject::createStructure(databaseThreadVM(), jsNull()), normalWorld(databaseThreadVM())));
>+    static NeverDestroyed<WeakPtr<IDBSerializationContext>> s_context;
>+    if (context)
>+        return;
> 
>-    RELEASE_ASSERT(domGlobalObject.get()->globalExec());
>-    return *domGlobalObject.get()->globalExec();
>+    auto newContext = adoptRef(*new IDBSerializationContext());
>+    if (!s_context.get().get())
>+        s_context.get() = makeWeakPtr(newContext.ptr());
>+    context = makeRefPtr(s_context.get().get());
> }
> 
> void UniqueIDBDatabase::performPutOrAdd(uint64_t callbackIdentifier, const IDBResourceIdentifier& transactionIdentifier, uint64_t objectStoreIdentifier, const IDBKeyData& keyData, const IDBValue& originalRecordValue, IndexedDB::ObjectStoreOverwriteMode overwriteMode)
>@@ -1011,22 +1029,23 @@ void UniqueIDBDatabase::performPutOrAdd(uint64_t callbackIdentifier, const IDBRe
>     // using steps to assign a key to a value using a key path.
>     ThreadSafeDataBuffer injectedRecordValue;
>     if (usedKeyIsGenerated && objectStoreInfo->keyPath()) {
>-        VM& vm = databaseThreadVM();
>+        sharedIDBSerializationContext(m_serializationContext);
>+        VM& vm = m_serializationContext->vm();
>         JSLockHolder locker(vm);
>         auto scope = DECLARE_THROW_SCOPE(vm);
> 
>-        auto value = deserializeIDBValueToJSValue(databaseThreadExecState(), originalRecordValue.data());
>+        auto value = deserializeIDBValueToJSValue(m_serializationContext->execState(), originalRecordValue.data());
>         if (value.isUndefined()) {
>             postDatabaseTaskReply(createCrossThreadTask(*this, &UniqueIDBDatabase::didPerformPutOrAdd, callbackIdentifier, IDBError(ConstraintError, "Unable to deserialize record value for record key injection"_s), usedKey));
>             return;
>         }
> 
>-        if (!injectIDBKeyIntoScriptValue(databaseThreadExecState(), usedKey, value, objectStoreInfo->keyPath().value())) {
>+        if (!injectIDBKeyIntoScriptValue(m_serializationContext->execState(), usedKey, value, objectStoreInfo->keyPath().value())) {
>             postDatabaseTaskReply(createCrossThreadTask(*this, &UniqueIDBDatabase::didPerformPutOrAdd, callbackIdentifier, IDBError(ConstraintError, "Unable to inject record key into record value"_s), usedKey));
>             return;
>         }
> 
>-        auto serializedValue = SerializedScriptValue::create(databaseThreadExecState(), value);
>+        auto serializedValue = SerializedScriptValue::create(m_serializationContext->execState(), value);
>         if (UNLIKELY(scope.exception())) {
>             postDatabaseTaskReply(createCrossThreadTask(*this, &UniqueIDBDatabase::didPerformPutOrAdd, callbackIdentifier, IDBError(ConstraintError, "Unable to serialize record value after injecting record key"_s), usedKey));
>             return;
>diff --git a/Source/WebCore/Modules/indexeddb/server/UniqueIDBDatabase.h b/Source/WebCore/Modules/indexeddb/server/UniqueIDBDatabase.h
>index d46dfa903cfb35ed7c3538e21c3e2d6c4ab87480..54d46fd5d9e6f07c0693dcda5fb40804d349f81a 100644
>--- a/Source/WebCore/Modules/indexeddb/server/UniqueIDBDatabase.h
>+++ b/Source/WebCore/Modules/indexeddb/server/UniqueIDBDatabase.h
>@@ -35,6 +35,8 @@
> #include "Timer.h"
> #include "UniqueIDBDatabaseConnection.h"
> #include "UniqueIDBDatabaseTransaction.h"
>+#include <JavaScriptCore/StrongInlines.h>
>+#include <JavaScriptCore/StructureInlines.h>
> #include <wtf/CrossThreadQueue.h>
> #include <wtf/CrossThreadTask.h>
> #include <wtf/Deque.h>
>@@ -54,6 +56,7 @@ class IDBError;
> class IDBGetAllResult;
> class IDBRequestData;
> class IDBTransactionInfo;
>+class JSDOMGlobalObject;
> 
> enum class IDBGetRecordDataType;
> 
>@@ -72,6 +75,17 @@ typedef Function<void(const IDBError&, const IDBGetResult&)> GetResultCallback;
> typedef Function<void(const IDBError&, const IDBGetAllResult&)> GetAllResultsCallback;
> typedef Function<void(const IDBError&, uint64_t)> CountCallback;
> 
>+class IDBSerializationContext : public CanMakeWeakPtr<IDBSerializationContext>, public RefCounted<IDBSerializationContext> {
>+public:
>+    IDBSerializationContext();
>+    ~IDBSerializationContext();
>+    JSC::VM& vm();
>+    JSC::ExecState& execState();
>+private:
>+    RefPtr<JSC::VM> m_vm;
>+    JSC::Strong<JSDOMGlobalObject> m_globalDOMObject;
>+};
>+
> class UniqueIDBDatabase : public CanMakeWeakPtr<UniqueIDBDatabase> {
> public:
>     UniqueIDBDatabase(IDBServer&, const IDBDatabaseIdentifier&);
>@@ -113,8 +127,7 @@ public:
>     void handleDelete(IDBConnectionToClient&, const IDBRequestData&);
>     void immediateCloseForUserDelete();
> 
>-    static JSC::VM& databaseThreadVM();
>-    static JSC::ExecState& databaseThreadExecState();
>+    static void sharedIDBSerializationContext(RefPtr<IDBSerializationContext>&);
> 
>     bool hardClosedForUserDelete() const { return m_hardClosedForUserDelete; }
> 
>@@ -271,6 +284,8 @@ private:
>     std::unique_ptr<UniqueIDBDatabase> m_owningPointerForClose;
> 
>     HashSet<IDBResourceIdentifier> m_cursorPrefetches;
>+
>+    RefPtr<IDBSerializationContext> m_serializationContext;
> };
> 
> } // namespace IDBServer

Actions: View | Formatted Diff | Diff

Attachments on bug 192270: 356268 | 356284 | 356426