| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "modules/websockets/WebSocketChannel.h" | 5 #include "modules/websockets/WebSocketChannel.h" |
| 6 | 6 |
| 7 #include "core/dom/DOMArrayBuffer.h" | 7 #include "core/dom/DOMArrayBuffer.h" |
| 8 #include "core/dom/Document.h" | 8 #include "core/dom/Document.h" |
| 9 #include "core/fileapi/Blob.h" | 9 #include "core/fileapi/Blob.h" |
| 10 #include "core/testing/DummyPageHolder.h" | 10 #include "core/testing/DummyPageHolder.h" |
| (...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 73 public: | 73 public: |
| 74 static MockWebSocketHandle* create() | 74 static MockWebSocketHandle* create() |
| 75 { | 75 { |
| 76 return new testing::StrictMock<MockWebSocketHandle>(); | 76 return new testing::StrictMock<MockWebSocketHandle>(); |
| 77 } | 77 } |
| 78 | 78 |
| 79 MockWebSocketHandle() { } | 79 MockWebSocketHandle() { } |
| 80 | 80 |
| 81 ~MockWebSocketHandle() override { } | 81 ~MockWebSocketHandle() override { } |
| 82 | 82 |
| 83 MOCK_METHOD4(connect, void(const WebURL&, const WebVector<WebString>&, const
WebSecurityOrigin&, WebSocketHandleClient*)); | 83 MOCK_METHOD5(connect, void(const WebURL&, const WebVector<WebString>&, const
WebSecurityOrigin&, const WebString&, WebSocketHandleClient*)); |
| 84 MOCK_METHOD4(send, void(bool, WebSocketHandle::MessageType, const char*, siz
e_t)); | 84 MOCK_METHOD4(send, void(bool, WebSocketHandle::MessageType, const char*, siz
e_t)); |
| 85 MOCK_METHOD1(flowControl, void(int64_t)); | 85 MOCK_METHOD1(flowControl, void(int64_t)); |
| 86 MOCK_METHOD2(close, void(unsigned short, const WebString&)); | 86 MOCK_METHOD2(close, void(unsigned short, const WebString&)); |
| 87 }; | 87 }; |
| 88 | 88 |
| 89 class DocumentWebSocketChannelTest : public ::testing::Test { | 89 class DocumentWebSocketChannelTest : public ::testing::Test { |
| 90 public: | 90 public: |
| 91 DocumentWebSocketChannelTest() | 91 DocumentWebSocketChannelTest() |
| 92 : m_pageHolder(DummyPageHolder::create()) | 92 : m_pageHolder(DummyPageHolder::create()) |
| 93 , m_channelClient(MockWebSocketChannelClient::create()) | 93 , m_channelClient(MockWebSocketChannelClient::create()) |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 125 | 125 |
| 126 void didConsumeBufferedAmount(unsigned long a) | 126 void didConsumeBufferedAmount(unsigned long a) |
| 127 { | 127 { |
| 128 m_sumOfConsumedBufferedAmount += a; | 128 m_sumOfConsumedBufferedAmount += a; |
| 129 } | 129 } |
| 130 | 130 |
| 131 void connect() | 131 void connect() |
| 132 { | 132 { |
| 133 { | 133 { |
| 134 InSequence s; | 134 InSequence s; |
| 135 EXPECT_CALL(*handle(), connect(WebURL(KURL(KURL(), "ws://localhost/"
)), _, _, handleClient())); | 135 EXPECT_CALL(*handle(), connect(WebURL(KURL(KURL(), "ws://localhost/"
)), _, _, _, handleClient())); |
| 136 EXPECT_CALL(*handle(), flowControl(65536)); | 136 EXPECT_CALL(*handle(), flowControl(65536)); |
| 137 EXPECT_CALL(*channelClient(), didConnect(String("a"), String("b"))); | 137 EXPECT_CALL(*channelClient(), didConnect(String("a"), String("b"))); |
| 138 } | 138 } |
| 139 EXPECT_TRUE(channel()->connect(KURL(KURL(), "ws://localhost/"), "x")); | 139 EXPECT_TRUE(channel()->connect(KURL(KURL(), "ws://localhost/"), "x")); |
| 140 handleClient()->didConnect(handle(), WebString("a"), WebString("b")); | 140 handleClient()->didConnect(handle(), WebString("a"), WebString("b")); |
| 141 ::testing::Mock::VerifyAndClearExpectations(this); | 141 ::testing::Mock::VerifyAndClearExpectations(this); |
| 142 } | 142 } |
| 143 | 143 |
| 144 OwnPtr<DummyPageHolder> m_pageHolder; | 144 OwnPtr<DummyPageHolder> m_pageHolder; |
| 145 Persistent<MockWebSocketChannelClient> m_channelClient; | 145 Persistent<MockWebSocketChannelClient> m_channelClient; |
| (...skipping 10 matching lines...) Expand all Loading... |
| 156 ) | 156 ) |
| 157 { | 157 { |
| 158 return memcmp(arg, p, len) == 0; | 158 return memcmp(arg, p, len) == 0; |
| 159 } | 159 } |
| 160 | 160 |
| 161 TEST_F(DocumentWebSocketChannelTest, connectSuccess) | 161 TEST_F(DocumentWebSocketChannelTest, connectSuccess) |
| 162 { | 162 { |
| 163 Checkpoint checkpoint; | 163 Checkpoint checkpoint; |
| 164 { | 164 { |
| 165 InSequence s; | 165 InSequence s; |
| 166 EXPECT_CALL(*handle(), connect(WebURL(KURL(KURL(), "ws://localhost/")),
_, _, handleClient())); | 166 EXPECT_CALL(*handle(), connect(WebURL(KURL(KURL(), "ws://localhost/")),
_, _, _, handleClient())); |
| 167 EXPECT_CALL(*handle(), flowControl(65536)); | 167 EXPECT_CALL(*handle(), flowControl(65536)); |
| 168 EXPECT_CALL(checkpoint, Call(1)); | 168 EXPECT_CALL(checkpoint, Call(1)); |
| 169 EXPECT_CALL(*channelClient(), didConnect(String("a"), String("b"))); | 169 EXPECT_CALL(*channelClient(), didConnect(String("a"), String("b"))); |
| 170 } | 170 } |
| 171 | 171 |
| 172 EXPECT_TRUE(channel()->connect(KURL(KURL(), "ws://localhost/"), "x")); | 172 EXPECT_TRUE(channel()->connect(KURL(KURL(), "ws://localhost/"), "x")); |
| 173 checkpoint.Call(1); | 173 checkpoint.Call(1); |
| 174 handleClient()->didConnect(handle(), WebString("a"), WebString("b")); | 174 handleClient()->didConnect(handle(), WebString("a"), WebString("b")); |
| 175 } | 175 } |
| 176 | 176 |
| (...skipping 502 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 679 EXPECT_CALL(*channelClient(), didError()); | 679 EXPECT_CALL(*channelClient(), didError()); |
| 680 EXPECT_CALL(*channelClient(), didClose(WebSocketChannelClient::ClosingHa
ndshakeIncomplete, WebSocketChannel::CloseEventCodeAbnormalClosure, String())); | 680 EXPECT_CALL(*channelClient(), didClose(WebSocketChannelClient::ClosingHa
ndshakeIncomplete, WebSocketChannel::CloseEventCodeAbnormalClosure, String())); |
| 681 } | 681 } |
| 682 | 682 |
| 683 channel()->fail("fail message from WebSocket", ErrorMessageLevel, nullptr); | 683 channel()->fail("fail message from WebSocket", ErrorMessageLevel, nullptr); |
| 684 } | 684 } |
| 685 | 685 |
| 686 } // namespace | 686 } // namespace |
| 687 | 687 |
| 688 } // namespace blink | 688 } // namespace blink |
| OLD | NEW |