| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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 "core/page/EventSource.h" | 5 #include "core/page/EventSource.h" |
| 6 | 6 |
| 7 #include "bindings/core/v8/ExceptionState.h" | 7 #include "bindings/core/v8/ExceptionState.h" |
| 8 #include "bindings/core/v8/ScriptState.h" | 8 #include "bindings/core/v8/ScriptState.h" |
| 9 #include "bindings/core/v8/ScriptValue.h" | 9 #include "bindings/core/v8/ScriptValue.h" |
| 10 #include "bindings/core/v8/SerializedScriptValue.h" | 10 #include "bindings/core/v8/SerializedScriptValue.h" |
| (...skipping 233 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 244 EXPECT_NE(EventSource::defaultReconnectDelay, source()->reconnectDelayForTes
t()); | 244 EXPECT_NE(EventSource::defaultReconnectDelay, source()->reconnectDelayForTes
t()); |
| 245 EXPECT_EQ(123u, source()->reconnectDelayForTest()); | 245 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
| 246 | 246 |
| 247 EXPECT_EQ(123u, source()->reconnectDelayForTest()); | 247 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
| 248 enqueue("retry:a0\n"); | 248 enqueue("retry:a0\n"); |
| 249 EXPECT_EQ(123u, source()->reconnectDelayForTest()); | 249 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
| 250 enqueue("retry:xi\n"); | 250 enqueue("retry:xi\n"); |
| 251 EXPECT_EQ(123u, source()->reconnectDelayForTest()); | 251 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
| 252 | 252 |
| 253 enqueue("retry:2a\n"); | 253 enqueue("retry:2a\n"); |
| 254 // TODO(yhirano): Should be ignored. | 254 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
| 255 // EXPECT_EQ(123u, source()->reconnectDelayForTest()); | |
| 256 EXPECT_EQ(2u, source()->reconnectDelayForTest()); | |
| 257 | 255 |
| 258 enqueue("retry:09a\n"); | 256 enqueue("retry:09a\n"); |
| 259 // TODO(yhirano): Should be ignored. | 257 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
| 260 // EXPECT_EQ(123u, source()->reconnectDelayForTest()); | |
| 261 EXPECT_EQ(9u, source()->reconnectDelayForTest()); | |
| 262 | 258 |
| 263 enqueue("retry:1\b\n"); | 259 enqueue("retry:1\b\n"); |
| 264 // TODO(yhirano): Should be ignored. | 260 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
| 265 // EXPECT_EQ(123u, source()->reconnectDelayForTest()); | |
| 266 EXPECT_EQ(1u, source()->reconnectDelayForTest()); | |
| 267 | 261 |
| 268 enqueue("retry: 1234\n"); | 262 enqueue("retry: 1234\n"); |
| 269 // TODO(yhirano): Should be ignored. | 263 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
| 270 // EXPECT_EQ(123u, source()->reconnectDelayForTest()); | |
| 271 EXPECT_EQ(1234u, source()->reconnectDelayForTest()); | |
| 272 | 264 |
| 273 enqueue("retry:456 \n"); | 265 enqueue("retry:456 \n"); |
| 274 // TODO(yhirano): Should be ignored. | 266 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
| 275 // EXPECT_EQ(123u, source()->reconnectDelayForTest()); | |
| 276 EXPECT_EQ(456u, source()->reconnectDelayForTest()); | |
| 277 | 267 |
| 278 EXPECT_EQ(0u, listener->events().size()); | 268 EXPECT_EQ(0u, listener->events().size()); |
| 279 } | 269 } |
| 280 | 270 |
| 281 TEST_F(EventSourceTest, UnrecognizedFieldShouldBeIgnored) | 271 TEST_F(EventSourceTest, UnrecognizedFieldShouldBeIgnored) |
| 282 { | 272 { |
| 283 RefPtrWillBeRawPtr<FakeEventListener> listener = FakeEventListener::create()
; | 273 RefPtrWillBeRawPtr<FakeEventListener> listener = FakeEventListener::create()
; |
| 284 | 274 |
| 285 source()->addEventListener("message", listener); | 275 source()->addEventListener("message", listener); |
| 286 enqueue("data:hello\nhoge:fuga\npiyo\n\n"); | 276 enqueue("data:hello\nhoge:fuga\npiyo\n\n"); |
| (...skipping 119 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 406 ASSERT_EQ("message", messageListener->events()[0]->type()); | 396 ASSERT_EQ("message", messageListener->events()[0]->type()); |
| 407 RefPtrWillBeRawPtr<MessageEvent> messageEvent = static_cast<MessageEvent*>(m
essageListener->events()[0].get()); | 397 RefPtrWillBeRawPtr<MessageEvent> messageEvent = static_cast<MessageEvent*>(m
essageListener->events()[0].get()); |
| 408 ASSERT_EQ(MessageEvent::DataTypeSerializedScriptValue, messageEvent->dataTyp
e()); | 398 ASSERT_EQ(MessageEvent::DataTypeSerializedScriptValue, messageEvent->dataTyp
e()); |
| 409 EXPECT_EQ("bye", dataAsString(scriptState(), messageEvent.get())); | 399 EXPECT_EQ("bye", dataAsString(scriptState(), messageEvent.get())); |
| 410 EXPECT_EQ("8", messageEvent->lastEventId()); | 400 EXPECT_EQ("8", messageEvent->lastEventId()); |
| 411 } | 401 } |
| 412 | 402 |
| 413 } // namespace | 403 } // namespace |
| 414 | 404 |
| 415 } // namespace blink | 405 } // namespace blink |
| OLD | NEW |