| 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 <algorithm> | 7 #include <algorithm> |
| 8 #include <memory> | 8 #include <memory> |
| 9 #include <utility> | 9 #include <utility> |
| 10 | 10 |
| (...skipping 3874 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3885 CreateMockRead(resp, 1), MockRead(ASYNC, ERR_IO_PENDING, 2), | 3885 CreateMockRead(resp, 1), MockRead(ASYNC, ERR_IO_PENDING, 2), |
| 3886 CreateMockRead(data_frame, 3), MockRead(ASYNC, ERR_IO_PENDING, 5), | 3886 CreateMockRead(data_frame, 3), MockRead(ASYNC, ERR_IO_PENDING, 5), |
| 3887 MockRead(ASYNC, 0, 6), | 3887 MockRead(ASYNC, 0, 6), |
| 3888 }; | 3888 }; |
| 3889 | 3889 |
| 3890 SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes)); | 3890 SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes)); |
| 3891 session_deps_.socket_factory->AddSocketDataProvider(&data); | 3891 session_deps_.socket_factory->AddSocketDataProvider(&data); |
| 3892 | 3892 |
| 3893 AddSSLSocketData(); | 3893 AddSSLSocketData(); |
| 3894 | 3894 |
| 3895 session_deps_.stream_max_recv_window_size = stream_max_recv_window_size; |
| 3895 CreateNetworkSession(); | 3896 CreateNetworkSession(); |
| 3896 | 3897 |
| 3897 SpdySessionPoolPeer pool_peer(spdy_session_pool_); | |
| 3898 pool_peer.SetStreamInitialRecvWindowSize(stream_max_recv_window_size); | |
| 3899 CreateSecureSpdySession(); | 3898 CreateSecureSpdySession(); |
| 3900 | 3899 |
| 3901 base::WeakPtr<SpdyStream> spdy_stream = | 3900 base::WeakPtr<SpdyStream> spdy_stream = |
| 3902 CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_, | 3901 CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_, |
| 3903 test_url_, LOWEST, NetLogWithSource()); | 3902 test_url_, LOWEST, NetLogWithSource()); |
| 3904 EXPECT_EQ(stream_max_recv_window_size, spdy_stream->recv_window_size()); | 3903 EXPECT_EQ(stream_max_recv_window_size, spdy_stream->recv_window_size()); |
| 3905 | 3904 |
| 3906 test::StreamDelegateDoNothing delegate(spdy_stream); | 3905 test::StreamDelegateDoNothing delegate(spdy_stream); |
| 3907 spdy_stream->SetDelegate(&delegate); | 3906 spdy_stream->SetDelegate(&delegate); |
| 3908 | 3907 |
| (...skipping 114 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4023 CreateMockRead(first, 3), MockRead(ASYNC, ERR_IO_PENDING, 4), | 4022 CreateMockRead(first, 3), MockRead(ASYNC, ERR_IO_PENDING, 4), |
| 4024 CreateMockRead(second, 5), MockRead(ASYNC, ERR_IO_PENDING, 7), | 4023 CreateMockRead(second, 5), MockRead(ASYNC, ERR_IO_PENDING, 7), |
| 4025 MockRead(ASYNC, 0, 8), | 4024 MockRead(ASYNC, 0, 8), |
| 4026 }; | 4025 }; |
| 4027 | 4026 |
| 4028 SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes)); | 4027 SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes)); |
| 4029 session_deps_.socket_factory->AddSocketDataProvider(&data); | 4028 session_deps_.socket_factory->AddSocketDataProvider(&data); |
| 4030 | 4029 |
| 4031 AddSSLSocketData(); | 4030 AddSSLSocketData(); |
| 4032 | 4031 |
| 4032 session_deps_.stream_max_recv_window_size = stream_max_recv_window_size; |
| 4033 CreateNetworkSession(); | 4033 CreateNetworkSession(); |
| 4034 SpdySessionPoolPeer pool_peer(spdy_session_pool_); | |
| 4035 pool_peer.SetStreamInitialRecvWindowSize(stream_max_recv_window_size); | |
| 4036 | 4034 |
| 4037 CreateSecureSpdySession(); | 4035 CreateSecureSpdySession(); |
| 4038 | 4036 |
| 4039 base::WeakPtr<SpdyStream> spdy_stream = | 4037 base::WeakPtr<SpdyStream> spdy_stream = |
| 4040 CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_, | 4038 CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_, |
| 4041 test_url_, LOWEST, NetLogWithSource()); | 4039 test_url_, LOWEST, NetLogWithSource()); |
| 4042 test::StreamDelegateDoNothing delegate(spdy_stream); | 4040 test::StreamDelegateDoNothing delegate(spdy_stream); |
| 4043 spdy_stream->SetDelegate(&delegate); | 4041 spdy_stream->SetDelegate(&delegate); |
| 4044 | 4042 |
| 4045 SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl)); | 4043 SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl)); |
| (...skipping 1838 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5884 ssl_info.cert = ImportCertFromFile(GetTestCertsDirectory(), | 5882 ssl_info.cert = ImportCertFromFile(GetTestCertsDirectory(), |
| 5885 "spdy_pooling.pem"); | 5883 "spdy_pooling.pem"); |
| 5886 ssl_info.is_issued_by_known_root = true; | 5884 ssl_info.is_issued_by_known_root = true; |
| 5887 ssl_info.public_key_hashes.push_back(test::GetTestHashValue(primary_pin)); | 5885 ssl_info.public_key_hashes.push_back(test::GetTestHashValue(primary_pin)); |
| 5888 | 5886 |
| 5889 EXPECT_TRUE(SpdySession::CanPool( | 5887 EXPECT_TRUE(SpdySession::CanPool( |
| 5890 &tss, ssl_info, "www.example.org", "mail.example.org")); | 5888 &tss, ssl_info, "www.example.org", "mail.example.org")); |
| 5891 } | 5889 } |
| 5892 | 5890 |
| 5893 } // namespace net | 5891 } // namespace net |
| OLD | NEW |