| 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 |