Index: third_party/WebKit/Source/core/workers/WorkerScriptTest.cpp |
diff --git a/third_party/WebKit/Source/core/workers/WorkerThreadTest.cpp b/third_party/WebKit/Source/core/workers/WorkerScriptTest.cpp |
similarity index 79% |
rename from third_party/WebKit/Source/core/workers/WorkerThreadTest.cpp |
rename to third_party/WebKit/Source/core/workers/WorkerScriptTest.cpp |
index eb93613514f7b0729d63172b36602e463f8e04e5..4dededab1d76aa4fac35b614c0a39618fef8333b 100644 |
--- a/third_party/WebKit/Source/core/workers/WorkerThreadTest.cpp |
+++ b/third_party/WebKit/Source/core/workers/WorkerScriptTest.cpp |
@@ -2,13 +2,13 @@ |
// Use of this source code is governed by a BSD-style license that can be |
// found in the LICENSE file. |
-#include "core/workers/WorkerThread.h" |
+#include "core/workers/WorkerScript.h" |
#include "bindings/core/v8/ScriptCallStack.h" |
#include "bindings/core/v8/V8GCController.h" |
#include "core/inspector/ConsoleMessage.h" |
#include "core/workers/WorkerReportingProxy.h" |
-#include "core/workers/WorkerThreadStartupData.h" |
+#include "core/workers/WorkerScriptStartupData.h" |
#include "platform/NotImplemented.h" |
#include "platform/Task.h" |
#include "platform/ThreadSafeFunctional.h" |
@@ -56,19 +56,19 @@ public: |
MOCK_METHOD1(didEvaluateWorkerScript, void(bool success)); |
MOCK_METHOD1(workerGlobalScopeStarted, void(WorkerGlobalScope*)); |
MOCK_METHOD0(workerGlobalScopeClosed, void()); |
- MOCK_METHOD0(workerThreadTerminated, void()); |
+ MOCK_METHOD0(workerScriptTerminated, void()); |
MOCK_METHOD0(willDestroyWorkerGlobalScope, void()); |
}; |
-void notifyScriptLoadedEventToWorkerThreadForTest(WorkerThread*); |
+void notifyScriptLoadedEventToWorkerScriptForTest(WorkerScript*); |
class FakeWorkerGlobalScope : public WorkerGlobalScope { |
public: |
typedef WorkerGlobalScope Base; |
- FakeWorkerGlobalScope(const KURL& url, const String& userAgent, WorkerThread* thread, PassOwnPtr<SecurityOrigin::PrivilegeData> starterOriginPrivilegeData, PassOwnPtrWillBeRawPtr<WorkerClients> workerClients) |
- : WorkerGlobalScope(url, userAgent, thread, monotonicallyIncreasingTime(), starterOriginPrivilegeData, workerClients) |
- , m_thread(thread) |
+ FakeWorkerGlobalScope(const KURL& url, const String& userAgent, WorkerScript* script, PassOwnPtr<SecurityOrigin::PrivilegeData> starterOriginPrivilegeData, PassOwnPtrWillBeRawPtr<WorkerClients> workerClients) |
+ : WorkerGlobalScope(url, userAgent, script, monotonicallyIncreasingTime(), starterOriginPrivilegeData, workerClients) |
+ , m_script(script) |
{ |
} |
@@ -78,7 +78,7 @@ public: |
void scriptLoaded(size_t, size_t) override |
{ |
- notifyScriptLoadedEventToWorkerThreadForTest(m_thread); |
+ notifyScriptLoadedEventToWorkerScriptForTest(m_script); |
} |
// EventTarget |
@@ -92,23 +92,23 @@ public: |
} |
private: |
- WorkerThread* m_thread; |
+ WorkerScript* m_script; |
}; |
-class WorkerThreadForTest : public WorkerThread { |
+class WorkerScriptForTest : public WorkerScript { |
public: |
- WorkerThreadForTest( |
+ WorkerScriptForTest( |
WorkerLoaderProxyProvider* mockWorkerLoaderProxyProvider, |
WorkerReportingProxy& mockWorkerReportingProxy) |
- : WorkerThread(WorkerLoaderProxy::create(mockWorkerLoaderProxyProvider), mockWorkerReportingProxy) |
+ : WorkerScript(WorkerLoaderProxy::create(mockWorkerLoaderProxyProvider), mockWorkerReportingProxy) |
, m_thread(WebThreadSupportingGC::create("Test thread")) |
, m_scriptLoadedEvent(adoptPtr(new WaitableEvent())) |
{ |
} |
- ~WorkerThreadForTest() override { } |
+ ~WorkerScriptForTest() override { } |
- // WorkerThread implementation: |
+ // WorkerScript implementation: |
WebThreadSupportingGC& backingThread() override |
{ |
return *m_thread; |
@@ -116,10 +116,10 @@ public: |
void willDestroyIsolate() override |
{ |
V8GCController::collectAllGarbageForTesting(v8::Isolate::GetCurrent()); |
- WorkerThread::willDestroyIsolate(); |
+ WorkerScript::willDestroyIsolate(); |
} |
- PassRefPtrWillBeRawPtr<WorkerGlobalScope> createWorkerGlobalScope(PassOwnPtr<WorkerThreadStartupData> startupData) override |
+ PassRefPtrWillBeRawPtr<WorkerGlobalScope> createWorkerGlobalScope(PassOwnPtr<WorkerScriptStartupData> startupData) override |
{ |
return adoptRefWillBeNoop(new FakeWorkerGlobalScope(startupData->m_scriptURL, startupData->m_userAgent, this, startupData->m_starterOriginPrivilegeData.release(), startupData->m_workerClients.release())); |
} |
@@ -139,28 +139,28 @@ private: |
OwnPtr<WaitableEvent> m_scriptLoadedEvent; |
}; |
-void notifyScriptLoadedEventToWorkerThreadForTest(WorkerThread* thread) |
+void notifyScriptLoadedEventToWorkerScriptForTest(WorkerScript* workerScript) |
{ |
- static_cast<WorkerThreadForTest*>(thread)->scriptLoaded(); |
+ static_cast<WorkerScriptForTest*>(workerScript)->scriptLoaded(); |
} |
} // namespace |
-class WorkerThreadTest : public testing::Test { |
+class WorkerScriptTest : public testing::Test { |
public: |
void SetUp() override |
{ |
m_mockWorkerLoaderProxyProvider = adoptPtr(new MockWorkerLoaderProxyProvider()); |
m_mockWorkerReportingProxy = adoptPtr(new MockWorkerReportingProxy()); |
m_securityOrigin = SecurityOrigin::create(KURL(ParsedURLString, "http://fake.url/")); |
- m_workerThread = adoptRef(new WorkerThreadForTest( |
+ m_workerScript = adoptRef(new WorkerScriptForTest( |
m_mockWorkerLoaderProxyProvider.get(), |
*m_mockWorkerReportingProxy)); |
} |
void TearDown() override |
{ |
- m_workerThread->workerLoaderProxy()->detachProvider(m_mockWorkerLoaderProxyProvider.get()); |
+ m_workerScript->workerLoaderProxy()->detachProvider(m_mockWorkerLoaderProxyProvider.get()); |
} |
void start() |
@@ -176,7 +176,7 @@ public: |
OwnPtrWillBeRawPtr<WorkerClients> clients = nullptr; |
- m_workerThread->start(WorkerThreadStartupData::create( |
+ m_workerScript->start(WorkerScriptStartupData::create( |
KURL(ParsedURLString, "http://fake.url/"), |
"fake user agent", |
source, |
@@ -191,7 +191,7 @@ public: |
void waitForInit() |
{ |
OwnPtr<WaitableEvent> completionEvent = adoptPtr(new WaitableEvent()); |
- m_workerThread->backingThread().postTask(BLINK_FROM_HERE, new Task(threadSafeBind(&WaitableEvent::signal, AllowCrossThreadAccess(completionEvent.get())))); |
+ m_workerScript->backingThread().postTask(BLINK_FROM_HERE, new Task(threadSafeBind(&WaitableEvent::signal, AllowCrossThreadAccess(completionEvent.get())))); |
completionEvent->wait(); |
} |
@@ -200,39 +200,39 @@ protected: |
{ |
EXPECT_CALL(*m_mockWorkerReportingProxy, workerGlobalScopeStarted(_)).Times(1); |
EXPECT_CALL(*m_mockWorkerReportingProxy, didEvaluateWorkerScript(true)).Times(1); |
- EXPECT_CALL(*m_mockWorkerReportingProxy, workerThreadTerminated()).Times(1); |
+ EXPECT_CALL(*m_mockWorkerReportingProxy, workerScriptTerminated()).Times(1); |
EXPECT_CALL(*m_mockWorkerReportingProxy, willDestroyWorkerGlobalScope()).Times(1); |
} |
RefPtr<SecurityOrigin> m_securityOrigin; |
OwnPtr<MockWorkerLoaderProxyProvider> m_mockWorkerLoaderProxyProvider; |
OwnPtr<MockWorkerReportingProxy> m_mockWorkerReportingProxy; |
- RefPtr<WorkerThreadForTest> m_workerThread; |
+ RefPtr<WorkerScriptForTest> m_workerScript; |
}; |
-TEST_F(WorkerThreadTest, StartAndStop) |
+TEST_F(WorkerScriptTest, StartAndStop) |
{ |
expectWorkerLifetimeReportingCalls(); |
start(); |
waitForInit(); |
- m_workerThread->terminateAndWait(); |
+ m_workerScript->terminateAndWait(); |
} |
-TEST_F(WorkerThreadTest, StartAndStopImmediately) |
+TEST_F(WorkerScriptTest, StartAndStopImmediately) |
{ |
EXPECT_CALL(*m_mockWorkerReportingProxy, workerGlobalScopeStarted(_)) |
.Times(AtMost(1)); |
EXPECT_CALL(*m_mockWorkerReportingProxy, didEvaluateWorkerScript(_)) |
.Times(AtMost(1)); |
- EXPECT_CALL(*m_mockWorkerReportingProxy, workerThreadTerminated()) |
+ EXPECT_CALL(*m_mockWorkerReportingProxy, workerScriptTerminated()) |
.Times(AtMost(1)); |
EXPECT_CALL(*m_mockWorkerReportingProxy, willDestroyWorkerGlobalScope()) |
.Times(AtMost(1)); |
start(); |
- m_workerThread->terminateAndWait(); |
+ m_workerScript->terminateAndWait(); |
} |
-TEST_F(WorkerThreadTest, StartAndStopOnScriptLoaded) |
+TEST_F(WorkerScriptTest, StartAndStopOnScriptLoaded) |
{ |
// Use a JavaScript source code that makes an infinite loop so that we can |
// catch some kind of issues as a timeout. |
@@ -242,13 +242,13 @@ TEST_F(WorkerThreadTest, StartAndStopOnScriptLoaded) |
.Times(AtMost(1)); |
EXPECT_CALL(*m_mockWorkerReportingProxy, didEvaluateWorkerScript(_)) |
.Times(AtMost(1)); |
- EXPECT_CALL(*m_mockWorkerReportingProxy, workerThreadTerminated()) |
+ EXPECT_CALL(*m_mockWorkerReportingProxy, workerScriptTerminated()) |
.Times(AtMost(1)); |
EXPECT_CALL(*m_mockWorkerReportingProxy, willDestroyWorkerGlobalScope()) |
.Times(AtMost(1)); |
startWithSourceCode(source); |
- m_workerThread->waitUntilScriptLoaded(); |
- m_workerThread->terminateAndWait(); |
+ m_workerScript->waitUntilScriptLoaded(); |
+ m_workerScript->terminateAndWait(); |
} |
} // namespace blink |