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