Home
last modified time | relevance | path

Searched refs:received_packet (Results 1 – 16 of 16) sorted by relevance

/external/webrtc/modules/rtp_rtcp/source/
Dulpfec_receiver_impl.cc100 auto received_packet = in AddReceivedRedPacket() local
102 received_packet->pkt = new ForwardErrorCorrection::Packet(); in AddReceivedRedPacket()
106 received_packet->is_fec = payload_type == ulpfec_payload_type; in AddReceivedRedPacket()
107 received_packet->is_recovered = rtp_packet.recovered(); in AddReceivedRedPacket()
108 received_packet->ssrc = rtp_packet.Ssrc(); in AddReceivedRedPacket()
109 received_packet->seq_num = rtp_packet.SequenceNumber(); in AddReceivedRedPacket()
124 if (received_packet->is_fec) { in AddReceivedRedPacket()
127 received_packet->pkt->data = in AddReceivedRedPacket()
132 received_packet->pkt->data.EnsureCapacity(rtp_packet.headers_size() + in AddReceivedRedPacket()
135 received_packet->pkt->data.SetData(rtp_packet.data(), in AddReceivedRedPacket()
[all …]
Drtp_fec_unittest.cc120 std::unique_ptr<ForwardErrorCorrection::ReceivedPacket> received_packet( in ReceivedPackets() local
122 received_packet->pkt = new ForwardErrorCorrection::Packet(); in ReceivedPackets()
123 received_packet->pkt->data = packet->data; in ReceivedPackets()
124 received_packet->is_fec = is_fec; in ReceivedPackets()
126 received_packet->ssrc = kMediaSsrc; in ReceivedPackets()
129 received_packet->seq_num = in ReceivedPackets()
132 received_packet->ssrc = ForwardErrorCorrectionType::kFecSsrc; in ReceivedPackets()
136 received_packet->seq_num = fec_seq_num; in ReceivedPackets()
138 received_packets_.push_back(std::move(received_packet)); in ReceivedPackets()
282 for (const auto& received_packet : this->received_packets_) { in TYPED_TEST()
[all …]
Dflexfec_receiver.cc71 std::unique_ptr<ForwardErrorCorrection::ReceivedPacket> received_packet = in OnRtpPacket() local
73 if (!received_packet) in OnRtpPacket()
76 ProcessReceivedPacket(*received_packet); in OnRtpPacket()
96 std::unique_ptr<ForwardErrorCorrection::ReceivedPacket> received_packet( in AddReceivedPacket() local
98 received_packet->seq_num = packet.SequenceNumber(); in AddReceivedPacket()
99 received_packet->ssrc = packet.Ssrc(); in AddReceivedPacket()
100 if (received_packet->ssrc == ssrc_) { in AddReceivedPacket()
106 received_packet->is_fec = true; in AddReceivedPacket()
110 received_packet->pkt = rtc::scoped_refptr<ForwardErrorCorrection::Packet>( in AddReceivedPacket()
112 received_packet->pkt->data = in AddReceivedPacket()
[all …]
Dforward_error_correction.cc361 const ReceivedPacket& received_packet) { in InsertMediaPacket() argument
362 RTC_DCHECK_EQ(received_packet.ssrc, protected_media_ssrc_); in InsertMediaPacket()
366 RTC_DCHECK_EQ(recovered_packet->ssrc, received_packet.ssrc); in InsertMediaPacket()
367 if (recovered_packet->seq_num == received_packet.seq_num) { in InsertMediaPacket()
378 recovered_packet->ssrc = received_packet.ssrc; in InsertMediaPacket()
379 recovered_packet->seq_num = received_packet.seq_num; in InsertMediaPacket()
380 recovered_packet->pkt = received_packet.pkt; in InsertMediaPacket()
405 const ReceivedPacket& received_packet) { in InsertFecPacket() argument
406 RTC_DCHECK_EQ(received_packet.ssrc, ssrc_); in InsertFecPacket()
410 RTC_DCHECK_EQ(existing_fec_packet->ssrc, received_packet.ssrc); in InsertFecPacket()
[all …]
Dflexfec_receiver_unittest.cc117 std::unique_ptr<ForwardErrorCorrection::ReceivedPacket> received_packet = in TEST_F() local
119 ASSERT_TRUE(received_packet); in TEST_F()
120 receiver_.ProcessReceivedPacket(*received_packet); in TEST_F()
133 std::unique_ptr<ForwardErrorCorrection::ReceivedPacket> received_packet = in TEST_F() local
135 ASSERT_TRUE(received_packet); in TEST_F()
136 receiver_.ProcessReceivedPacket(*received_packet); in TEST_F()
137 received_packet = receiver_.AddReceivedPacket(ParsePacket(*fec_packet)); in TEST_F()
138 ASSERT_TRUE(received_packet); in TEST_F()
139 receiver_.ProcessReceivedPacket(*received_packet); in TEST_F()
154 std::unique_ptr<ForwardErrorCorrection::ReceivedPacket> received_packet = in TEST_F() local
[all …]
Dforward_error_correction.h221 void DecodeFec(const ReceivedPacket& received_packet,
269 void InsertPacket(const ReceivedPacket& received_packet,
274 const ReceivedPacket& received_packet);
285 const ReceivedPacket& received_packet);
Drtp_sender_unittest.cc2324 const RtpPacketReceived& received_packet = transport_.last_sent_packet(); in TEST_P() local
2326 EXPECT_EQ(received_packet.GetExtension<TransmissionOffset>(), kDiffMs * 90); in TEST_P()
2328 EXPECT_EQ(received_packet.GetExtension<AbsoluteSendTime>(), in TEST_P()
2332 EXPECT_TRUE(received_packet.GetExtension<VideoTimingExtension>(&timing)); in TEST_P()
/external/webrtc/test/fuzzers/
Dforward_error_correction_fuzzer.cc67 ForwardErrorCorrection::ReceivedPacket received_packet; in FuzzOneInput() local
68 received_packet.pkt = rtc::scoped_refptr<ForwardErrorCorrection::Packet>( in FuzzOneInput()
70 received_packet.pkt->data.SetSize(kPacketSize); in FuzzOneInput()
71 received_packet.pkt->data.EnsureCapacity(IP_PACKET_SIZE); in FuzzOneInput()
72 uint8_t* packet_buffer = received_packet.pkt->data.data(); in FuzzOneInput()
95 received_packet.is_fec = true; in FuzzOneInput()
96 received_packet.ssrc = kFecSsrc; in FuzzOneInput()
97 received_packet.seq_num = seq_num_diff + fec_seqnum++; in FuzzOneInput()
107 received_packet.is_fec = false; in FuzzOneInput()
108 received_packet.ssrc = kMediaSsrc; in FuzzOneInput()
[all …]
/external/webrtc/modules/rtp_rtcp/test/testFec/
Dtest_fec.cc65 ForwardErrorCorrection::ReceivedPacket* received_packet = in ReceivePackets() local
71 *duplicate_packet = *received_packet; in ReceivePackets()
73 duplicate_packet->pkt->data = received_packet->pkt->data; in ReceivePackets()
310 received_packet( in RunTest() local
312 received_packet->pkt = new ForwardErrorCorrection::Packet(); in RunTest()
313 received_packet->pkt->data = media_packet->data; in RunTest()
314 received_packet->ssrc = media_ssrc; in RunTest()
315 received_packet->seq_num = in RunTest()
317 received_packet->is_fec = false; in RunTest()
318 received_packet_list.push_back(std::move(received_packet)); in RunTest()
[all …]
/external/webrtc/modules/rtp_rtcp/include/
Dflexfec_receiver.h53 const ForwardErrorCorrection::ReceivedPacket& received_packet);
/external/webrtc/video/
Drtp_video_stream_receiver2_unittest.cc305 RtpPacketReceived received_packet(&extension_map); in TEST_F() local
306 received_packet.Parse(packet_to_send.data(), packet_to_send.size()); in TEST_F()
307 return received_packet; in TEST_F()
1203 RtpPacketReceived received_packet(&extension_map); in TEST_P() local
1204 received_packet.Parse(packet_to_send.data(), packet_to_send.size()); in TEST_P()
1218 received_packet.PayloadBuffer(), received_packet, video_header); in TEST_P()
Drtp_video_stream_receiver_unittest.cc300 RtpPacketReceived received_packet(&extension_map); in TEST_F() local
301 received_packet.Parse(packet_to_send.data(), packet_to_send.size()); in TEST_F()
302 return received_packet; in TEST_F()
1196 RtpPacketReceived received_packet(&extension_map); in TEST_P() local
1197 received_packet.Parse(packet_to_send.data(), packet_to_send.size()); in TEST_P()
1211 received_packet.PayloadBuffer(), received_packet, video_header); in TEST_P()
/external/webrtc/call/
Drtp_transport_controller_send_interface.h144 virtual void OnReceivedPacket(const ReceivedPacket& received_packet) = 0;
/external/openscreen/cast/streaming/
Dsender_packet_router_unittest.cc272 std::vector<uint8_t> received_packet; in TEST_F() local
277 received_packet.assign(packet.begin(), packet.end()); in TEST_F()
287 EXPECT_EQ(audio_rtcp_packet, received_packet); in TEST_F()
/external/webrtc/modules/rtp_rtcp/source/rtcp_packet/
Dtransport_feedback.cc651 for (const auto& received_packet : received_packets_) { in Create() local
652 int16_t delta = received_packet.delta_ticks(); in Create()
/external/webrtc/modules/congestion_controller/goog_cc/
Dgoog_cc_network_control.cc279 ReceivedPacket received_packet) { in OnReceivedPacket() argument
280 last_packet_received_time_ = received_packet.receive_time; in OnReceivedPacket()