| 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();
|
| 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());
|
|
|
|
|