blob: fd1adc70c6434c6d9e99cb734ef2af620a65ff8f [file] [log] [blame]
Stefan Holmer4c1093b2015-12-11 18:25:45 +01001/*
2 * Copyright (c) 2015 The WebRTC project authors. All Rights Reserved.
3 *
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
6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree.
9 */
kwibergbfefb032016-05-01 14:53:46 -070010
11#include <memory>
12
Stefan Holmer4c1093b2015-12-11 18:25:45 +010013#include "webrtc/base/checks.h"
Stefan Holmer4c1093b2015-12-11 18:25:45 +010014#include "webrtc/modules/rtp_rtcp/source/byte_io.h"
brandtr74811e52016-08-10 00:51:50 -070015#include "webrtc/modules/rtp_rtcp/source/fec_test_helper.h"
brandtr869e7cd2016-10-31 05:27:07 -070016#include "webrtc/modules/rtp_rtcp/source/ulpfec_generator.h"
Stefan Holmer4c1093b2015-12-11 18:25:45 +010017
18namespace webrtc {
19
brandtrece4aba2016-09-20 23:16:28 -070020namespace {
21constexpr uint8_t kFecPayloadType = 96;
22constexpr uint8_t kRedPayloadType = 97;
23} // namespace
24
Stefan Holmer4c1093b2015-12-11 18:25:45 +010025void FuzzOneInput(const uint8_t* data, size_t size) {
brandtr869e7cd2016-10-31 05:27:07 -070026 UlpfecGenerator generator;
Stefan Holmer4c1093b2015-12-11 18:25:45 +010027 size_t i = 0;
28 if (size < 4)
29 return;
Peter Boströmd6b9d772016-04-27 00:18:41 +020030 FecProtectionParams params = {
31 data[i++] % 128, static_cast<int>(data[i++] % 10), kFecMaskBursty};
brandtr869e7cd2016-10-31 05:27:07 -070032 generator.SetFecParameters(&params);
Stefan Holmer4c1093b2015-12-11 18:25:45 +010033 uint16_t seq_num = data[i++];
34
35 while (i + 3 < size) {
36 size_t rtp_header_length = data[i++] % 10 + 12;
37 size_t payload_size = data[i++] % 10;
38 if (i + payload_size + rtp_header_length + 2 > size)
39 break;
kwibergbfefb032016-05-01 14:53:46 -070040 std::unique_ptr<uint8_t[]> packet(
Stefan Holmer4c1093b2015-12-11 18:25:45 +010041 new uint8_t[payload_size + rtp_header_length]);
42 memcpy(packet.get(), &data[i], payload_size + rtp_header_length);
43 ByteWriter<uint16_t>::WriteBigEndian(&packet[2], seq_num++);
44 i += payload_size + rtp_header_length;
45 // Make sure sequence numbers are increasing.
brandtr869e7cd2016-10-31 05:27:07 -070046 std::unique_ptr<RedPacket> red_packet = UlpfecGenerator::BuildRedPacket(
brandtr74811e52016-08-10 00:51:50 -070047 packet.get(), payload_size, rtp_header_length, kRedPayloadType);
Peter Boströmf5b804b2016-01-29 16:26:43 +010048 const bool protect = data[i++] % 2 == 1;
Stefan Holmer4c1093b2015-12-11 18:25:45 +010049 if (protect) {
brandtr869e7cd2016-10-31 05:27:07 -070050 generator.AddRtpPacketAndGenerateFec(packet.get(), payload_size,
51 rtp_header_length);
Stefan Holmer4c1093b2015-12-11 18:25:45 +010052 }
brandtr869e7cd2016-10-31 05:27:07 -070053 const size_t num_fec_packets = generator.NumAvailableFecPackets();
Stefan Holmer4c1093b2015-12-11 18:25:45 +010054 if (num_fec_packets > 0) {
brandtr74811e52016-08-10 00:51:50 -070055 std::vector<std::unique_ptr<RedPacket>> fec_packets =
brandtr869e7cd2016-10-31 05:27:07 -070056 generator.GetUlpfecPacketsAsRed(kRedPayloadType, kFecPayloadType, 100,
57 rtp_header_length);
Stefan Holmer4c1093b2015-12-11 18:25:45 +010058 RTC_CHECK_EQ(num_fec_packets, fec_packets.size());
Stefan Holmer4c1093b2015-12-11 18:25:45 +010059 }
60 }
61}
62} // namespace webrtc