OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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_stream.h" | 5 #include "net/spdy/spdy_stream.h" |
6 | 6 |
7 #include <stdint.h> | 7 #include <stdint.h> |
8 | 8 |
9 #include <algorithm> | 9 #include <algorithm> |
10 #include <cstddef> | 10 #include <cstddef> |
(...skipping 325 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
336 EXPECT_TRUE(stream->GetUrlFromHeaders().is_empty()); | 336 EXPECT_TRUE(stream->GetUrlFromHeaders().is_empty()); |
337 | 337 |
338 SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl)); | 338 SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl)); |
339 EXPECT_THAT( | 339 EXPECT_THAT( |
340 stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND), | 340 stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND), |
341 IsError(ERR_IO_PENDING)); | 341 IsError(ERR_IO_PENDING)); |
342 EXPECT_EQ(kDefaultUrl, stream->GetUrlFromHeaders().spec()); | 342 EXPECT_EQ(kDefaultUrl, stream->GetUrlFromHeaders().spec()); |
343 | 343 |
344 data.RunUntilPaused(); | 344 data.RunUntilPaused(); |
345 | 345 |
346 base::WeakPtr<SpdyStream> push_stream; | 346 SpdyStream* push_stream; |
347 EXPECT_THAT(session->GetPushStream(GURL(kPushUrl), IDLE, &push_stream, | 347 EXPECT_THAT(session->GetPushStream(GURL(kPushUrl), IDLE, &push_stream, |
348 NetLogWithSource()), | 348 NetLogWithSource()), |
349 IsOk()); | 349 IsOk()); |
350 ASSERT_TRUE(push_stream); | 350 ASSERT_TRUE(push_stream); |
351 EXPECT_EQ(kPushUrl, push_stream->GetUrlFromHeaders().spec()); | 351 EXPECT_EQ(kPushUrl, push_stream->GetUrlFromHeaders().spec()); |
352 | 352 |
353 LoadTimingInfo load_timing_info; | 353 LoadTimingInfo load_timing_info; |
354 EXPECT_TRUE(push_stream->GetLoadTimingInfo(&load_timing_info)); | 354 EXPECT_TRUE(push_stream->GetLoadTimingInfo(&load_timing_info)); |
355 EXPECT_EQ(g_time_now, load_timing_info.push_start); | 355 EXPECT_EQ(g_time_now, load_timing_info.push_start); |
356 EXPECT_TRUE(load_timing_info.push_end.is_null()); | 356 EXPECT_TRUE(load_timing_info.push_end.is_null()); |
357 | 357 |
358 StreamDelegateDoNothing push_delegate(push_stream); | 358 StreamDelegateDoNothing push_delegate(push_stream->GetWeakPtr()); |
359 push_stream->SetDelegate(&push_delegate); | 359 push_stream->SetDelegate(&push_delegate); |
360 | 360 |
361 data.Resume(); | 361 data.Resume(); |
362 | 362 |
363 EXPECT_TRUE(push_stream->GetLoadTimingInfo(&load_timing_info)); | 363 EXPECT_TRUE(push_stream->GetLoadTimingInfo(&load_timing_info)); |
364 EXPECT_EQ(g_time_now, load_timing_info.push_start); | 364 EXPECT_EQ(g_time_now, load_timing_info.push_start); |
365 EXPECT_FALSE(load_timing_info.push_end.is_null()); | 365 EXPECT_FALSE(load_timing_info.push_end.is_null()); |
366 | 366 |
367 EXPECT_THAT(delegate.WaitForClose(), IsOk()); | 367 EXPECT_THAT(delegate.WaitForClose(), IsOk()); |
368 EXPECT_EQ("200", delegate.GetResponseHeaderValue(spdy_util_.GetStatusKey())); | 368 EXPECT_EQ("200", delegate.GetResponseHeaderValue(spdy_util_.GetStatusKey())); |
(...skipping 280 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
649 EXPECT_TRUE(stream->GetUrlFromHeaders().is_empty()); | 649 EXPECT_TRUE(stream->GetUrlFromHeaders().is_empty()); |
650 | 650 |
651 SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl)); | 651 SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl)); |
652 EXPECT_THAT( | 652 EXPECT_THAT( |
653 stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND), | 653 stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND), |
654 IsError(ERR_IO_PENDING)); | 654 IsError(ERR_IO_PENDING)); |
655 EXPECT_EQ(kDefaultUrl, stream->GetUrlFromHeaders().spec()); | 655 EXPECT_EQ(kDefaultUrl, stream->GetUrlFromHeaders().spec()); |
656 | 656 |
657 data.RunUntilPaused(); | 657 data.RunUntilPaused(); |
658 | 658 |
659 base::WeakPtr<SpdyStream> push_stream; | 659 SpdyStream* push_stream; |
660 EXPECT_THAT(session->GetPushStream(GURL(kPushUrl), IDLE, &push_stream, | 660 EXPECT_THAT(session->GetPushStream(GURL(kPushUrl), IDLE, &push_stream, |
661 NetLogWithSource()), | 661 NetLogWithSource()), |
662 IsOk()); | 662 IsOk()); |
663 EXPECT_FALSE(push_stream); | 663 EXPECT_FALSE(push_stream); |
664 | 664 |
665 data.Resume(); | 665 data.Resume(); |
666 | 666 |
667 EXPECT_THAT(delegate.WaitForClose(), IsError(ERR_CONNECTION_CLOSED)); | 667 EXPECT_THAT(delegate.WaitForClose(), IsError(ERR_CONNECTION_CLOSED)); |
668 | 668 |
669 EXPECT_TRUE(data.AllWriteDataConsumed()); | 669 EXPECT_TRUE(data.AllWriteDataConsumed()); |
(...skipping 829 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1499 EXPECT_EQ(response_len, stream->raw_received_bytes()); | 1499 EXPECT_EQ(response_len, stream->raw_received_bytes()); |
1500 | 1500 |
1501 // FIN | 1501 // FIN |
1502 data.Resume(); | 1502 data.Resume(); |
1503 EXPECT_THAT(delegate.WaitForClose(), IsError(ERR_CONNECTION_CLOSED)); | 1503 EXPECT_THAT(delegate.WaitForClose(), IsError(ERR_CONNECTION_CLOSED)); |
1504 } | 1504 } |
1505 | 1505 |
1506 } // namespace test | 1506 } // namespace test |
1507 | 1507 |
1508 } // namespace net | 1508 } // namespace net |
OLD | NEW |