| 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 cecc96b5e8d23632ebe25c96c3f07be5505d662c..5199f1fc65d71dcfab036289e611980424e57af7 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);
|
| }
|
|
|
| @@ -298,6 +300,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_;
|
| @@ -357,12 +360,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 =
|
| @@ -522,7 +526,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[] = {
|
| @@ -575,7 +579,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());
|
|
|
|
|