| OLD | NEW |
| 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_session.h" | 5 #include "net/spdy/spdy_session.h" |
| 6 | 6 |
| 7 #include <memory> | 7 #include <memory> |
| 8 #include <utility> | 8 #include <utility> |
| 9 | 9 |
| 10 #include "base/base64.h" | 10 #include "base/base64.h" |
| (...skipping 394 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 405 test::StreamDelegateDoNothing delegate1(spdy_stream1); | 405 test::StreamDelegateDoNothing delegate1(spdy_stream1); |
| 406 spdy_stream1->SetDelegate(&delegate1); | 406 spdy_stream1->SetDelegate(&delegate1); |
| 407 | 407 |
| 408 base::WeakPtr<SpdyStream> spdy_stream2 = CreateStreamSynchronously( | 408 base::WeakPtr<SpdyStream> spdy_stream2 = CreateStreamSynchronously( |
| 409 SPDY_REQUEST_RESPONSE_STREAM, session_, test_url_, MEDIUM, BoundNetLog()); | 409 SPDY_REQUEST_RESPONSE_STREAM, session_, test_url_, MEDIUM, BoundNetLog()); |
| 410 test::StreamDelegateDoNothing delegate2(spdy_stream2); | 410 test::StreamDelegateDoNothing delegate2(spdy_stream2); |
| 411 spdy_stream2->SetDelegate(&delegate2); | 411 spdy_stream2->SetDelegate(&delegate2); |
| 412 | 412 |
| 413 std::unique_ptr<SpdyHeaderBlock> headers( | 413 std::unique_ptr<SpdyHeaderBlock> headers( |
| 414 new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); | 414 new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
| 415 std::unique_ptr<SpdyHeaderBlock> headers2(new SpdyHeaderBlock(*headers)); | 415 std::unique_ptr<SpdyHeaderBlock> headers2( |
| 416 new SpdyHeaderBlock(headers->Clone())); |
| 416 | 417 |
| 417 spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); | 418 spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
| 418 EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); | 419 EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
| 419 spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND); | 420 spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND); |
| 420 EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); | 421 EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); |
| 421 | 422 |
| 422 base::RunLoop().RunUntilIdle(); | 423 base::RunLoop().RunUntilIdle(); |
| 423 | 424 |
| 424 EXPECT_EQ(1u, spdy_stream1->stream_id()); | 425 EXPECT_EQ(1u, spdy_stream1->stream_id()); |
| 425 EXPECT_EQ(3u, spdy_stream2->stream_id()); | 426 EXPECT_EQ(3u, spdy_stream2->stream_id()); |
| (...skipping 118 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 544 test::StreamDelegateDoNothing delegate1(spdy_stream1); | 545 test::StreamDelegateDoNothing delegate1(spdy_stream1); |
| 545 spdy_stream1->SetDelegate(&delegate1); | 546 spdy_stream1->SetDelegate(&delegate1); |
| 546 | 547 |
| 547 base::WeakPtr<SpdyStream> spdy_stream2 = CreateStreamSynchronously( | 548 base::WeakPtr<SpdyStream> spdy_stream2 = CreateStreamSynchronously( |
| 548 SPDY_REQUEST_RESPONSE_STREAM, session_, test_url_, MEDIUM, BoundNetLog()); | 549 SPDY_REQUEST_RESPONSE_STREAM, session_, test_url_, MEDIUM, BoundNetLog()); |
| 549 test::StreamDelegateDoNothing delegate2(spdy_stream2); | 550 test::StreamDelegateDoNothing delegate2(spdy_stream2); |
| 550 spdy_stream2->SetDelegate(&delegate2); | 551 spdy_stream2->SetDelegate(&delegate2); |
| 551 | 552 |
| 552 std::unique_ptr<SpdyHeaderBlock> headers( | 553 std::unique_ptr<SpdyHeaderBlock> headers( |
| 553 new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); | 554 new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
| 554 std::unique_ptr<SpdyHeaderBlock> headers2(new SpdyHeaderBlock(*headers)); | 555 std::unique_ptr<SpdyHeaderBlock> headers2( |
| 556 new SpdyHeaderBlock(headers->Clone())); |
| 555 | 557 |
| 556 spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); | 558 spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
| 557 EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); | 559 EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
| 558 spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND); | 560 spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND); |
| 559 EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); | 561 EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); |
| 560 | 562 |
| 561 base::RunLoop().RunUntilIdle(); | 563 base::RunLoop().RunUntilIdle(); |
| 562 | 564 |
| 563 EXPECT_EQ(1u, spdy_stream1->stream_id()); | 565 EXPECT_EQ(1u, spdy_stream1->stream_id()); |
| 564 EXPECT_EQ(3u, spdy_stream2->stream_id()); | 566 EXPECT_EQ(3u, spdy_stream2->stream_id()); |
| (...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 618 test::StreamDelegateDoNothing delegate1(spdy_stream1); | 620 test::StreamDelegateDoNothing delegate1(spdy_stream1); |
| 619 spdy_stream1->SetDelegate(&delegate1); | 621 spdy_stream1->SetDelegate(&delegate1); |
| 620 | 622 |
| 621 base::WeakPtr<SpdyStream> spdy_stream2 = CreateStreamSynchronously( | 623 base::WeakPtr<SpdyStream> spdy_stream2 = CreateStreamSynchronously( |
| 622 SPDY_REQUEST_RESPONSE_STREAM, session_, test_url_, MEDIUM, BoundNetLog()); | 624 SPDY_REQUEST_RESPONSE_STREAM, session_, test_url_, MEDIUM, BoundNetLog()); |
| 623 test::StreamDelegateDoNothing delegate2(spdy_stream2); | 625 test::StreamDelegateDoNothing delegate2(spdy_stream2); |
| 624 spdy_stream2->SetDelegate(&delegate2); | 626 spdy_stream2->SetDelegate(&delegate2); |
| 625 | 627 |
| 626 std::unique_ptr<SpdyHeaderBlock> headers( | 628 std::unique_ptr<SpdyHeaderBlock> headers( |
| 627 new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); | 629 new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
| 628 std::unique_ptr<SpdyHeaderBlock> headers2(new SpdyHeaderBlock(*headers)); | 630 std::unique_ptr<SpdyHeaderBlock> headers2( |
| 631 new SpdyHeaderBlock(headers->Clone())); |
| 629 | 632 |
| 630 spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); | 633 spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
| 631 EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); | 634 EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
| 632 spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND); | 635 spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND); |
| 633 EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); | 636 EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); |
| 634 | 637 |
| 635 base::RunLoop().RunUntilIdle(); | 638 base::RunLoop().RunUntilIdle(); |
| 636 | 639 |
| 637 EXPECT_EQ(1u, spdy_stream1->stream_id()); | 640 EXPECT_EQ(1u, spdy_stream1->stream_id()); |
| 638 EXPECT_EQ(3u, spdy_stream2->stream_id()); | 641 EXPECT_EQ(3u, spdy_stream2->stream_id()); |
| (...skipping 5254 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5893 ssl_info.cert = ImportCertFromFile(GetTestCertsDirectory(), | 5896 ssl_info.cert = ImportCertFromFile(GetTestCertsDirectory(), |
| 5894 "spdy_pooling.pem"); | 5897 "spdy_pooling.pem"); |
| 5895 ssl_info.is_issued_by_known_root = true; | 5898 ssl_info.is_issued_by_known_root = true; |
| 5896 ssl_info.public_key_hashes.push_back(test::GetTestHashValue(primary_pin)); | 5899 ssl_info.public_key_hashes.push_back(test::GetTestHashValue(primary_pin)); |
| 5897 | 5900 |
| 5898 EXPECT_TRUE(SpdySession::CanPool( | 5901 EXPECT_TRUE(SpdySession::CanPool( |
| 5899 &tss, ssl_info, "www.example.org", "mail.example.org")); | 5902 &tss, ssl_info, "www.example.org", "mail.example.org")); |
| 5900 } | 5903 } |
| 5901 | 5904 |
| 5902 } // namespace net | 5905 } // namespace net |
| OLD | NEW |