OLD | NEW |
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2013 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/test_tools/quic_packet_creator_peer.h" | 5 #include "net/quic/test_tools/quic_packet_creator_peer.h" |
6 | 6 |
7 #include "net/quic/quic_packet_creator.h" | 7 #include "net/quic/quic_packet_creator.h" |
8 | 8 |
9 namespace net { | 9 namespace net { |
10 namespace test { | 10 namespace test { |
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
58 return creator->packet_.packet_number_length; | 58 return creator->packet_.packet_number_length; |
59 } | 59 } |
60 | 60 |
61 void QuicPacketCreatorPeer::SetPacketNumber(QuicPacketCreator* creator, | 61 void QuicPacketCreatorPeer::SetPacketNumber(QuicPacketCreator* creator, |
62 QuicPacketNumber s) { | 62 QuicPacketNumber s) { |
63 creator->packet_.packet_number = s; | 63 creator->packet_.packet_number = s; |
64 } | 64 } |
65 | 65 |
66 // static | 66 // static |
67 void QuicPacketCreatorPeer::FillPacketHeader(QuicPacketCreator* creator, | 67 void QuicPacketCreatorPeer::FillPacketHeader(QuicPacketCreator* creator, |
68 QuicFecGroupNumber fec_group, | |
69 bool fec_flag, | |
70 QuicPacketHeader* header) { | 68 QuicPacketHeader* header) { |
71 creator->FillPacketHeader(fec_group, fec_flag, header); | 69 creator->FillPacketHeader(header); |
72 } | 70 } |
73 | 71 |
74 // static | 72 // static |
75 size_t QuicPacketCreatorPeer::CreateStreamFrame(QuicPacketCreator* creator, | 73 size_t QuicPacketCreatorPeer::CreateStreamFrame(QuicPacketCreator* creator, |
76 QuicStreamId id, | 74 QuicStreamId id, |
77 QuicIOVector iov, | 75 QuicIOVector iov, |
78 size_t iov_offset, | 76 size_t iov_offset, |
79 QuicStreamOffset offset, | 77 QuicStreamOffset offset, |
80 bool fin, | 78 bool fin, |
81 QuicFrame* frame) { | 79 QuicFrame* frame) { |
82 return creator->CreateStreamFrame(id, iov, iov_offset, offset, fin, frame); | 80 return creator->CreateStreamFrame(id, iov, iov_offset, offset, fin, frame); |
83 } | 81 } |
84 | 82 |
85 // static | 83 // static |
86 bool QuicPacketCreatorPeer::IsFecProtected(QuicPacketCreator* creator) { | |
87 return creator->fec_protect_; | |
88 } | |
89 | |
90 // static | |
91 bool QuicPacketCreatorPeer::IsFecEnabled(QuicPacketCreator* creator) { | |
92 return creator->max_packets_per_fec_group_ > 0; | |
93 } | |
94 | |
95 // static | |
96 void QuicPacketCreatorPeer::StartFecProtectingPackets( | |
97 QuicPacketCreator* creator) { | |
98 creator->StartFecProtectingPackets(); | |
99 } | |
100 | |
101 // static | |
102 void QuicPacketCreatorPeer::StopFecProtectingPackets( | |
103 QuicPacketCreator* creator) { | |
104 creator->StopFecProtectingPackets(); | |
105 } | |
106 | |
107 // static | |
108 void QuicPacketCreatorPeer::SerializeFec(QuicPacketCreator* creator, | |
109 char* buffer, | |
110 size_t buffer_len) { | |
111 creator->SerializeFec(buffer, buffer_len); | |
112 } | |
113 | |
114 // static | |
115 SerializedPacket QuicPacketCreatorPeer::SerializeAllFrames( | 84 SerializedPacket QuicPacketCreatorPeer::SerializeAllFrames( |
116 QuicPacketCreator* creator, | 85 QuicPacketCreator* creator, |
117 const QuicFrames& frames, | 86 const QuicFrames& frames, |
118 char* buffer, | 87 char* buffer, |
119 size_t buffer_len) { | 88 size_t buffer_len) { |
120 DCHECK(creator->queued_frames_.empty()); | 89 DCHECK(creator->queued_frames_.empty()); |
121 DCHECK(!frames.empty()); | 90 DCHECK(!frames.empty()); |
122 for (const QuicFrame& frame : frames) { | 91 for (const QuicFrame& frame : frames) { |
123 bool success = creator->AddFrame(frame, false); | 92 bool success = creator->AddFrame(frame, false); |
124 DCHECK(success); | 93 DCHECK(success); |
125 } | 94 } |
126 creator->SerializePacket(buffer, buffer_len); | 95 creator->SerializePacket(buffer, buffer_len); |
127 SerializedPacket packet = creator->packet_; | 96 SerializedPacket packet = creator->packet_; |
128 // The caller takes ownership of the QuicEncryptedPacket. | 97 // The caller takes ownership of the QuicEncryptedPacket. |
129 creator->packet_.encrypted_buffer = nullptr; | 98 creator->packet_.encrypted_buffer = nullptr; |
130 DCHECK(packet.retransmittable_frames.empty()); | 99 DCHECK(packet.retransmittable_frames.empty()); |
131 return packet; | 100 return packet; |
132 } | 101 } |
133 | 102 |
134 // static | 103 // static |
135 void QuicPacketCreatorPeer::ResetFecGroup(QuicPacketCreator* creator) { | |
136 creator->ResetFecGroup(); | |
137 } | |
138 | |
139 // static | |
140 QuicTime::Delta QuicPacketCreatorPeer::GetFecTimeout( | |
141 QuicPacketCreator* creator) { | |
142 return creator->fec_timeout_; | |
143 } | |
144 | |
145 // static | |
146 float QuicPacketCreatorPeer::GetRttMultiplierForFecTimeout( | |
147 QuicPacketCreator* creator) { | |
148 return creator->rtt_multiplier_for_fec_timeout_; | |
149 } | |
150 | |
151 // static | |
152 EncryptionLevel QuicPacketCreatorPeer::GetEncryptionLevel( | 104 EncryptionLevel QuicPacketCreatorPeer::GetEncryptionLevel( |
153 QuicPacketCreator* creator) { | 105 QuicPacketCreator* creator) { |
154 return creator->packet_.encryption_level; | 106 return creator->packet_.encryption_level; |
155 } | 107 } |
156 | 108 |
157 // static | 109 // static |
158 QuicPathId QuicPacketCreatorPeer::GetCurrentPath(QuicPacketCreator* creator) { | 110 QuicPathId QuicPacketCreatorPeer::GetCurrentPath(QuicPacketCreator* creator) { |
159 return creator->packet_.path_id; | 111 return creator->packet_.path_id; |
160 } | 112 } |
161 | 113 |
162 } // namespace test | 114 } // namespace test |
163 } // namespace net | 115 } // namespace net |
OLD | NEW |