Index: third_party/WebKit/Source/core/page/NetworkStateNotifierTest.cpp |
diff --git a/third_party/WebKit/Source/core/page/NetworkStateNotifierTest.cpp b/third_party/WebKit/Source/core/page/NetworkStateNotifierTest.cpp |
index 0876f4d78712af358697aac84fc6b1f2063b056b..8a6d4949605aa9ef2b4b360e9c7d894c411dcce6 100644 |
--- a/third_party/WebKit/Source/core/page/NetworkStateNotifierTest.cpp |
+++ b/third_party/WebKit/Source/core/page/NetworkStateNotifierTest.cpp |
@@ -31,6 +31,7 @@ |
#include "core/page/NetworkStateNotifier.h" |
#include "core/dom/Document.h" |
+#include "core/dom/TaskRunnerHelper.h" |
#include "platform/testing/UnitTestHelpers.h" |
#include "public/platform/Platform.h" |
#include "public/platform/WebConnectionType.h" |
@@ -89,9 +90,13 @@ class NetworkStateNotifierTest : public ::testing::Test { |
m_notifier.setWebConnection(WebConnectionTypeUnknown, 0.0); |
} |
- ExecutionContext* getExecutionContext() { return m_document.get(); } |
+ WebTaskRunner* getTaskRunner() { |
+ return TaskRunnerHelper::get(TaskType::Networking, m_document.get()).get(); |
+ } |
- ExecutionContext* executionContext2() { return m_document2.get(); } |
+ WebTaskRunner* getTaskRunner2() { |
+ return TaskRunnerHelper::get(TaskType::Networking, m_document2.get()).get(); |
+ } |
protected: |
void setConnection(WebConnectionType type, double maxBandwidthMbps) { |
@@ -101,17 +106,16 @@ class NetworkStateNotifierTest : public ::testing::Test { |
void addObserverOnNotification(StateObserver* observer, |
StateObserver* observerToAdd) { |
- observer->setNotificationCallback(bind( |
- &NetworkStateNotifier::addObserver, WTF::unretained(&m_notifier), |
- WTF::unretained(observerToAdd), wrapPersistent(getExecutionContext()))); |
+ observer->setNotificationCallback( |
+ bind(&NetworkStateNotifier::addObserver, WTF::unretained(&m_notifier), |
+ WTF::unretained(observerToAdd), WTF::unretained(getTaskRunner()))); |
} |
void removeObserverOnNotification(StateObserver* observer, |
StateObserver* observerToRemove) { |
- observer->setNotificationCallback( |
- bind(&NetworkStateNotifier::removeObserver, |
- WTF::unretained(&m_notifier), WTF::unretained(observerToRemove), |
- wrapPersistent(getExecutionContext()))); |
+ observer->setNotificationCallback(bind( |
+ &NetworkStateNotifier::removeObserver, WTF::unretained(&m_notifier), |
+ WTF::unretained(observerToRemove), WTF::unretained(getTaskRunner()))); |
} |
bool verifyObservations(const StateObserver& observer, |
@@ -130,7 +134,7 @@ class NetworkStateNotifierTest : public ::testing::Test { |
TEST_F(NetworkStateNotifierTest, AddObserver) { |
StateObserver observer; |
- m_notifier.addObserver(&observer, getExecutionContext()); |
+ m_notifier.addObserver(&observer, getTaskRunner()); |
EXPECT_TRUE(verifyObservations(observer, WebConnectionTypeNone, |
kNoneMaxBandwidthMbps)); |
@@ -142,9 +146,9 @@ TEST_F(NetworkStateNotifierTest, AddObserver) { |
TEST_F(NetworkStateNotifierTest, RemoveObserver) { |
StateObserver observer1, observer2; |
- m_notifier.addObserver(&observer1, getExecutionContext()); |
- m_notifier.removeObserver(&observer1, getExecutionContext()); |
- m_notifier.addObserver(&observer2, getExecutionContext()); |
+ m_notifier.addObserver(&observer1, getTaskRunner()); |
+ m_notifier.removeObserver(&observer1, getTaskRunner()); |
+ m_notifier.addObserver(&observer2, getTaskRunner()); |
setConnection(WebConnectionTypeBluetooth, kBluetoothMaxBandwidthMbps); |
EXPECT_TRUE(verifyObservations(observer1, WebConnectionTypeNone, |
@@ -155,8 +159,8 @@ TEST_F(NetworkStateNotifierTest, RemoveObserver) { |
TEST_F(NetworkStateNotifierTest, RemoveSoleObserver) { |
StateObserver observer1; |
- m_notifier.addObserver(&observer1, getExecutionContext()); |
- m_notifier.removeObserver(&observer1, getExecutionContext()); |
+ m_notifier.addObserver(&observer1, getTaskRunner()); |
+ m_notifier.removeObserver(&observer1, getTaskRunner()); |
setConnection(WebConnectionTypeBluetooth, kBluetoothMaxBandwidthMbps); |
EXPECT_TRUE(verifyObservations(observer1, WebConnectionTypeNone, |
@@ -165,7 +169,7 @@ TEST_F(NetworkStateNotifierTest, RemoveSoleObserver) { |
TEST_F(NetworkStateNotifierTest, AddObserverWhileNotifying) { |
StateObserver observer1, observer2; |
- m_notifier.addObserver(&observer1, getExecutionContext()); |
+ m_notifier.addObserver(&observer1, getTaskRunner()); |
addObserverOnNotification(&observer1, &observer2); |
setConnection(WebConnectionTypeBluetooth, kBluetoothMaxBandwidthMbps); |
@@ -177,7 +181,7 @@ TEST_F(NetworkStateNotifierTest, AddObserverWhileNotifying) { |
TEST_F(NetworkStateNotifierTest, RemoveSoleObserverWhileNotifying) { |
StateObserver observer1; |
- m_notifier.addObserver(&observer1, getExecutionContext()); |
+ m_notifier.addObserver(&observer1, getTaskRunner()); |
removeObserverOnNotification(&observer1, &observer1); |
setConnection(WebConnectionTypeBluetooth, kBluetoothMaxBandwidthMbps); |
@@ -191,8 +195,8 @@ TEST_F(NetworkStateNotifierTest, RemoveSoleObserverWhileNotifying) { |
TEST_F(NetworkStateNotifierTest, RemoveCurrentObserverWhileNotifying) { |
StateObserver observer1, observer2; |
- m_notifier.addObserver(&observer1, getExecutionContext()); |
- m_notifier.addObserver(&observer2, getExecutionContext()); |
+ m_notifier.addObserver(&observer1, getTaskRunner()); |
+ m_notifier.addObserver(&observer2, getTaskRunner()); |
removeObserverOnNotification(&observer1, &observer1); |
setConnection(WebConnectionTypeBluetooth, kBluetoothMaxBandwidthMbps); |
@@ -210,8 +214,8 @@ TEST_F(NetworkStateNotifierTest, RemoveCurrentObserverWhileNotifying) { |
TEST_F(NetworkStateNotifierTest, RemovePastObserverWhileNotifying) { |
StateObserver observer1, observer2; |
- m_notifier.addObserver(&observer1, getExecutionContext()); |
- m_notifier.addObserver(&observer2, getExecutionContext()); |
+ m_notifier.addObserver(&observer1, getTaskRunner()); |
+ m_notifier.addObserver(&observer2, getTaskRunner()); |
removeObserverOnNotification(&observer2, &observer1); |
setConnection(WebConnectionTypeBluetooth, kBluetoothMaxBandwidthMbps); |
@@ -227,9 +231,9 @@ TEST_F(NetworkStateNotifierTest, RemovePastObserverWhileNotifying) { |
TEST_F(NetworkStateNotifierTest, RemoveFutureObserverWhileNotifying) { |
StateObserver observer1, observer2, observer3; |
- m_notifier.addObserver(&observer1, getExecutionContext()); |
- m_notifier.addObserver(&observer2, getExecutionContext()); |
- m_notifier.addObserver(&observer3, getExecutionContext()); |
+ m_notifier.addObserver(&observer1, getTaskRunner()); |
+ m_notifier.addObserver(&observer2, getTaskRunner()); |
+ m_notifier.addObserver(&observer3, getTaskRunner()); |
removeObserverOnNotification(&observer1, &observer2); |
setConnection(WebConnectionTypeBluetooth, kBluetoothMaxBandwidthMbps); |
@@ -243,8 +247,8 @@ TEST_F(NetworkStateNotifierTest, RemoveFutureObserverWhileNotifying) { |
TEST_F(NetworkStateNotifierTest, MultipleContextsAddObserver) { |
StateObserver observer1, observer2; |
- m_notifier.addObserver(&observer1, getExecutionContext()); |
- m_notifier.addObserver(&observer2, executionContext2()); |
+ m_notifier.addObserver(&observer1, getTaskRunner()); |
+ m_notifier.addObserver(&observer2, getTaskRunner2()); |
setConnection(WebConnectionTypeBluetooth, kBluetoothMaxBandwidthMbps); |
EXPECT_TRUE(verifyObservations(observer1, WebConnectionTypeBluetooth, |
@@ -255,9 +259,9 @@ TEST_F(NetworkStateNotifierTest, MultipleContextsAddObserver) { |
TEST_F(NetworkStateNotifierTest, RemoveContext) { |
StateObserver observer1, observer2; |
- m_notifier.addObserver(&observer1, getExecutionContext()); |
- m_notifier.addObserver(&observer2, executionContext2()); |
- m_notifier.removeObserver(&observer2, executionContext2()); |
+ m_notifier.addObserver(&observer1, getTaskRunner()); |
+ m_notifier.addObserver(&observer2, getTaskRunner2()); |
+ m_notifier.removeObserver(&observer2, getTaskRunner2()); |
setConnection(WebConnectionTypeBluetooth, kBluetoothMaxBandwidthMbps); |
EXPECT_TRUE(verifyObservations(observer1, WebConnectionTypeBluetooth, |
@@ -268,10 +272,10 @@ TEST_F(NetworkStateNotifierTest, RemoveContext) { |
TEST_F(NetworkStateNotifierTest, RemoveAllContexts) { |
StateObserver observer1, observer2; |
- m_notifier.addObserver(&observer1, getExecutionContext()); |
- m_notifier.addObserver(&observer2, executionContext2()); |
- m_notifier.removeObserver(&observer1, getExecutionContext()); |
- m_notifier.removeObserver(&observer2, executionContext2()); |
+ m_notifier.addObserver(&observer1, getTaskRunner()); |
+ m_notifier.addObserver(&observer2, getTaskRunner2()); |
+ m_notifier.removeObserver(&observer1, getTaskRunner()); |
+ m_notifier.removeObserver(&observer2, getTaskRunner2()); |
setConnection(WebConnectionTypeBluetooth, kBluetoothMaxBandwidthMbps); |
EXPECT_TRUE(verifyObservations(observer1, WebConnectionTypeNone, |
@@ -282,7 +286,7 @@ TEST_F(NetworkStateNotifierTest, RemoveAllContexts) { |
TEST_F(NetworkStateNotifierTest, SetOverride) { |
StateObserver observer; |
- m_notifier.addObserver(&observer, getExecutionContext()); |
+ m_notifier.addObserver(&observer, getTaskRunner()); |
m_notifier.setOnLine(true); |
setConnection(WebConnectionTypeBluetooth, kBluetoothMaxBandwidthMbps); |
@@ -320,12 +324,12 @@ TEST_F(NetworkStateNotifierTest, SetOverride) { |
EXPECT_EQ(WebConnectionTypeNone, m_notifier.connectionType()); |
EXPECT_EQ(kNoneMaxBandwidthMbps, m_notifier.maxBandwidth()); |
- m_notifier.removeObserver(&observer, getExecutionContext()); |
+ m_notifier.removeObserver(&observer, getTaskRunner()); |
} |
TEST_F(NetworkStateNotifierTest, NoExtraNotifications) { |
StateObserver observer; |
- m_notifier.addObserver(&observer, getExecutionContext()); |
+ m_notifier.addObserver(&observer, getTaskRunner()); |
setConnection(WebConnectionTypeBluetooth, kBluetoothMaxBandwidthMbps); |
EXPECT_TRUE(verifyObservations(observer, WebConnectionTypeBluetooth, |
@@ -348,7 +352,7 @@ TEST_F(NetworkStateNotifierTest, NoExtraNotifications) { |
kBluetoothMaxBandwidthMbps)); |
EXPECT_EQ(observer.callbackCount(), 3); |
- m_notifier.removeObserver(&observer, getExecutionContext()); |
+ m_notifier.removeObserver(&observer, getTaskRunner()); |
} |
TEST_F(NetworkStateNotifierTest, NoNotificationOnInitialization) { |
@@ -356,7 +360,7 @@ TEST_F(NetworkStateNotifierTest, NoNotificationOnInitialization) { |
Persistent<Document> document(Document::create()); |
StateObserver observer; |
- notifier.addObserver(&observer, document.get()); |
+ notifier.addObserver(&observer, getTaskRunner()); |
testing::runPendingTasks(); |
EXPECT_EQ(observer.callbackCount(), 0); |