OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 "net/spdy/spdy_websocket_stream.h" | 5 #include "net/spdy/spdy_websocket_stream.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "net/base/completion_callback.h" | 10 #include "net/base/completion_callback.h" |
(...skipping 162 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
173 sync_callback_.Run(OK); | 173 sync_callback_.Run(OK); |
174 } | 174 } |
175 | 175 |
176 protected: | 176 protected: |
177 SpdyWebSocketStreamTest() {} | 177 SpdyWebSocketStreamTest() {} |
178 virtual ~SpdyWebSocketStreamTest() {} | 178 virtual ~SpdyWebSocketStreamTest() {} |
179 | 179 |
180 virtual void SetUp() { | 180 virtual void SetUp() { |
181 EnableCompression(false); | 181 EnableCompression(false); |
182 SpdySession::SetSSLMode(false); | 182 SpdySession::SetSSLMode(false); |
| 183 // Disable sending PING. |
| 184 SpdySession::set_enable_ping_based_connection_checking(false); |
183 | 185 |
184 host_port_pair_.set_host("example.com"); | 186 host_port_pair_.set_host("example.com"); |
185 host_port_pair_.set_port(80); | 187 host_port_pair_.set_port(80); |
186 host_port_proxy_pair_.first = host_port_pair_; | 188 host_port_proxy_pair_.first = host_port_pair_; |
187 host_port_proxy_pair_.second = ProxyServer::Direct(); | 189 host_port_proxy_pair_.second = ProxyServer::Direct(); |
188 | 190 |
189 const size_t max_concurrent_streams = 1; | 191 const size_t max_concurrent_streams = 1; |
190 spdy::SettingsFlagsAndId id(0); | 192 spdy::SettingsFlagsAndId id(0); |
191 id.set_id(spdy::SETTINGS_MAX_CONCURRENT_STREAMS); | 193 id.set_id(spdy::SETTINGS_MAX_CONCURRENT_STREAMS); |
192 | 194 |
193 id.set_flags(spdy::SETTINGS_FLAG_PLEASE_PERSIST); | 195 id.set_flags(spdy::SETTINGS_FLAG_PLEASE_PERSIST); |
194 spdy_settings_to_set_.push_back( | 196 spdy_settings_to_set_.push_back( |
195 spdy::SpdySetting(id, max_concurrent_streams)); | 197 spdy::SpdySetting(id, max_concurrent_streams)); |
196 | 198 |
197 id.set_flags(spdy::SETTINGS_FLAG_PERSISTED); | 199 id.set_flags(spdy::SETTINGS_FLAG_PERSISTED); |
198 spdy_settings_to_send_.push_back( | 200 spdy_settings_to_send_.push_back( |
199 spdy::SpdySetting(id, max_concurrent_streams)); | 201 spdy::SpdySetting(id, max_concurrent_streams)); |
200 } | 202 } |
201 virtual void TearDown() { | 203 virtual void TearDown() { |
202 MessageLoop::current()->RunAllPending(); | 204 MessageLoop::current()->RunAllPending(); |
| 205 // Enable sending PING. |
| 206 SpdySession::set_enable_ping_based_connection_checking(true); |
203 } | 207 } |
204 | 208 |
205 void EnableCompression(bool enabled) { | 209 void EnableCompression(bool enabled) { |
206 spdy::SpdyFramer::set_enable_compression_default(enabled); | 210 spdy::SpdyFramer::set_enable_compression_default(enabled); |
207 } | 211 } |
208 void Prepare(spdy::SpdyStreamId stream_id) { | 212 void Prepare(spdy::SpdyStreamId stream_id) { |
209 stream_id_ = stream_id; | 213 stream_id_ = stream_id; |
210 | 214 |
211 const char* const request_headers[] = { | 215 const char* const request_headers[] = { |
212 "url", "ws://example.com/echo", | 216 "url", "ws://example.com/echo", |
(...skipping 389 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
602 EXPECT_EQ(OK, events[7].result); | 606 EXPECT_EQ(OK, events[7].result); |
603 | 607 |
604 // EOF close SPDY session. | 608 // EOF close SPDY session. |
605 EXPECT_TRUE(!http_session_->spdy_session_pool()->HasSession( | 609 EXPECT_TRUE(!http_session_->spdy_session_pool()->HasSession( |
606 host_port_proxy_pair_)); | 610 host_port_proxy_pair_)); |
607 EXPECT_TRUE(data()->at_read_eof()); | 611 EXPECT_TRUE(data()->at_read_eof()); |
608 EXPECT_TRUE(data()->at_write_eof()); | 612 EXPECT_TRUE(data()->at_write_eof()); |
609 } | 613 } |
610 | 614 |
611 } // namespace net | 615 } // namespace net |
OLD | NEW |