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 |