Home
last modified time | relevance | path

Searched refs:media_packet (Results 1 – 17 of 17) sorted by relevance

/external/webrtc/webrtc/modules/remote_bitrate_estimator/test/
Dbwe_unittest.cc152 const MediaPacket media_packet(kFlowId, kSendTimeUs, kPayloadSizeBytes, in TEST_F() local
154 bwe_receiver_.ReceivePacket(kArrivalTimeMs, media_packet); in TEST_F()
171 const MediaPacket media_packet(kFlowId, send_time_us, kPayloadSizeBytes, in TEST_F() local
173 bwe_receiver_.ReceivePacket(arrival_time_ms, media_packet); in TEST_F()
186 const MediaPacket media_packet(kFlowId, 0, 0, 0); in TEST_F() local
187 bwe_receiver_.ReceivePacket(0, media_packet); in TEST_F()
198 const MediaPacket media_packet(kFlowId, 0, 0, sequence_number); in TEST_F() local
200 bwe_receiver_.ReceivePacket(0, media_packet); in TEST_F()
207 const MediaPacket media_packet(kFlowId, 0, 0, sequence_number); in TEST_F() local
209 bwe_receiver_.ReceivePacket(2 * kTimeWindowMs, media_packet); in TEST_F()
[all …]
Dpacket_receiver.cc89 const MediaPacket* media_packet = static_cast<const MediaPacket*>(*it); in RunFor() local
92 int64_t arrival_time_ms = media_packet->send_time_ms(); in RunFor()
93 int64_t send_time_ms = media_packet->creation_time_ms(); in RunFor()
99 media_packet->payload_size()); in RunFor()
105 bwe_receiver_->ReceivePacket(arrival_time_ms, *media_packet); in RunFor()
109 delete media_packet; in RunFor()
Dpacket_sender.cc211 MediaPacket* media_packet = static_cast<MediaPacket*>(packet); in RunFor() local
213 PacedSender::kNormalPriority, media_packet->header().ssrc, in RunFor()
214 media_packet->header().sequenceNumber, media_packet->send_time_ms(), in RunFor()
215 media_packet->payload_size(), false); in RunFor()
286 MediaPacket* media_packet = static_cast<MediaPacket*>(*it); in TimeToSendPacket() local
287 if (media_packet->header().sequenceNumber == sequence_number) { in TimeToSendPacket()
292 assert(pace_out_time_ms >= media_packet->send_time_ms()); in TimeToSendPacket()
294 media_packet->SetAbsSendTimeMs(pace_out_time_ms); in TimeToSendPacket()
295 media_packet->set_send_time_us(1000 * pace_out_time_ms); in TimeToSendPacket()
296 media_packet->set_sender_timestamp_us(1000 * pace_out_time_ms); in TimeToSendPacket()
[all …]
Dbwe.cc46 const MediaPacket& media_packet) { in ReceivePacket() argument
51 received_packets_.Insert(media_packet.sequence_number(), in ReceivePacket()
52 media_packet.send_time_ms(), arrival_time_ms, in ReceivePacket()
53 media_packet.payload_size()); in ReceivePacket()
55 rate_counter_.UpdateRates(media_packet.send_time_ms() * 1000, in ReceivePacket()
56 static_cast<uint32_t>(media_packet.payload_size())); in ReceivePacket()
Dbwe_test_framework_unittest.cc527 const MediaPacket* media_packet = static_cast<const MediaPacket*>(packet); in TestReorderFilter() local
528 uint16_t sequence_number = media_packet->header().sequenceNumber; in TestReorderFilter()
631 const MediaPacket* media_packet = static_cast<const MediaPacket*>(packet); in CheckMaxDelay() local
632 int64_t delay_us = media_packet->send_time_us() - in CheckMaxDelay()
633 send_times_us_[media_packet->header().sequenceNumber]; in CheckMaxDelay()
797 const MediaPacket* media_packet = static_cast<const MediaPacket*>(packet); in TestVideoSender() local
798 EXPECT_LE(send_time_us, media_packet->send_time_us()); in TestVideoSender()
799 send_time_us = media_packet->send_time_us(); in TestVideoSender()
801 media_packet->payload_size()) { in TestVideoSender()
802 EXPECT_EQ(expected_payload_size, media_packet->payload_size()); in TestVideoSender()
[all …]
Dbwe.h139 const MediaPacket& media_packet);
/external/webrtc/webrtc/modules/remote_bitrate_estimator/test/estimators/
Dsend_side.cc94 MediaPacket* media_packet = static_cast<MediaPacket*>(packet); in OnPacketsSent() local
95 send_time_history_.AddAndRemoveOld(media_packet->header().sequenceNumber, in OnPacketsSent()
96 media_packet->payload_size(), in OnPacketsSent()
98 send_time_history_.OnSentPacket(media_packet->header().sequenceNumber, in OnPacketsSent()
99 media_packet->sender_timestamp_ms()); in OnPacketsSent()
127 const MediaPacket& media_packet) { in ReceivePacket() argument
129 -1, arrival_time_ms, media_packet.sender_timestamp_ms(), in ReceivePacket()
130 media_packet.header().sequenceNumber, media_packet.payload_size(), true)); in ReceivePacket()
133 BweReceiver::ReceivePacket(arrival_time_ms, media_packet); in ReceivePacket()
Dtcp.cc35 const MediaPacket& media_packet) { in ReceivePacket() argument
36 latest_owd_ms_ = arrival_time_ms - media_packet.sender_timestamp_ms() / 1000; in ReceivePacket()
37 acks_.push_back(media_packet.header().sequenceNumber); in ReceivePacket()
40 BweReceiver::ReceivePacket(arrival_time_ms, media_packet); in ReceivePacket()
Dremb.cc85 const MediaPacket& media_packet) { in ReceivePacket() argument
86 recv_stats_->IncomingPacket(media_packet.header(), in ReceivePacket()
87 media_packet.payload_size(), false); in ReceivePacket()
97 estimator_->IncomingPacket(arrival_time_ms, media_packet.payload_size(), in ReceivePacket()
98 media_packet.header(), true); in ReceivePacket()
103 BweReceiver::ReceivePacket(arrival_time_ms, media_packet); in ReceivePacket()
Dnada.cc50 const MediaPacket& media_packet) { in ReceivePacket() argument
56 recv_stats_->IncomingPacket(media_packet.header(), in ReceivePacket()
57 media_packet.payload_size(), false); in ReceivePacket()
59 int64_t delay_ms = arrival_time_ms - media_packet.sender_timestamp_ms(); in ReceivePacket()
89 BweReceiver::ReceivePacket(arrival_time_ms, media_packet); in ReceivePacket()
Dnada_unittest.cc340 const MediaPacket media_packet(kFlowId, send_time_us, 0, sequence_number); in TEST_F() local
341 nada_receiver_.ReceivePacket(arrival_time_ms, media_packet); in TEST_F()
378 const MediaPacket media_packet(kFlowId, send_time_us, 0, sequence_number); in TEST_F() local
379 nada_receiver_.ReceivePacket(arrival_time_ms, media_packet); in TEST_F()
447 const MediaPacket media_packet(kFlowId, send_time_us, 0, sequence_number); in TEST_F() local
448 nada_receiver_.ReceivePacket(arrival_time_ms, media_packet); in TEST_F()
Dtcp.h27 const MediaPacket& media_packet) override;
Dsend_side.h57 const MediaPacket& media_packet) override;
Dremb.h58 const MediaPacket& media_packet) override;
Dnada.h40 const MediaPacket& media_packet) override;
/external/webrtc/webrtc/modules/rtp_rtcp/source/
Drtp_fec_unittest.cc819 ForwardErrorCorrection::Packet* media_packet; in IsRecoveryComplete() local
831 media_packet = *media_packet_list_item; in IsRecoveryComplete()
833 if (recovered_packet->pkt->length != media_packet->length) { in IsRecoveryComplete()
836 if (memcmp(recovered_packet->pkt->data, media_packet->data, in IsRecoveryComplete()
837 media_packet->length) != 0) { in IsRecoveryComplete()
897 ForwardErrorCorrection::Packet* media_packet = NULL; in ConstructMediaPacketsSeqNum() local
902 media_packet = new ForwardErrorCorrection::Packet; in ConstructMediaPacketsSeqNum()
903 media_packet_list_.push_back(media_packet); in ConstructMediaPacketsSeqNum()
908 media_packet->length = random_.Rand(kMinPacketSize, kMaxPacketSize); in ConstructMediaPacketsSeqNum()
911 media_packet->data[0] = random_.Rand<uint8_t>(); in ConstructMediaPacketsSeqNum()
[all …]
Dforward_error_correction.cc131 for (Packet* media_packet : media_packet_list) { in GenerateFEC()
132 assert(media_packet); in GenerateFEC()
134 if (media_packet->length < kRtpHeaderSize) { in GenerateFEC()
135 LOG(LS_WARNING) << "Media packet " << media_packet->length << " bytes " in GenerateFEC()
141 if (media_packet->length + PacketOverhead() + kTransportOverhead > in GenerateFEC()
143 LOG(LS_WARNING) << "Media packet " << media_packet->length << " bytes " in GenerateFEC()
230 Packet* media_packet = *media_list_it; in GenerateFecBitStrings() local
234 media_payload_length, media_packet->length - kRtpHeaderSize); in GenerateFecBitStrings()
236 fec_packet_length = media_packet->length + fec_rtp_offset; in GenerateFecBitStrings()
240 memcpy(fec_packet->data, media_packet->data, 2); in GenerateFecBitStrings()
[all …]