OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
51 } | 51 } |
52 | 52 |
53 std::unique_ptr<Packet> WriteHeader(const uint8_t* packet_mask, | 53 std::unique_ptr<Packet> WriteHeader(const uint8_t* packet_mask, |
54 size_t packet_mask_size) { | 54 size_t packet_mask_size) { |
55 UlpfecHeaderWriter writer; | 55 UlpfecHeaderWriter writer; |
56 std::unique_ptr<Packet> written_packet(new Packet()); | 56 std::unique_ptr<Packet> written_packet(new Packet()); |
57 written_packet->length = kMediaPacketLength; | 57 written_packet->length = kMediaPacketLength; |
58 for (size_t i = 0; i < written_packet->length; ++i) { | 58 for (size_t i = 0; i < written_packet->length; ++i) { |
59 written_packet->data[i] = i; // Actual content doesn't matter. | 59 written_packet->data[i] = i; // Actual content doesn't matter. |
60 } | 60 } |
61 writer.FinalizeFecHeader(kMediaStartSeqNum, packet_mask, packet_mask_size, | 61 writer.FinalizeFecHeader(kMediaSsrc, kMediaStartSeqNum, packet_mask, |
62 written_packet.get()); | 62 packet_mask_size, written_packet.get()); |
63 return written_packet; | 63 return written_packet; |
64 } | 64 } |
65 | 65 |
66 std::unique_ptr<ReceivedFecPacket> ReadHeader(const Packet& written_packet) { | 66 std::unique_ptr<ReceivedFecPacket> ReadHeader(const Packet& written_packet) { |
67 UlpfecHeaderReader reader; | 67 UlpfecHeaderReader reader; |
68 std::unique_ptr<ReceivedFecPacket> read_packet(new ReceivedFecPacket()); | 68 std::unique_ptr<ReceivedFecPacket> read_packet(new ReceivedFecPacket()); |
69 read_packet->ssrc = kMediaSsrc; | 69 read_packet->ssrc = kMediaSsrc; |
70 read_packet->protected_ssrc = kMediaSsrc; | 70 read_packet->protected_ssrc = kMediaSsrc; |
71 read_packet->pkt = rtc::scoped_refptr<Packet>(new Packet()); | 71 read_packet->pkt = rtc::scoped_refptr<Packet>(new Packet()); |
72 memcpy(read_packet->pkt->data, written_packet.data, written_packet.length); | 72 memcpy(read_packet->pkt->data, written_packet.data, written_packet.length); |
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
127 TEST(UlpfecHeaderReaderWriterTest, WriteAndReadLargeHeader) { | 127 TEST(UlpfecHeaderReaderWriterTest, WriteAndReadLargeHeader) { |
128 auto packet_mask = GeneratePacketMask(kUlpfecPacketMaskSizeLBitSet, 0xabcd); | 128 auto packet_mask = GeneratePacketMask(kUlpfecPacketMaskSizeLBitSet, 0xabcd); |
129 auto written_packet = | 129 auto written_packet = |
130 WriteHeader(packet_mask.get(), kUlpfecPacketMaskSizeLBitSet); | 130 WriteHeader(packet_mask.get(), kUlpfecPacketMaskSizeLBitSet); |
131 auto read_packet = ReadHeader(*written_packet); | 131 auto read_packet = ReadHeader(*written_packet); |
132 VerifyHeaders(kUlpfecHeaderSizeLBitSet, packet_mask.get(), | 132 VerifyHeaders(kUlpfecHeaderSizeLBitSet, packet_mask.get(), |
133 kUlpfecPacketMaskSizeLBitSet, *written_packet, *read_packet); | 133 kUlpfecPacketMaskSizeLBitSet, *written_packet, *read_packet); |
134 } | 134 } |
135 | 135 |
136 } // namespace webrtc | 136 } // namespace webrtc |
OLD | NEW |