Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(319)

Side by Side Diff: net/spdy/spdy_websocket_stream_spdy2_unittest.cc

Issue 9817014: Created a new class SpdyTestStateHelper to serve as a helper to manage the state of a number of SPD… (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Add TODO Created 8 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « net/spdy/spdy_test_util_spdy3.cc ('k') | net/spdy/spdy_websocket_stream_spdy3_unittest.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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 "base/bind.h" 10 #include "base/bind.h"
(...skipping 171 matching lines...) Expand 10 before | Expand all | Expand 10 after
182 182
183 void DoSync(SpdyWebSocketStreamEvent* event) { 183 void DoSync(SpdyWebSocketStreamEvent* event) {
184 sync_callback_.SetResult(OK); 184 sync_callback_.SetResult(OK);
185 } 185 }
186 186
187 protected: 187 protected:
188 SpdyWebSocketStreamSpdy2Test() {} 188 SpdyWebSocketStreamSpdy2Test() {}
189 virtual ~SpdyWebSocketStreamSpdy2Test() {} 189 virtual ~SpdyWebSocketStreamSpdy2Test() {}
190 190
191 virtual void SetUp() { 191 virtual void SetUp() {
192 EnableCompression(false);
193 SpdySession::set_default_protocol(SSLClientSocket::kProtoSPDY2); 192 SpdySession::set_default_protocol(SSLClientSocket::kProtoSPDY2);
194 193
195 host_port_pair_.set_host("example.com"); 194 host_port_pair_.set_host("example.com");
196 host_port_pair_.set_port(80); 195 host_port_pair_.set_port(80);
197 host_port_proxy_pair_.first = host_port_pair_; 196 host_port_proxy_pair_.first = host_port_pair_;
198 host_port_proxy_pair_.second = ProxyServer::Direct(); 197 host_port_proxy_pair_.second = ProxyServer::Direct();
199 198
200 const size_t max_concurrent_streams = 1; 199 const size_t max_concurrent_streams = 1;
201 spdy::SettingsFlagsAndId id(spdy::SETTINGS_FLAG_PLEASE_PERSIST, 200 spdy::SettingsFlagsAndId id(spdy::SETTINGS_FLAG_PLEASE_PERSIST,
202 spdy::SETTINGS_MAX_CONCURRENT_STREAMS); 201 spdy::SETTINGS_MAX_CONCURRENT_STREAMS);
203 spdy_settings_to_set_.push_back( 202 spdy_settings_to_set_.push_back(
204 spdy::SpdySetting(id, max_concurrent_streams)); 203 spdy::SpdySetting(id, max_concurrent_streams));
205 204
206 spdy::SettingsFlagsAndId id1(spdy::SETTINGS_FLAG_PERSISTED, 205 spdy::SettingsFlagsAndId id1(spdy::SETTINGS_FLAG_PERSISTED,
207 spdy::SETTINGS_MAX_CONCURRENT_STREAMS); 206 spdy::SETTINGS_MAX_CONCURRENT_STREAMS);
208 spdy_settings_to_send_.push_back( 207 spdy_settings_to_send_.push_back(
209 spdy::SpdySetting(id1, max_concurrent_streams)); 208 spdy::SpdySetting(id1, max_concurrent_streams));
210 } 209 }
211 210
212 virtual void TearDown() { 211 virtual void TearDown() {
213 MessageLoop::current()->RunAllPending(); 212 MessageLoop::current()->RunAllPending();
214 } 213 }
215 214
216 void EnableCompression(bool enabled) {
217 spdy::SpdyFramer::set_enable_compression_default(enabled);
218 }
219 void Prepare(spdy::SpdyStreamId stream_id) { 215 void Prepare(spdy::SpdyStreamId stream_id) {
220 stream_id_ = stream_id; 216 stream_id_ = stream_id;
221 217
222 const char* const request_headers[] = { 218 const char* const request_headers[] = {
223 "url", "ws://example.com/echo", 219 "url", "ws://example.com/echo",
224 "origin", "http://example.com/wsdemo", 220 "origin", "http://example.com/wsdemo",
225 }; 221 };
226 222
227 int request_header_count = arraysize(request_headers) / 2; 223 int request_header_count = arraysize(request_headers) / 2;
228 224
(...skipping 81 matching lines...) Expand 10 before | Expand all | Expand 10 after
310 scoped_ptr<spdy::SpdyFrame> closing_frame_; 306 scoped_ptr<spdy::SpdyFrame> closing_frame_;
311 HostPortPair host_port_pair_; 307 HostPortPair host_port_pair_;
312 HostPortProxyPair host_port_proxy_pair_; 308 HostPortProxyPair host_port_proxy_pair_;
313 TestCompletionCallback completion_callback_; 309 TestCompletionCallback completion_callback_;
314 TestCompletionCallback sync_callback_; 310 TestCompletionCallback sync_callback_;
315 311
316 static const char kMessageFrame[]; 312 static const char kMessageFrame[];
317 static const char kClosingFrame[]; 313 static const char kClosingFrame[];
318 static const size_t kMessageFrameLength; 314 static const size_t kMessageFrameLength;
319 static const size_t kClosingFrameLength; 315 static const size_t kClosingFrameLength;
316
317 private:
318 SpdyTestStateHelper spdy_state_;
320 }; 319 };
321 320
322 const char SpdyWebSocketStreamSpdy2Test::kMessageFrame[] = "\0hello\xff"; 321 const char SpdyWebSocketStreamSpdy2Test::kMessageFrame[] = "\0hello\xff";
323 const char SpdyWebSocketStreamSpdy2Test::kClosingFrame[] = "\xff\0"; 322 const char SpdyWebSocketStreamSpdy2Test::kClosingFrame[] = "\xff\0";
324 const size_t SpdyWebSocketStreamSpdy2Test::kMessageFrameLength = 323 const size_t SpdyWebSocketStreamSpdy2Test::kMessageFrameLength =
325 arraysize(SpdyWebSocketStreamSpdy2Test::kMessageFrame) - 1; 324 arraysize(SpdyWebSocketStreamSpdy2Test::kMessageFrame) - 1;
326 const size_t SpdyWebSocketStreamSpdy2Test::kClosingFrameLength = 325 const size_t SpdyWebSocketStreamSpdy2Test::kClosingFrameLength =
327 arraysize(SpdyWebSocketStreamSpdy2Test::kClosingFrame) - 1; 326 arraysize(SpdyWebSocketStreamSpdy2Test::kClosingFrame) - 1;
328 327
329 TEST_F(SpdyWebSocketStreamSpdy2Test, Basic) { 328 TEST_F(SpdyWebSocketStreamSpdy2Test, Basic) {
(...skipping 291 matching lines...) Expand 10 before | Expand all | Expand 10 after
621 EXPECT_EQ(OK, events[7].result); 620 EXPECT_EQ(OK, events[7].result);
622 621
623 // EOF close SPDY session. 622 // EOF close SPDY session.
624 EXPECT_TRUE(!http_session_->spdy_session_pool()->HasSession( 623 EXPECT_TRUE(!http_session_->spdy_session_pool()->HasSession(
625 host_port_proxy_pair_)); 624 host_port_proxy_pair_));
626 EXPECT_TRUE(data()->at_read_eof()); 625 EXPECT_TRUE(data()->at_read_eof());
627 EXPECT_TRUE(data()->at_write_eof()); 626 EXPECT_TRUE(data()->at_write_eof());
628 } 627 }
629 628
630 } // namespace net 629 } // namespace net
OLDNEW
« no previous file with comments | « net/spdy/spdy_test_util_spdy3.cc ('k') | net/spdy/spdy_websocket_stream_spdy3_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698