| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (C) 2013 Google Inc. All rights reserved. | 2 * Copyright (C) 2013 Google Inc. All rights reserved. |
| 3 * | 3 * |
| 4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
| 5 * modification, are permitted provided that the following conditions are | 5 * modification, are permitted provided that the following conditions are |
| 6 * met: | 6 * met: |
| 7 * | 7 * |
| 8 * * Redistributions of source code must retain the above copyright | 8 * * Redistributions of source code must retain the above copyright |
| 9 * notice, this list of conditions and the following disclaimer. | 9 * notice, this list of conditions and the following disclaimer. |
| 10 * * Redistributions in binary form must reproduce the above | 10 * * Redistributions in binary form must reproduce the above |
| (...skipping 18 matching lines...) Expand all Loading... |
| 29 */ | 29 */ |
| 30 | 30 |
| 31 #include "config.h" | 31 #include "config.h" |
| 32 #include "WorkerStorageQuotaCallbacksBridge.h" | 32 #include "WorkerStorageQuotaCallbacksBridge.h" |
| 33 | 33 |
| 34 #include "WebCommonWorkerClient.h" | 34 #include "WebCommonWorkerClient.h" |
| 35 #include "WebStorageQuotaCallbacks.h" | 35 #include "WebStorageQuotaCallbacks.h" |
| 36 #include "WebStorageQuotaCallbacksImpl.h" | 36 #include "WebStorageQuotaCallbacksImpl.h" |
| 37 #include "WebWorkerBase.h" | 37 #include "WebWorkerBase.h" |
| 38 #include "core/dom/CrossThreadTask.h" | 38 #include "core/dom/CrossThreadTask.h" |
| 39 #include "core/workers/WorkerContext.h" | 39 #include "core/workers/WorkerGlobalScope.h" |
| 40 #include "core/workers/WorkerLoaderProxy.h" | 40 #include "core/workers/WorkerLoaderProxy.h" |
| 41 #include "wtf/MainThread.h" | 41 #include "wtf/MainThread.h" |
| 42 | 42 |
| 43 using namespace WebCore; | 43 using namespace WebCore; |
| 44 | 44 |
| 45 namespace WebKit { | 45 namespace WebKit { |
| 46 | 46 |
| 47 // FIXME: Replace WebFrame parameter in queryStorageUsageAndQuota() with WebStri
ng and move the method to Platform so that we can remove all these complexity fo
r Worker. | 47 // FIXME: Replace WebFrame parameter in queryStorageUsageAndQuota() with WebStri
ng and move the method to Platform so that we can remove all these complexity fo
r Worker. |
| 48 class MainThreadStorageQuotaCallbacks : public WebStorageQuotaCallbacks { | 48 class MainThreadStorageQuotaCallbacks : public WebStorageQuotaCallbacks { |
| 49 public: | 49 public: |
| (...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 83 ASSERT(m_bridge); | 83 ASSERT(m_bridge); |
| 84 } | 84 } |
| 85 | 85 |
| 86 RefPtr<WorkerStorageQuotaCallbacksBridge> m_bridge; | 86 RefPtr<WorkerStorageQuotaCallbacksBridge> m_bridge; |
| 87 const String m_mode; | 87 const String m_mode; |
| 88 }; | 88 }; |
| 89 | 89 |
| 90 // FIXME: Replace WebFrame parameter in queryStorageUsageAndQuota() with WebStri
ng and move the method to Platform so that we can remove all these complexity fo
r Worker." | 90 // FIXME: Replace WebFrame parameter in queryStorageUsageAndQuota() with WebStri
ng and move the method to Platform so that we can remove all these complexity fo
r Worker." |
| 91 // Observes the worker context. By keeping this separate, it is easier to verify | 91 // Observes the worker context. By keeping this separate, it is easier to verify |
| 92 // that it only gets deleted on the worker context thread which is verified by ~
Observer. | 92 // that it only gets deleted on the worker context thread which is verified by ~
Observer. |
| 93 class WorkerStorageQuotaContextObserver : public WebCore::WorkerContext::Observe
r { | 93 class WorkerStorageQuotaContextObserver : public WebCore::WorkerGlobalScope::Obs
erver { |
| 94 public: | 94 public: |
| 95 static PassOwnPtr<WorkerStorageQuotaContextObserver> create(WorkerContext* c
ontext, PassRefPtr<WorkerStorageQuotaCallbacksBridge> bridge) | 95 static PassOwnPtr<WorkerStorageQuotaContextObserver> create(WorkerGlobalScop
e* context, PassRefPtr<WorkerStorageQuotaCallbacksBridge> bridge) |
| 96 { | 96 { |
| 97 return adoptPtr(new WorkerStorageQuotaContextObserver(context, bridge)); | 97 return adoptPtr(new WorkerStorageQuotaContextObserver(context, bridge)); |
| 98 } | 98 } |
| 99 | 99 |
| 100 // WorkerContext::Observer method. | 100 // WorkerGlobalScope::Observer method. |
| 101 virtual void notifyStop() | 101 virtual void notifyStop() |
| 102 { | 102 { |
| 103 m_bridge->stop(); | 103 m_bridge->stop(); |
| 104 } | 104 } |
| 105 | 105 |
| 106 private: | 106 private: |
| 107 WorkerStorageQuotaContextObserver(WorkerContext* context, PassRefPtr<WorkerS
torageQuotaCallbacksBridge> bridge) | 107 WorkerStorageQuotaContextObserver(WorkerGlobalScope* context, PassRefPtr<Wor
kerStorageQuotaCallbacksBridge> bridge) |
| 108 : WebCore::WorkerContext::Observer(context) | 108 : WebCore::WorkerGlobalScope::Observer(context) |
| 109 , m_bridge(bridge) | 109 , m_bridge(bridge) |
| 110 { | 110 { |
| 111 } | 111 } |
| 112 | 112 |
| 113 RefPtr<WorkerStorageQuotaCallbacksBridge> m_bridge; | 113 RefPtr<WorkerStorageQuotaCallbacksBridge> m_bridge; |
| 114 }; | 114 }; |
| 115 | 115 |
| 116 void WorkerStorageQuotaCallbacksBridge::stop() | 116 void WorkerStorageQuotaCallbacksBridge::stop() |
| 117 { | 117 { |
| 118 ASSERT(m_workerContext->isContextThread()); | 118 ASSERT(m_workerGlobalScope->isContextThread()); |
| 119 { | 119 { |
| 120 MutexLocker locker(m_loaderProxyMutex); | 120 MutexLocker locker(m_loaderProxyMutex); |
| 121 m_workerLoaderProxy = 0; | 121 m_workerLoaderProxy = 0; |
| 122 } | 122 } |
| 123 | 123 |
| 124 if (m_callbacksOnWorkerThread) | 124 if (m_callbacksOnWorkerThread) |
| 125 m_callbacksOnWorkerThread->didFail(WebStorageQuotaErrorAbort); | 125 m_callbacksOnWorkerThread->didFail(WebStorageQuotaErrorAbort); |
| 126 | 126 |
| 127 cleanUpAfterCallback(); | 127 cleanUpAfterCallback(); |
| 128 } | 128 } |
| 129 | 129 |
| 130 void WorkerStorageQuotaCallbacksBridge::cleanUpAfterCallback() | 130 void WorkerStorageQuotaCallbacksBridge::cleanUpAfterCallback() |
| 131 { | 131 { |
| 132 ASSERT(m_workerContext->isContextThread()); | 132 ASSERT(m_workerGlobalScope->isContextThread()); |
| 133 | 133 |
| 134 m_callbacksOnWorkerThread = 0; | 134 m_callbacksOnWorkerThread = 0; |
| 135 if (m_workerContextObserver) { | 135 if (m_workerGlobalScopeObserver) { |
| 136 WorkerStorageQuotaContextObserver* observer = m_workerContextObserver; | 136 WorkerStorageQuotaContextObserver* observer = m_workerGlobalScopeObserve
r; |
| 137 m_workerContextObserver = 0; | 137 m_workerGlobalScopeObserver = 0; |
| 138 // The next line may delete this. | 138 // The next line may delete this. |
| 139 delete observer; | 139 delete observer; |
| 140 } | 140 } |
| 141 } | 141 } |
| 142 | 142 |
| 143 WorkerStorageQuotaCallbacksBridge::WorkerStorageQuotaCallbacksBridge(WebCore::Wo
rkerLoaderProxy* workerLoaderProxy, WebCore::ScriptExecutionContext* workerConte
xt, WebStorageQuotaCallbacksImpl* callbacks) | 143 WorkerStorageQuotaCallbacksBridge::WorkerStorageQuotaCallbacksBridge(WebCore::Wo
rkerLoaderProxy* workerLoaderProxy, WebCore::ScriptExecutionContext* workerGloba
lScope, WebStorageQuotaCallbacksImpl* callbacks) |
| 144 : m_workerLoaderProxy(workerLoaderProxy) | 144 : m_workerLoaderProxy(workerLoaderProxy) |
| 145 , m_workerContext(workerContext) | 145 , m_workerGlobalScope(workerGlobalScope) |
| 146 , m_workerContextObserver(WorkerStorageQuotaContextObserver::create(static_c
ast<WorkerContext*>(m_workerContext), this).leakPtr()) | 146 , m_workerGlobalScopeObserver(WorkerStorageQuotaContextObserver::create(stat
ic_cast<WorkerGlobalScope*>(m_workerGlobalScope), this).leakPtr()) |
| 147 , m_callbacksOnWorkerThread(callbacks) | 147 , m_callbacksOnWorkerThread(callbacks) |
| 148 { | 148 { |
| 149 ASSERT(m_workerContext->isContextThread()); | 149 ASSERT(m_workerGlobalScope->isContextThread()); |
| 150 } | 150 } |
| 151 | 151 |
| 152 WorkerStorageQuotaCallbacksBridge::~WorkerStorageQuotaCallbacksBridge() | 152 WorkerStorageQuotaCallbacksBridge::~WorkerStorageQuotaCallbacksBridge() |
| 153 { | 153 { |
| 154 // One way or another, the bridge should be stopped before it is destroyed. | 154 // One way or another, the bridge should be stopped before it is destroyed. |
| 155 ASSERT(!m_callbacksOnWorkerThread); | 155 ASSERT(!m_callbacksOnWorkerThread); |
| 156 } | 156 } |
| 157 | 157 |
| 158 void WorkerStorageQuotaCallbacksBridge::postQueryUsageAndQuotaToMainThread(WebCo
mmonWorkerClient* commonClient, WebStorageQuotaType storageType, const String& m
ode) | 158 void WorkerStorageQuotaCallbacksBridge::postQueryUsageAndQuotaToMainThread(WebCo
mmonWorkerClient* commonClient, WebStorageQuotaType storageType, const String& m
ode) |
| 159 { | 159 { |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 192 { | 192 { |
| 193 ASSERT(isMainThread()); | 193 ASSERT(isMainThread()); |
| 194 taskToRun->performTask(scriptExecutionContext); | 194 taskToRun->performTask(scriptExecutionContext); |
| 195 } | 195 } |
| 196 | 196 |
| 197 void WorkerStorageQuotaCallbacksBridge::runTaskOnWorkerThread(WebCore::ScriptExe
cutionContext* scriptExecutionContext, PassRefPtr<WorkerStorageQuotaCallbacksBri
dge> bridge, PassOwnPtr<WebCore::ScriptExecutionContext::Task> taskToRun) | 197 void WorkerStorageQuotaCallbacksBridge::runTaskOnWorkerThread(WebCore::ScriptExe
cutionContext* scriptExecutionContext, PassRefPtr<WorkerStorageQuotaCallbacksBri
dge> bridge, PassOwnPtr<WebCore::ScriptExecutionContext::Task> taskToRun) |
| 198 { | 198 { |
| 199 ASSERT(bridge); | 199 ASSERT(bridge); |
| 200 if (!bridge->m_callbacksOnWorkerThread) | 200 if (!bridge->m_callbacksOnWorkerThread) |
| 201 return; | 201 return; |
| 202 ASSERT(bridge->m_workerContext); | 202 ASSERT(bridge->m_workerGlobalScope); |
| 203 ASSERT(bridge->m_workerContext->isContextThread()); | 203 ASSERT(bridge->m_workerGlobalScope->isContextThread()); |
| 204 ASSERT(taskToRun); | 204 ASSERT(taskToRun); |
| 205 taskToRun->performTask(scriptExecutionContext); | 205 taskToRun->performTask(scriptExecutionContext); |
| 206 | 206 |
| 207 // taskToRun does the callback. | 207 // taskToRun does the callback. |
| 208 bridge->cleanUpAfterCallback(); | 208 bridge->cleanUpAfterCallback(); |
| 209 | 209 |
| 210 // WorkerStorageQuotaCallbacksBridge may be deleted here when bridge goes ou
t of scope. | 210 // WorkerStorageQuotaCallbacksBridge may be deleted here when bridge goes ou
t of scope. |
| 211 } | 211 } |
| 212 | 212 |
| 213 void WorkerStorageQuotaCallbacksBridge::dispatchTaskToMainThread(PassOwnPtr<WebC
ore::ScriptExecutionContext::Task> task) | 213 void WorkerStorageQuotaCallbacksBridge::dispatchTaskToMainThread(PassOwnPtr<WebC
ore::ScriptExecutionContext::Task> task) |
| 214 { | 214 { |
| 215 ASSERT(m_workerLoaderProxy); | 215 ASSERT(m_workerLoaderProxy); |
| 216 ASSERT(m_workerContext->isContextThread()); | 216 ASSERT(m_workerGlobalScope->isContextThread()); |
| 217 WebWorkerBase::dispatchTaskToMainThread(createCallbackTask(&runTaskOnMainThr
ead, RefPtr<WorkerStorageQuotaCallbacksBridge>(this).release(), task)); | 217 WebWorkerBase::dispatchTaskToMainThread(createCallbackTask(&runTaskOnMainThr
ead, RefPtr<WorkerStorageQuotaCallbacksBridge>(this).release(), task)); |
| 218 } | 218 } |
| 219 | 219 |
| 220 void WorkerStorageQuotaCallbacksBridge::mayPostTaskToWorker(PassOwnPtr<ScriptExe
cutionContext::Task> task, const String& mode) | 220 void WorkerStorageQuotaCallbacksBridge::mayPostTaskToWorker(PassOwnPtr<ScriptExe
cutionContext::Task> task, const String& mode) |
| 221 { | 221 { |
| 222 // Relies on its caller (MainThreadStorageQuotaCallbacks:did*) to keep Worke
rStorageQuotaCallbacksBridge alive. | 222 // Relies on its caller (MainThreadStorageQuotaCallbacks:did*) to keep Worke
rStorageQuotaCallbacksBridge alive. |
| 223 ASSERT(isMainThread()); | 223 ASSERT(isMainThread()); |
| 224 | 224 |
| 225 MutexLocker locker(m_loaderProxyMutex); | 225 MutexLocker locker(m_loaderProxyMutex); |
| 226 if (m_workerLoaderProxy) | 226 if (m_workerLoaderProxy) |
| 227 m_workerLoaderProxy->postTaskForModeToWorkerContext(createCallbackTask(&
runTaskOnWorkerThread, this, task), mode); | 227 m_workerLoaderProxy->postTaskForModeToWorkerGlobalScope(createCallbackTa
sk(&runTaskOnWorkerThread, this, task), mode); |
| 228 } | 228 } |
| 229 | 229 |
| 230 } // namespace WebCore | 230 } // namespace WebCore |
| OLD | NEW |