Chromium Code Reviews| Index: net/spdy/spdy_websocket_stream_spdy3_unittest.cc |
| diff --git a/net/spdy/spdy_websocket_stream_spdy3_unittest.cc b/net/spdy/spdy_websocket_stream_spdy3_unittest.cc |
| index 5a21e6640f495f9f6ccbbbefaec541598012a75e..30b6f93f3b994f766cf33c8b9c8610284ab8cbd3 100644 |
| --- a/net/spdy/spdy_websocket_stream_spdy3_unittest.cc |
| +++ b/net/spdy/spdy_websocket_stream_spdy3_unittest.cc |
| @@ -165,6 +165,8 @@ class SpdyWebSocketStreamSpdy3Test : public testing::Test { |
| OrderedSocketData* data() { return data_.get(); } |
| void DoSendHelloFrame(SpdyWebSocketStreamEvent* event) { |
| + // record the actual stream_id |
| + created_stream_id_ = websocket_stream_->stream_->stream_id(); |
|
ramant (doing other things)
2012/06/26 23:30:25
nit: record -> Record
Ryan Hamilton
2012/06/27 16:58:28
Done.
|
| websocket_stream_->SendData(kMessageFrame, kMessageFrameLength); |
| } |
| @@ -299,6 +301,7 @@ class SpdyWebSocketStreamSpdy3Test : public testing::Test { |
| scoped_refptr<TransportSocketParams> transport_params_; |
| scoped_ptr<SpdyWebSocketStream> websocket_stream_; |
| SpdyStreamId stream_id_; |
| + SpdyStreamId created_stream_id_; |
| scoped_ptr<SpdyFrame> request_frame_; |
| scoped_ptr<SpdyFrame> response_frame_; |
| scoped_ptr<SpdyFrame> message_frame_; |
| @@ -358,12 +361,13 @@ TEST_F(SpdyWebSocketStreamSpdy3Test, Basic) { |
| ASSERT_EQ(OK, websocket_stream_->InitializeStream(url, HIGHEST, net_log)); |
| ASSERT_TRUE(websocket_stream_->stream_); |
| - EXPECT_EQ(stream_id_, websocket_stream_->stream_->stream_id()); |
| SendRequest(); |
| completion_callback_.WaitForResult(); |
| + EXPECT_EQ(stream_id_, created_stream_id_); |
| + |
| websocket_stream_.reset(); |
| const std::vector<SpdyWebSocketStreamEvent>& events = |
| @@ -523,7 +527,7 @@ TEST_F(SpdyWebSocketStreamSpdy3Test, DestructionAfterExplicitClose) { |
| } |
| TEST_F(SpdyWebSocketStreamSpdy3Test, IOPending) { |
| - Prepare(3); |
| + Prepare(1); |
| scoped_ptr<SpdyFrame> settings_frame( |
| ConstructSpdySettings(spdy_settings_to_send_)); |
| MockWrite writes[] = { |
| @@ -576,7 +580,7 @@ TEST_F(SpdyWebSocketStreamSpdy3Test, IOPending) { |
| ASSERT_EQ(ERR_IO_PENDING, websocket_stream_->InitializeStream( |
| url, HIGHEST, net_log)); |
| - // Delete the fist stream to allow create the second stream. |
| + // Delete the first stream to allow create the second stream. |
| block_stream.reset(); |
| ASSERT_EQ(OK, sync_callback_.WaitForResult()); |