| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "config.h" | 5 #include "config.h" |
| 6 #include "modules/compositorworker/CompositorWorkerManager.h" | 6 #include "modules/compositorworker/CompositorWorkerManager.h" |
| 7 | 7 |
| 8 #include "bindings/core/v8/ScriptSourceCode.h" | 8 #include "bindings/core/v8/ScriptSourceCode.h" |
| 9 #include "core/inspector/ConsoleMessage.h" | 9 #include "core/inspector/ConsoleMessage.h" |
| 10 #include "core/testing/DummyPageHolder.h" | 10 #include "core/testing/DummyPageHolder.h" |
| (...skipping 106 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 117 | 117 |
| 118 void createWorkerAdapter(RefPtr<CompositorWorkerThread>* workerThread, WebWa
itableEvent* creationEvent) | 118 void createWorkerAdapter(RefPtr<CompositorWorkerThread>* workerThread, WebWa
itableEvent* creationEvent) |
| 119 { | 119 { |
| 120 *workerThread = createCompositorWorker(creationEvent); | 120 *workerThread = createCompositorWorker(creationEvent); |
| 121 } | 121 } |
| 122 | 122 |
| 123 // Attempts to run some simple script for |worker|. | 123 // Attempts to run some simple script for |worker|. |
| 124 void checkWorkerCanExecuteScript(WorkerThread* worker) | 124 void checkWorkerCanExecuteScript(WorkerThread* worker) |
| 125 { | 125 { |
| 126 OwnPtr<WebWaitableEvent> waitEvent = adoptPtr(Platform::current()->creat
eWaitableEvent()); | 126 OwnPtr<WebWaitableEvent> waitEvent = adoptPtr(Platform::current()->creat
eWaitableEvent()); |
| 127 worker->backingThread().platformThread().postTask(FROM_HERE, threadSafeB
ind(&CompositorWorkerManagerTest::executeScriptInWorker, AllowCrossThreadAccess(
this), | 127 worker->backingThread().postTask(FROM_HERE, threadSafeBind(&CompositorWo
rkerManagerTest::executeScriptInWorker, AllowCrossThreadAccess(this), |
| 128 AllowCrossThreadAccess(worker), AllowCrossThreadAccess(waitEvent.get
()))); | 128 AllowCrossThreadAccess(worker), AllowCrossThreadAccess(waitEvent.get
()))); |
| 129 waitEvent->wait(); | 129 waitEvent->wait(); |
| 130 } | 130 } |
| 131 | 131 |
| 132 void waitForWaitableEventAfterIteratingCurrentLoop(WebWaitableEvent* waitEve
nt) | 132 void waitForWaitableEventAfterIteratingCurrentLoop(WebWaitableEvent* waitEve
nt) |
| 133 { | 133 { |
| 134 testing::runPendingTasks(); | 134 testing::runPendingTasks(); |
| 135 waitEvent->wait(); | 135 waitEvent->wait(); |
| 136 } | 136 } |
| 137 | 137 |
| (...skipping 29 matching lines...) Expand all Loading... |
| 167 checkWorkerCanExecuteScript(compositorWorker.get()); | 167 checkWorkerCanExecuteScript(compositorWorker.get()); |
| 168 compositorWorker->terminateAndWait(); | 168 compositorWorker->terminateAndWait(); |
| 169 } | 169 } |
| 170 | 170 |
| 171 // Tests that the same WebThread is used for new workers if the WebThread is sti
ll alive. | 171 // Tests that the same WebThread is used for new workers if the WebThread is sti
ll alive. |
| 172 TEST_F(CompositorWorkerManagerTest, CreateSecondAndTerminateFirst) | 172 TEST_F(CompositorWorkerManagerTest, CreateSecondAndTerminateFirst) |
| 173 { | 173 { |
| 174 // Create the first worker and wait until it is initialized. | 174 // Create the first worker and wait until it is initialized. |
| 175 OwnPtr<WebWaitableEvent> firstCreationEvent = adoptPtr(Platform::current()->
createWaitableEvent()); | 175 OwnPtr<WebWaitableEvent> firstCreationEvent = adoptPtr(Platform::current()->
createWaitableEvent()); |
| 176 RefPtr<CompositorWorkerThread> firstWorker = createCompositorWorker(firstCre
ationEvent.get()); | 176 RefPtr<CompositorWorkerThread> firstWorker = createCompositorWorker(firstCre
ationEvent.get()); |
| 177 WebThreadSupportingGC* firstThread = &CompositorWorkerManager::instance()->c
ompositorWorkerThread(); | 177 WebThread* firstThread = &CompositorWorkerManager::instance()->compositorWor
kerThread(); |
| 178 ASSERT(firstThread); | 178 ASSERT(firstThread); |
| 179 waitForWaitableEventAfterIteratingCurrentLoop(firstCreationEvent.get()); | 179 waitForWaitableEventAfterIteratingCurrentLoop(firstCreationEvent.get()); |
| 180 v8::Isolate* firstIsolate = firstWorker->isolate(); | 180 v8::Isolate* firstIsolate = firstWorker->isolate(); |
| 181 ASSERT(firstIsolate); | 181 ASSERT(firstIsolate); |
| 182 | 182 |
| 183 // Create the second worker and immediately destroy the first worker. | 183 // Create the second worker and immediately destroy the first worker. |
| 184 OwnPtr<WebWaitableEvent> secondCreationEvent = adoptPtr(Platform::current()-
>createWaitableEvent()); | 184 OwnPtr<WebWaitableEvent> secondCreationEvent = adoptPtr(Platform::current()-
>createWaitableEvent()); |
| 185 RefPtr<CompositorWorkerThread> secondWorker = createCompositorWorker(secondC
reationEvent.get()); | 185 RefPtr<CompositorWorkerThread> secondWorker = createCompositorWorker(secondC
reationEvent.get()); |
| 186 firstWorker->terminateAndWait(); | 186 firstWorker->terminateAndWait(); |
| 187 | 187 |
| 188 // Wait until the second worker is initialized. Verify that the second worke
r is using the same | 188 // Wait until the second worker is initialized. Verify that the second worke
r is using the same |
| 189 // thread and Isolate as the first worker. | 189 // thread and Isolate as the first worker. |
| 190 WebThreadSupportingGC* secondThread = &CompositorWorkerManager::instance()->
compositorWorkerThread(); | 190 WebThread* secondThread = &CompositorWorkerManager::instance()->compositorWo
rkerThread(); |
| 191 ASSERT(secondThread); | 191 ASSERT(secondThread); |
| 192 waitForWaitableEventAfterIteratingCurrentLoop(secondCreationEvent.get()); | 192 waitForWaitableEventAfterIteratingCurrentLoop(secondCreationEvent.get()); |
| 193 EXPECT_EQ(firstThread, secondThread); | 193 EXPECT_EQ(firstThread, secondThread); |
| 194 | 194 |
| 195 v8::Isolate* secondIsolate = secondWorker->isolate(); | 195 v8::Isolate* secondIsolate = secondWorker->isolate(); |
| 196 ASSERT(secondIsolate); | 196 ASSERT(secondIsolate); |
| 197 EXPECT_EQ(firstIsolate, secondIsolate); | 197 EXPECT_EQ(firstIsolate, secondIsolate); |
| 198 | 198 |
| 199 // Verify that the worker can still successfully execute script. | 199 // Verify that the worker can still successfully execute script. |
| 200 checkWorkerCanExecuteScript(secondWorker.get()); | 200 checkWorkerCanExecuteScript(secondWorker.get()); |
| 201 | 201 |
| 202 secondWorker->terminateAndWait(); | 202 secondWorker->terminateAndWait(); |
| 203 } | 203 } |
| 204 | 204 |
| 205 static void checkCurrentIsolate(v8::Isolate* isolate, WebWaitableEvent* event) | 205 static void checkCurrentIsolate(v8::Isolate* isolate, WebWaitableEvent* event) |
| 206 { | 206 { |
| 207 EXPECT_EQ(v8::Isolate::GetCurrent(), isolate); | 207 EXPECT_EQ(v8::Isolate::GetCurrent(), isolate); |
| 208 event->signal(); | 208 event->signal(); |
| 209 } | 209 } |
| 210 | 210 |
| 211 // Tests that a new WebThread is created if all existing workers are terminated
before a new worker is created. | 211 // Tests that a new WebThread is created if all existing workers are terminated
before a new worker is created. |
| 212 TEST_F(CompositorWorkerManagerTest, TerminateFirstAndCreateSecond) | 212 TEST_F(CompositorWorkerManagerTest, TerminateFirstAndCreateSecond) |
| 213 { | 213 { |
| 214 // Create the first worker, wait until it is initialized, and terminate it. | 214 // Create the first worker, wait until it is initialized, and terminate it. |
| 215 OwnPtr<WebWaitableEvent> creationEvent = adoptPtr(Platform::current()->creat
eWaitableEvent()); | 215 OwnPtr<WebWaitableEvent> creationEvent = adoptPtr(Platform::current()->creat
eWaitableEvent()); |
| 216 RefPtr<CompositorWorkerThread> compositorWorker = createCompositorWorker(cre
ationEvent.get()); | 216 RefPtr<CompositorWorkerThread> compositorWorker = createCompositorWorker(cre
ationEvent.get()); |
| 217 WebThreadSupportingGC* firstThread = &CompositorWorkerManager::instance()->c
ompositorWorkerThread(); | 217 WebThread* firstThread = &CompositorWorkerManager::instance()->compositorWor
kerThread(); |
| 218 waitForWaitableEventAfterIteratingCurrentLoop(creationEvent.get()); | 218 waitForWaitableEventAfterIteratingCurrentLoop(creationEvent.get()); |
| 219 ASSERT(compositorWorker->isolate()); | 219 ASSERT(compositorWorker->isolate()); |
| 220 compositorWorker->terminateAndWait(); | 220 compositorWorker->terminateAndWait(); |
| 221 | 221 |
| 222 // Create the second worker. Verify that the second worker lives in a differ
ent WebThread since the first | 222 // Create the second worker. Verify that the second worker lives in a differ
ent WebThread since the first |
| 223 // thread will have been destroyed after destroying the first worker. | 223 // thread will have been destroyed after destroying the first worker. |
| 224 creationEvent = adoptPtr(Platform::current()->createWaitableEvent()); | 224 creationEvent = adoptPtr(Platform::current()->createWaitableEvent()); |
| 225 compositorWorker = createCompositorWorker(creationEvent.get()); | 225 compositorWorker = createCompositorWorker(creationEvent.get()); |
| 226 WebThreadSupportingGC* secondThread = &CompositorWorkerManager::instance()->
compositorWorkerThread(); | 226 WebThread* secondThread = &CompositorWorkerManager::instance()->compositorWo
rkerThread(); |
| 227 EXPECT_NE(firstThread, secondThread); | 227 EXPECT_NE(firstThread, secondThread); |
| 228 waitForWaitableEventAfterIteratingCurrentLoop(creationEvent.get()); | 228 waitForWaitableEventAfterIteratingCurrentLoop(creationEvent.get()); |
| 229 | 229 |
| 230 // Jump over to the worker's thread to verify that the Isolate is set up cor
rectly and execute script. | 230 // Jump over to the worker's thread to verify that the Isolate is set up cor
rectly and execute script. |
| 231 OwnPtr<WebWaitableEvent> checkEvent = adoptPtr(Platform::current()->createWa
itableEvent()); | 231 OwnPtr<WebWaitableEvent> checkEvent = adoptPtr(Platform::current()->createWa
itableEvent()); |
| 232 secondThread->platformThread().postTask(FROM_HERE, threadSafeBind(&checkCurr
entIsolate, AllowCrossThreadAccess(compositorWorker->isolate()), AllowCrossThrea
dAccess(checkEvent.get()))); | 232 secondThread->postTask(FROM_HERE, threadSafeBind(&checkCurrentIsolate, Allow
CrossThreadAccess(compositorWorker->isolate()), AllowCrossThreadAccess(checkEven
t.get()))); |
| 233 waitForWaitableEventAfterIteratingCurrentLoop(checkEvent.get()); | 233 waitForWaitableEventAfterIteratingCurrentLoop(checkEvent.get()); |
| 234 checkWorkerCanExecuteScript(compositorWorker.get()); | 234 checkWorkerCanExecuteScript(compositorWorker.get()); |
| 235 | 235 |
| 236 compositorWorker->terminateAndWait(); | 236 compositorWorker->terminateAndWait(); |
| 237 } | 237 } |
| 238 | 238 |
| 239 // Tests that v8::Isolate and WebThread are correctly set-up if a worker is crea
ted while another is terminating. | 239 // Tests that v8::Isolate and WebThread are correctly set-up if a worker is crea
ted while another is terminating. |
| 240 TEST_F(CompositorWorkerManagerTest, CreatingSecondDuringTerminationOfFirst) | 240 TEST_F(CompositorWorkerManagerTest, CreatingSecondDuringTerminationOfFirst) |
| 241 { | 241 { |
| 242 OwnPtr<WebWaitableEvent> firstCreationEvent = adoptPtr(Platform::current()->
createWaitableEvent()); | 242 OwnPtr<WebWaitableEvent> firstCreationEvent = adoptPtr(Platform::current()->
createWaitableEvent()); |
| (...skipping 14 matching lines...) Expand all Loading... |
| 257 v8::Isolate* secondIsolate = secondWorker->isolate(); | 257 v8::Isolate* secondIsolate = secondWorker->isolate(); |
| 258 ASSERT(secondIsolate); | 258 ASSERT(secondIsolate); |
| 259 EXPECT_EQ(firstIsolate, secondIsolate); | 259 EXPECT_EQ(firstIsolate, secondIsolate); |
| 260 | 260 |
| 261 // Verify that the isolate can run some scripts correctly in the second work
er. | 261 // Verify that the isolate can run some scripts correctly in the second work
er. |
| 262 checkWorkerCanExecuteScript(secondWorker.get()); | 262 checkWorkerCanExecuteScript(secondWorker.get()); |
| 263 secondWorker->terminateAndWait(); | 263 secondWorker->terminateAndWait(); |
| 264 } | 264 } |
| 265 | 265 |
| 266 } // namespace blink | 266 } // namespace blink |
| OLD | NEW |