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/quic/quic_packet_generator.h" | 5 #include "net/quic/quic_packet_generator.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 | 8 |
9 #include "net/quic/crypto/crypto_protocol.h" | 9 #include "net/quic/crypto/crypto_protocol.h" |
10 #include "net/quic/crypto/null_encrypter.h" | 10 #include "net/quic/crypto/null_encrypter.h" |
11 #include "net/quic/crypto/quic_decrypter.h" | 11 #include "net/quic/crypto/quic_decrypter.h" |
12 #include "net/quic/crypto/quic_encrypter.h" | 12 #include "net/quic/crypto/quic_encrypter.h" |
13 #include "net/quic/quic_utils.h" | 13 #include "net/quic/quic_utils.h" |
| 14 #include "net/quic/test_tools/quic_packet_creator_peer.h" |
14 #include "net/quic/test_tools/quic_test_utils.h" | 15 #include "net/quic/test_tools/quic_test_utils.h" |
15 #include "net/quic/test_tools/simple_quic_framer.h" | 16 #include "net/quic/test_tools/simple_quic_framer.h" |
16 #include "testing/gmock/include/gmock/gmock.h" | 17 #include "testing/gmock/include/gmock/gmock.h" |
17 #include "testing/gtest/include/gtest/gtest.h" | 18 #include "testing/gtest/include/gtest/gtest.h" |
18 | 19 |
19 using base::StringPiece; | 20 using base::StringPiece; |
20 using std::string; | 21 using std::string; |
21 using testing::InSequence; | 22 using testing::InSequence; |
22 using testing::Return; | 23 using testing::Return; |
23 using testing::SaveArg; | 24 using testing::SaveArg; |
(...skipping 408 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
432 | 433 |
433 PacketContents contents; | 434 PacketContents contents; |
434 contents.num_stream_frames = 2; | 435 contents.num_stream_frames = 2; |
435 CheckPacketContains(contents, packet_); | 436 CheckPacketContains(contents, packet_); |
436 } | 437 } |
437 | 438 |
438 TEST_F(QuicPacketGeneratorTest, ConsumeDataFEC) { | 439 TEST_F(QuicPacketGeneratorTest, ConsumeDataFEC) { |
439 delegate_.SetCanWriteAnything(); | 440 delegate_.SetCanWriteAnything(); |
440 | 441 |
441 // Send FEC every two packets. | 442 // Send FEC every two packets. |
442 creator_.options()->max_packets_per_fec_group = 2; | 443 EXPECT_TRUE(QuicPacketCreatorPeer::SwitchFecProtectionOn(&creator_, 2)); |
443 | 444 |
444 { | 445 { |
445 InSequence dummy; | 446 InSequence dummy; |
446 EXPECT_CALL(delegate_, OnSerializedPacket(_)).WillOnce( | 447 EXPECT_CALL(delegate_, OnSerializedPacket(_)).WillOnce( |
447 DoAll(SaveArg<0>(&packet_), Return(true))); | 448 DoAll(SaveArg<0>(&packet_), Return(true))); |
448 EXPECT_CALL(delegate_, OnSerializedPacket(_)).WillOnce( | 449 EXPECT_CALL(delegate_, OnSerializedPacket(_)).WillOnce( |
449 DoAll(SaveArg<0>(&packet2_), Return(true))); | 450 DoAll(SaveArg<0>(&packet2_), Return(true))); |
450 EXPECT_CALL(delegate_, OnSerializedPacket(_)).WillOnce( | 451 EXPECT_CALL(delegate_, OnSerializedPacket(_)).WillOnce( |
451 DoAll(SaveArg<0>(&packet3_), Return(true))); | 452 DoAll(SaveArg<0>(&packet3_), Return(true))); |
452 EXPECT_CALL(delegate_, OnSerializedPacket(_)).WillOnce( | 453 EXPECT_CALL(delegate_, OnSerializedPacket(_)).WillOnce( |
(...skipping 15 matching lines...) Expand all Loading... |
468 CheckPacketIsFec(packet3_, 1); | 469 CheckPacketIsFec(packet3_, 1); |
469 | 470 |
470 CheckPacketHasSingleStreamFrame(packet4_); | 471 CheckPacketHasSingleStreamFrame(packet4_); |
471 CheckPacketIsFec(packet5_, 4); | 472 CheckPacketIsFec(packet5_, 4); |
472 } | 473 } |
473 | 474 |
474 TEST_F(QuicPacketGeneratorTest, ConsumeDataSendsFecAtEnd) { | 475 TEST_F(QuicPacketGeneratorTest, ConsumeDataSendsFecAtEnd) { |
475 delegate_.SetCanWriteAnything(); | 476 delegate_.SetCanWriteAnything(); |
476 | 477 |
477 // Send FEC every six packets. | 478 // Send FEC every six packets. |
478 creator_.options()->max_packets_per_fec_group = 6; | 479 EXPECT_TRUE(QuicPacketCreatorPeer::SwitchFecProtectionOn(&creator_, 6)); |
479 | |
480 { | 480 { |
481 InSequence dummy; | 481 InSequence dummy; |
482 EXPECT_CALL(delegate_, OnSerializedPacket(_)).WillOnce( | 482 EXPECT_CALL(delegate_, OnSerializedPacket(_)).WillOnce( |
483 DoAll(SaveArg<0>(&packet_), Return(true))); | 483 DoAll(SaveArg<0>(&packet_), Return(true))); |
484 EXPECT_CALL(delegate_, OnSerializedPacket(_)).WillOnce( | 484 EXPECT_CALL(delegate_, OnSerializedPacket(_)).WillOnce( |
485 DoAll(SaveArg<0>(&packet2_), Return(true))); | 485 DoAll(SaveArg<0>(&packet2_), Return(true))); |
486 EXPECT_CALL(delegate_, OnSerializedPacket(_)).WillOnce( | 486 EXPECT_CALL(delegate_, OnSerializedPacket(_)).WillOnce( |
487 DoAll(SaveArg<0>(&packet3_), Return(true))); | 487 DoAll(SaveArg<0>(&packet3_), Return(true))); |
488 } | 488 } |
489 | 489 |
(...skipping 139 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
629 | 629 |
630 // The second should have the remainder of the stream data. | 630 // The second should have the remainder of the stream data. |
631 PacketContents contents2; | 631 PacketContents contents2; |
632 contents2.num_goaway_frames = 1; | 632 contents2.num_goaway_frames = 1; |
633 contents2.num_stream_frames = 1; | 633 contents2.num_stream_frames = 1; |
634 CheckPacketContains(contents2, packet2_); | 634 CheckPacketContains(contents2, packet2_); |
635 } | 635 } |
636 | 636 |
637 } // namespace test | 637 } // namespace test |
638 } // namespace net | 638 } // namespace net |
OLD | NEW |