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 <stddef.h> | 5 #include <stddef.h> |
6 #include <sys/epoll.h> | 6 #include <sys/epoll.h> |
7 #include <string> | 7 #include <string> |
8 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "base/memory/scoped_ptr.h" | 10 #include "base/memory/scoped_ptr.h" |
(...skipping 955 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
966 server_thread_->Pause(); | 966 server_thread_->Pause(); |
967 EXPECT_TRUE(server_config_.HasReceivedConnectionOptions()); | 967 EXPECT_TRUE(server_config_.HasReceivedConnectionOptions()); |
968 EXPECT_TRUE( | 968 EXPECT_TRUE( |
969 ContainsQuicTag(server_config_.ReceivedConnectionOptions(), kTBBR)); | 969 ContainsQuicTag(server_config_.ReceivedConnectionOptions(), kTBBR)); |
970 EXPECT_TRUE( | 970 EXPECT_TRUE( |
971 ContainsQuicTag(server_config_.ReceivedConnectionOptions(), kIW10)); | 971 ContainsQuicTag(server_config_.ReceivedConnectionOptions(), kIW10)); |
972 EXPECT_TRUE( | 972 EXPECT_TRUE( |
973 ContainsQuicTag(server_config_.ReceivedConnectionOptions(), kPRST)); | 973 ContainsQuicTag(server_config_.ReceivedConnectionOptions(), kPRST)); |
974 } | 974 } |
975 | 975 |
976 TEST_P(EndToEndTest, CorrectlyConfiguredFec) { | |
977 ASSERT_TRUE(Initialize()); | |
978 client_->client()->WaitForCryptoHandshakeConfirmed(); | |
979 server_thread_->WaitForCryptoHandshakeConfirmed(); | |
980 | |
981 FecPolicy expected_policy = FEC_PROTECT_OPTIONAL; | |
982 | |
983 // Verify that server's FEC configuration is correct. | |
984 server_thread_->Pause(); | |
985 QuicDispatcher* dispatcher = | |
986 QuicServerPeer::GetDispatcher(server_thread_->server()); | |
987 ASSERT_EQ(1u, dispatcher->session_map().size()); | |
988 QuicSpdySession* session = dispatcher->session_map().begin()->second; | |
989 EXPECT_EQ(expected_policy, | |
990 QuicSpdySessionPeer::GetHeadersStream(session)->fec_policy()); | |
991 server_thread_->Resume(); | |
992 | |
993 // Verify that client's FEC configuration is correct. | |
994 EXPECT_EQ(expected_policy, | |
995 QuicSpdySessionPeer::GetHeadersStream(client_->client()->session()) | |
996 ->fec_policy()); | |
997 EXPECT_EQ(expected_policy, client_->GetOrCreateStream()->fec_policy()); | |
998 } | |
999 | |
1000 TEST_P(EndToEndTest, LargePostSmallBandwidthLargeBuffer) { | 976 TEST_P(EndToEndTest, LargePostSmallBandwidthLargeBuffer) { |
1001 ASSERT_TRUE(Initialize()); | 977 ASSERT_TRUE(Initialize()); |
1002 SetPacketSendDelay(QuicTime::Delta::FromMicroseconds(1)); | 978 SetPacketSendDelay(QuicTime::Delta::FromMicroseconds(1)); |
1003 // 256KB per second with a 256KB buffer from server to client. Wireless | 979 // 256KB per second with a 256KB buffer from server to client. Wireless |
1004 // clients commonly have larger buffers, but our max CWND is 200. | 980 // clients commonly have larger buffers, but our max CWND is 200. |
1005 server_writer_->set_max_bandwidth_and_buffer_size( | 981 server_writer_->set_max_bandwidth_and_buffer_size( |
1006 QuicBandwidth::FromBytesPerSecond(256 * 1024), 256 * 1024); | 982 QuicBandwidth::FromBytesPerSecond(256 * 1024), 256 * 1024); |
1007 | 983 |
1008 client_->client()->WaitForCryptoHandshakeConfirmed(); | 984 client_->client()->WaitForCryptoHandshakeConfirmed(); |
1009 | 985 |
(...skipping 1394 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2404 // sending requests for them. | 2380 // sending requests for them. |
2405 EXPECT_EQ(1u, client_->num_requests()); | 2381 EXPECT_EQ(1u, client_->num_requests()); |
2406 // Including response to original request, 12 responses in total were | 2382 // Including response to original request, 12 responses in total were |
2407 // recieved. | 2383 // recieved. |
2408 EXPECT_EQ(12u, client_->num_responses()); | 2384 EXPECT_EQ(12u, client_->num_responses()); |
2409 } | 2385 } |
2410 | 2386 |
2411 } // namespace | 2387 } // namespace |
2412 } // namespace test | 2388 } // namespace test |
2413 } // namespace net | 2389 } // namespace net |
OLD | NEW |