| Index: net/quic/core/quic_packet_creator_test.cc
|
| diff --git a/net/quic/core/quic_packet_creator_test.cc b/net/quic/core/quic_packet_creator_test.cc
|
| index 6a31455e76f8575f1dd3aa531c6ba153120f6cd8..176a65e72d08ec2b7818150cd419229741b4992d 100644
|
| --- a/net/quic/core/quic_packet_creator_test.cc
|
| +++ b/net/quic/core/quic_packet_creator_test.cc
|
| @@ -16,7 +16,6 @@
|
| #include "net/quic/core/quic_flags.h"
|
| #include "net/quic/core/quic_simple_buffer_allocator.h"
|
| #include "net/quic/core/quic_utils.h"
|
| -#include "net/quic/test_tools/mock_random.h"
|
| #include "net/quic/test_tools/quic_framer_peer.h"
|
| #include "net/quic/test_tools/quic_packet_creator_peer.h"
|
| #include "net/quic/test_tools/quic_test_utils.h"
|
| @@ -126,7 +125,6 @@ class QuicPacketCreatorTest : public ::testing::TestWithParam<TestParams> {
|
| data_("foo"),
|
| creator_(connection_id_,
|
| &client_framer_,
|
| - &mock_random_,
|
| &buffer_allocator_,
|
| &delegate_),
|
| serialized_packet_(creator_.NoPacket()) {
|
| @@ -135,7 +133,6 @@ class QuicPacketCreatorTest : public ::testing::TestWithParam<TestParams> {
|
| creator_.SetEncrypter(ENCRYPTION_INITIAL, new NullEncrypter());
|
| creator_.SetEncrypter(ENCRYPTION_FORWARD_SECURE, new NullEncrypter());
|
| client_framer_.set_visitor(&framer_visitor_);
|
| - client_framer_.set_received_entropy_calculator(&entropy_calculator_);
|
| server_framer_.set_visitor(&framer_visitor_);
|
| }
|
|
|
| @@ -223,10 +220,8 @@ class QuicPacketCreatorTest : public ::testing::TestWithParam<TestParams> {
|
| QuicConnectionId connection_id_;
|
| string data_;
|
| struct iovec iov_;
|
| - MockRandom mock_random_;
|
| SimpleBufferAllocator buffer_allocator_;
|
| QuicPacketCreator creator_;
|
| - MockEntropyCalculator entropy_calculator_;
|
| SerializedPacket serialized_packet_;
|
| };
|
|
|
| @@ -827,117 +822,6 @@ TEST_P(QuicPacketCreatorTest, SerializeAndSendStreamFrame) {
|
| EXPECT_FALSE(creator_.HasPendingFrames());
|
| }
|
|
|
| -TEST_P(QuicPacketCreatorTest, SerializeTruncatedAckFrameWithLargePacketSize) {
|
| - creator_.set_encryption_level(ENCRYPTION_FORWARD_SECURE);
|
| - if (!GetParam().version_serialization) {
|
| - creator_.StopSendingVersion();
|
| - }
|
| - creator_.SetMaxPacketLength(kMaxPacketSize);
|
| -
|
| - // Serialized length of ack frame with 2000 nack ranges should be limited by
|
| - // the number of nack ranges that can be fit in an ack frame.
|
| - QuicAckFrame ack_frame = MakeAckFrameWithNackRanges(2000u, 0u);
|
| - size_t frame_len = client_framer_.GetSerializedFrameLength(
|
| - QuicFrame(&ack_frame), creator_.BytesFree(), true, true,
|
| - PACKET_1BYTE_PACKET_NUMBER);
|
| - EXPECT_GT(creator_.BytesFree(), frame_len);
|
| - EXPECT_GT(creator_.max_packet_length(), creator_.PacketSize());
|
| -
|
| - // Add ack frame to creator.
|
| - EXPECT_TRUE(creator_.AddSavedFrame(QuicFrame(&ack_frame)));
|
| - EXPECT_TRUE(creator_.HasPendingFrames());
|
| - EXPECT_GT(creator_.max_packet_length(), creator_.PacketSize());
|
| - EXPECT_LT(0u, creator_.BytesFree());
|
| -
|
| - // Make sure that an additional stream frame can be added to the packet.
|
| - QuicFrame frame;
|
| - QuicIOVector io_vector(MakeIOVector("test"));
|
| - ASSERT_TRUE(
|
| - creator_.ConsumeData(2u, io_vector, 0u, 0u, false, false, &frame));
|
| - ASSERT_TRUE(frame.stream_frame);
|
| - size_t consumed = frame.stream_frame->data_length;
|
| - EXPECT_EQ(4u, consumed);
|
| - EXPECT_TRUE(creator_.HasPendingFrames());
|
| -
|
| - // Ensure the packet is successfully created, and the packet size estimate
|
| - // matches the serialized packet length.
|
| - if (GetParam().version <= QUIC_VERSION_33) {
|
| - EXPECT_CALL(entropy_calculator_, EntropyHash(_))
|
| - .WillOnce(testing::Return(0));
|
| - }
|
| - EXPECT_CALL(delegate_, OnSerializedPacket(_))
|
| - .WillOnce(Invoke(this, &QuicPacketCreatorTest::SaveSerializedPacket));
|
| - size_t est_packet_size = creator_.PacketSize();
|
| - creator_.Flush();
|
| - ASSERT_TRUE(serialized_packet_.encrypted_buffer);
|
| - EXPECT_EQ(est_packet_size, client_framer_.GetMaxPlaintextSize(
|
| - serialized_packet_.encrypted_length));
|
| - DeleteSerializedPacket();
|
| -}
|
| -
|
| -TEST_P(QuicPacketCreatorTest, SerializeTruncatedAckFrameWithSmallPacketSize) {
|
| - if (!GetParam().version_serialization) {
|
| - creator_.StopSendingVersion();
|
| - }
|
| - creator_.SetMaxPacketLength(500u);
|
| -
|
| - const size_t max_plaintext_size =
|
| - client_framer_.GetMaxPlaintextSize(creator_.max_packet_length());
|
| - EXPECT_EQ(max_plaintext_size - creator_.PacketSize(), creator_.BytesFree());
|
| -
|
| - // Serialized length of ack frame with 2000 nack ranges should be limited by
|
| - // the packet size.
|
| - QuicAckFrame ack_frame = MakeAckFrameWithNackRanges(2000u, 0u);
|
| - size_t frame_len = client_framer_.GetSerializedFrameLength(
|
| - QuicFrame(&ack_frame), creator_.BytesFree(), true, true,
|
| - PACKET_1BYTE_PACKET_NUMBER);
|
| - EXPECT_EQ(creator_.BytesFree(), frame_len);
|
| -
|
| - // Add ack frame to creator.
|
| - EXPECT_TRUE(creator_.AddSavedFrame(QuicFrame(&ack_frame)));
|
| - EXPECT_TRUE(creator_.HasPendingFrames());
|
| - EXPECT_EQ(client_framer_.GetMaxPlaintextSize(creator_.max_packet_length()),
|
| - creator_.PacketSize());
|
| - EXPECT_EQ(0u, creator_.BytesFree());
|
| -
|
| - // Ensure the packet is successfully created, and the packet size estimate
|
| - // may not match the serialized packet length.
|
| - if (GetParam().version <= QUIC_VERSION_33) {
|
| - EXPECT_CALL(entropy_calculator_, EntropyHash(_)).WillOnce(Return(0));
|
| - }
|
| - size_t est_packet_size = creator_.PacketSize();
|
| - EXPECT_CALL(delegate_, OnSerializedPacket(_))
|
| - .WillOnce(Invoke(this, &QuicPacketCreatorTest::SaveSerializedPacket));
|
| - creator_.Flush();
|
| - ASSERT_TRUE(serialized_packet_.encrypted_buffer);
|
| - EXPECT_GE(est_packet_size, client_framer_.GetMaxPlaintextSize(
|
| - serialized_packet_.encrypted_length));
|
| - DeleteSerializedPacket();
|
| -}
|
| -
|
| -TEST_P(QuicPacketCreatorTest, EntropyFlag) {
|
| - frames_.push_back(QuicFrame(
|
| - new QuicStreamFrame(kCryptoStreamId, false, 0u, StringPiece())));
|
| -
|
| - for (int i = 0; i < 2; ++i) {
|
| - for (int j = 0; j < 64; ++j) {
|
| - SerializedPacket serialized = SerializeAllFrames(frames_);
|
| - // Verify both BoolSource and hash algorithm.
|
| - bool expected_rand_bool =
|
| - (mock_random_.RandUint64() & (UINT64_C(1) << j)) != 0;
|
| - bool observed_rand_bool =
|
| - (serialized.entropy_hash & (1 << ((j + 1) % 8))) != 0;
|
| - uint8_t rest_of_hash = serialized.entropy_hash & ~(1 << ((j + 1) % 8));
|
| - EXPECT_EQ(expected_rand_bool, observed_rand_bool);
|
| - EXPECT_EQ(0, rest_of_hash);
|
| - }
|
| - // After 64 calls, BoolSource will refresh the bucket - make sure it does.
|
| - mock_random_.ChangeValue();
|
| - }
|
| -
|
| - delete frames_[0].stream_frame;
|
| -}
|
| -
|
| TEST_P(QuicPacketCreatorTest, SetCurrentPath) {
|
| // Current path is the default path.
|
| EXPECT_EQ(kDefaultPathId, QuicPacketCreatorPeer::GetCurrentPath(&creator_));
|
|
|