Searched refs:media_packet (Results 1 – 8 of 8) sorted by relevance
60 RtpPacketReceived media_packet; in OnRtpPacket() local61 media_packet.CopyHeaderFrom(rtx_packet); in OnRtpPacket()63 media_packet.SetSsrc(media_ssrc_); in OnRtpPacket()64 media_packet.SetSequenceNumber((payload[0] << 8) + payload[1]); in OnRtpPacket()65 media_packet.SetPayloadType(it->second); in OnRtpPacket()66 media_packet.set_recovered(true); in OnRtpPacket()67 media_packet.set_arrival_time_ms(rtx_packet.arrival_time_ms()); in OnRtpPacket()72 uint8_t* media_payload = media_packet.AllocatePayload(rtx_payload.size()); in OnRtpPacket()77 media_sink_->OnRtpPacket(media_packet); in OnRtpPacket()
114 std::unique_ptr<Packet> media_packet( in TEST_F() local118 receiver_.AddReceivedPacket(ParsePacket(*media_packet)); in TEST_F()130 const auto& media_packet = media_packets.front(); in TEST_F() local134 receiver_.AddReceivedPacket(ParsePacket(*media_packet)); in TEST_F()149 const auto& media_packet = media_packets.front(); in TEST_F() local155 receiver_.AddReceivedPacket(ParsePacket(*media_packet)); in TEST_F()166 auto& media_packet = media_packets.front(); in TEST_F() local168 media_packet->data[8] = 0; in TEST_F()169 media_packet->data[9] = 1; in TEST_F()170 media_packet->data[10] = 2; in TEST_F()[all …]
55 std::unique_ptr<ForwardErrorCorrection::Packet> media_packet( in ConstructMediaPackets() local57 media_packet->data.SetSize( in ConstructMediaPackets()60 uint8_t* data = media_packet->data.data(); in ConstructMediaPackets()83 for (size_t j = 12; j < media_packet->data.size(); ++j) in ConstructMediaPackets()86 media_packets.push_back(std::move(media_packet)); in ConstructMediaPackets()89 ForwardErrorCorrection::Packet* media_packet = media_packets.back().get(); in ConstructMediaPackets() local90 RTC_DCHECK(media_packet); in ConstructMediaPackets()91 media_packet->data[1] |= 0x80; in ConstructMediaPackets()
129 for (const auto& media_packet : media_packets) { in EncodeFec() local130 RTC_DCHECK(media_packet); in EncodeFec()131 if (media_packet->data.size() < kRtpHeaderSize) { in EncodeFec()132 RTC_LOG(LS_WARNING) << "Media packet " << media_packet->data.size() in EncodeFec()138 if (media_packet->data.size() + MaxPacketOverhead() + kTransportOverhead > in EncodeFec()140 RTC_LOG(LS_WARNING) << "Media packet " << media_packet->data.size() in EncodeFec()218 Packet* const media_packet = media_packets_it->get(); in GenerateFecPayloads() local219 const uint8_t* media_packet_data = media_packet->data.cdata(); in GenerateFecPayloads()223 media_packet->data.size() - kRtpHeaderSize; in GenerateFecPayloads()249 XorHeaders(*media_packet, fec_packet); in GenerateFecPayloads()[all …]
48 void BuildRedPayload(const RtpPacketToSend& media_packet, in BuildRedPayload() argument51 kRedForFecHeaderLength + media_packet.payload_size()); in BuildRedPayload()53 red_payload[0] = media_packet.PayloadType(); in BuildRedPayload()55 auto media_payload = media_packet.payload(); in BuildRedPayload()
154 [](const std::unique_ptr<ForwardErrorCorrection::Packet>& media_packet, in IsRecoveryComplete()157 if (media_packet->data.size() != recovered_packet->pkt->data.size()) { in IsRecoveryComplete()160 if (memcmp(media_packet->data.cdata(), in IsRecoveryComplete()162 media_packet->data.size()) != 0) { in IsRecoveryComplete()
1362 std::unique_ptr<RtpPacketToSend> media_packet; in TEST_P() local1371 media_packet = std::move(packet); in TEST_P()1374 flexfec_sender.AddPacketAndGenerateFec(*media_packet); in TEST_P()1395 ASSERT_TRUE(media_packet != nullptr); in TEST_P()1399 rtp_sender_context_->InjectPacket(std::move(media_packet), PacedPacketInfo()); in TEST_P()1472 const RtpPacketReceived& media_packet = transport_.sent_packets_[0]; in TEST_P() local1473 EXPECT_EQ(kMediaPayloadType, media_packet.PayloadType()); in TEST_P()1474 EXPECT_EQ(kSsrc, media_packet.Ssrc()); in TEST_P()
248 std::unique_ptr<ForwardErrorCorrection::Packet> media_packet( in RunTest() local255 media_packet->data.SetSize(packet_length); in RunTest()257 uint8_t* data = media_packet->data.data(); in RunTest()285 media_packet_list.push_back(std::move(media_packet)); in RunTest()303 for (const auto& media_packet : media_packet_list) { in RunTest() local313 received_packet->pkt->data = media_packet->data; in RunTest()316 ByteReader<uint16_t>::ReadBigEndian(&media_packet->data[2]); in RunTest()410 for (const auto& media_packet : media_packet_list) { in RunTest() local422 media_packet->data.size()) in RunTest()426 media_packet->data.cdata(), in RunTest()[all …]