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_creator.h" | 5 #include "net/quic/quic_packet_creator.h" |
6 | 6 |
7 #include "base/stl_util.h" | 7 #include "base/stl_util.h" |
8 #include "net/quic/crypto/null_encrypter.h" | 8 #include "net/quic/crypto/null_encrypter.h" |
9 #include "net/quic/crypto/quic_decrypter.h" | 9 #include "net/quic/crypto/quic_decrypter.h" |
10 #include "net/quic/crypto/quic_encrypter.h" | 10 #include "net/quic/crypto/quic_encrypter.h" |
(...skipping 831 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
842 1, 10000 * 256 * 256 / kDefaultMaxPacketSize); | 842 1, 10000 * 256 * 256 / kDefaultMaxPacketSize); |
843 EXPECT_EQ(PACKET_4BYTE_SEQUENCE_NUMBER, | 843 EXPECT_EQ(PACKET_4BYTE_SEQUENCE_NUMBER, |
844 creator_.next_sequence_number_length()); | 844 creator_.next_sequence_number_length()); |
845 | 845 |
846 creator_.UpdateSequenceNumberLength( | 846 creator_.UpdateSequenceNumberLength( |
847 1, GG_UINT64_C(1000) * 256 * 256 * 256 * 256 / kDefaultMaxPacketSize); | 847 1, GG_UINT64_C(1000) * 256 * 256 * 256 * 256 / kDefaultMaxPacketSize); |
848 EXPECT_EQ(PACKET_6BYTE_SEQUENCE_NUMBER, | 848 EXPECT_EQ(PACKET_6BYTE_SEQUENCE_NUMBER, |
849 creator_.next_sequence_number_length()); | 849 creator_.next_sequence_number_length()); |
850 } | 850 } |
851 | 851 |
852 TEST_P(QuicPacketCreatorTest, CreateStreamFrameWithNotifier) { | |
853 // Ensure that if CreateStreamFrame does not consume any data (e.g. a FIN only | |
854 // frame) then any QuicAckNotifier that is passed in still gets attached to | |
855 // the frame. | |
856 scoped_refptr<MockAckNotifierDelegate> delegate(new MockAckNotifierDelegate); | |
857 QuicAckNotifier notifier(delegate.get()); | |
858 QuicFrame frame; | |
859 IOVector empty_iovector; | |
860 bool fin = true; | |
861 size_t consumed_bytes = creator_.CreateStreamFrameWithNotifier( | |
862 1u, empty_iovector, 0u, fin, ¬ifier, &frame); | |
863 EXPECT_EQ(0u, consumed_bytes); | |
864 EXPECT_EQ(¬ifier, frame.stream_frame->notifier); | |
865 delete frame.stream_frame; | |
866 } | |
867 | |
868 TEST_P(QuicPacketCreatorTest, SerializeFrame) { | 852 TEST_P(QuicPacketCreatorTest, SerializeFrame) { |
869 if (!GetParam().version_serialization) { | 853 if (!GetParam().version_serialization) { |
870 creator_.StopSendingVersion(); | 854 creator_.StopSendingVersion(); |
871 } | 855 } |
872 frames_.push_back(QuicFrame(new QuicStreamFrame(0u, false, 0u, IOVector()))); | 856 frames_.push_back(QuicFrame(new QuicStreamFrame(0u, false, 0u, IOVector()))); |
873 SerializedPacket serialized = creator_.SerializeAllFrames(frames_); | 857 SerializedPacket serialized = creator_.SerializeAllFrames(frames_); |
874 delete frames_[0].stream_frame; | 858 delete frames_[0].stream_frame; |
875 | 859 |
876 QuicPacketHeader header; | 860 QuicPacketHeader header; |
877 { | 861 { |
(...skipping 194 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1072 // After 64 calls, BoolSource will refresh the bucket - make sure it does. | 1056 // After 64 calls, BoolSource will refresh the bucket - make sure it does. |
1073 mock_random_.ChangeValue(); | 1057 mock_random_.ChangeValue(); |
1074 } | 1058 } |
1075 | 1059 |
1076 delete frames_[0].stream_frame; | 1060 delete frames_[0].stream_frame; |
1077 } | 1061 } |
1078 | 1062 |
1079 } // namespace | 1063 } // namespace |
1080 } // namespace test | 1064 } // namespace test |
1081 } // namespace net | 1065 } // namespace net |
OLD | NEW |