Home
last modified time | relevance | path

Searched refs:arrival_time_ms (Results 1 – 25 of 34) sorted by relevance

12

/external/webrtc/webrtc/modules/remote_bitrate_estimator/test/
Dpacket_receiver.cc92 int64_t arrival_time_ms = media_packet->send_time_ms(); in RunFor() local
94 delay_stats_.Push(arrival_time_ms - send_time_ms); in RunFor()
97 metric_recorder_->UpdateTimeMs(arrival_time_ms); in RunFor()
98 UpdateMetrics(arrival_time_ms, send_time_ms, in RunFor()
102 PlotDelay(arrival_time_ms, send_time_ms); in RunFor()
105 bwe_receiver_->ReceivePacket(arrival_time_ms, *media_packet); in RunFor()
106 FeedbackPacket* fb = bwe_receiver_->GetFeedback(arrival_time_ms); in RunFor()
119 void PacketReceiver::UpdateMetrics(int64_t arrival_time_ms, in UpdateMetrics() argument
123 metric_recorder_->UpdateDelayMs(arrival_time_ms - send_time_ms); in UpdateMetrics()
128 void PacketReceiver::PlotDelay(int64_t arrival_time_ms, int64_t send_time_ms) { in PlotDelay() argument
[all …]
Dmetric_recorder_unittest.cc49 int64_t arrival_time_ms = kInterpacketGapMs * i + kDelayMs; in TEST_F() local
50 metric_recorder_.UpdateTimeMs(arrival_time_ms); in TEST_F()
51 metric_recorder_.PushDelayMs(kDelayMs, arrival_time_ms); in TEST_F()
52 metric_recorder_.PushThroughputBytes(kPayloadSizeBytes, arrival_time_ms); in TEST_F()
82 int64_t arrival_time_ms = kInterpacketGapMs * i + delays_ms[i]; in TEST_F() local
83 last_received_ms = std::max(last_received_ms, arrival_time_ms); in TEST_F()
84 metric_recorder_.UpdateTimeMs(arrival_time_ms); in TEST_F()
85 metric_recorder_.PushDelayMs(delays_ms[i], arrival_time_ms); in TEST_F()
86 metric_recorder_.PushThroughputBytes(kPayloadSizeBytes, arrival_time_ms); in TEST_F()
Dbwe.cc45 void BweReceiver::ReceivePacket(int64_t arrival_time_ms, in ReceivePacket() argument
52 media_packet.send_time_ms(), arrival_time_ms, in ReceivePacket()
188 int64_t time_limit_ms = (*node_it)->arrival_time_ms - kPacketLossTimeWindowMs; in RecentPacketLossRatio()
194 if ((*node_it)->arrival_time_ms < time_limit_ms) { in RecentPacketLossRatio()
221 int64_t arrival_time_ms, in Insert() argument
227 node->arrival_time_ms = arrival_time_ms; in Insert()
238 arrival_time_ms, payload_size)); in Insert()
244 packet_identifier.arrival_time_ms, packet_identifier.payload_size); in Insert()
Dbwe.h53 int64_t arrival_time_ms, in PacketIdentifierNode()
57 arrival_time_ms(arrival_time_ms), in PacketIdentifierNode()
62 int64_t arrival_time_ms; member
82 int64_t arrival_time_ms,
138 virtual void ReceivePacket(int64_t arrival_time_ms,
Dmetric_recorder.cc195 void MetricRecorder::PushDelayMs(int64_t delay_ms, int64_t arrival_time_ms) { in PushDelayMs() argument
196 if (ShouldRecord(arrival_time_ms)) { in PushDelayMs()
216 int64_t arrival_time_ms) { in PushThroughputBytes() argument
217 if (ShouldRecord(arrival_time_ms)) { in PushThroughputBytes()
230 (arrival_time_ms - plot_information_[kThroughput].time_ms)) / in PushThroughputBytes()
238 (arrival_time_ms - plot_information_[kThroughput].time_ms)) / in PushThroughputBytes()
245 bool MetricRecorder::ShouldRecord(int64_t arrival_time_ms) { in ShouldRecord() argument
246 if (arrival_time_ms >= start_computing_metrics_ms_) { in ShouldRecord()
248 start_computing_metrics_ms_ = arrival_time_ms; in ShouldRecord()
249 now_ms_ = arrival_time_ms; in ShouldRecord()
Dpacket_receiver.h51 void UpdateMetrics(int64_t arrival_time_ms,
59 void PlotDelay(int64_t arrival_time_ms, int64_t send_time_ms);
Dmetric_recorder.h140 bool ShouldRecord(int64_t arrival_time_ms);
142 void PushDelayMs(int64_t delay_ms, int64_t arrival_time_ms);
143 void PushThroughputBytes(size_t throughput_bytes, int64_t arrival_time_ms);
/external/webrtc/webrtc/modules/remote_bitrate_estimator/
Dtransport_feedback_adapter_unittest.cc94 truth[0].arrival_time_ms - input[0].arrival_time_ms; in ComparePacketVectors()
96 EXPECT_EQ(truth[i].arrival_time_ms, in ComparePacketVectors()
97 input[i].arrival_time_ms + arrival_time_delta); in ComparePacketVectors()
107 info.arrival_time_ms = 0; in OnSentPacket()
134 packets[0].arrival_time_ms * 1000); in TEST_F()
138 packet.arrival_time_ms * 1000)); in TEST_F()
170 packets[0].arrival_time_ms * 1000); in TEST_F()
175 packet.arrival_time_ms * 1000)); in TEST_F()
210 packets[i].arrival_time_ms * 1000); in TEST_F()
213 packets[i].sequence_number, packets[i].arrival_time_ms * 1000)); in TEST_F()
[all …]
Dinter_arrival.cc33 int64_t arrival_time_ms, in ComputeDeltas() argument
49 } else if (NewTimestampGroup(arrival_time_ms, timestamp)) { in ComputeDeltas()
80 current_timestamp_group_.complete_time_ms = arrival_time_ms; in ComputeDeltas()
100 bool InterArrival::NewTimestampGroup(int64_t arrival_time_ms, in NewTimestampGroup() argument
104 } else if (BelongsToBurst(arrival_time_ms, timestamp)) { in NewTimestampGroup()
113 bool InterArrival::BelongsToBurst(int64_t arrival_time_ms, in BelongsToBurst() argument
119 int64_t arrival_time_delta_ms = arrival_time_ms - in BelongsToBurst()
Dinter_arrival_unittest.cc48 void ExpectFalse(int64_t timestamp_us, int64_t arrival_time_ms, in ExpectFalse() argument
51 MakeRtpTimestamp(timestamp_us), arrival_time_ms, in ExpectFalse()
54 arrival_time_ms, packet_size); in ExpectFalse()
61 void ExpectTrue(int64_t timestamp_us, int64_t arrival_time_ms, in ExpectTrue() argument
67 arrival_time_ms, packet_size, in ExpectTrue()
72 arrival_time_ms, packet_size, in ExpectTrue()
163 uint32_t timestamp, int64_t arrival_time_ms, in InternalExpectFalse() argument
169 arrival_time_ms, in InternalExpectFalse()
181 uint32_t timestamp, int64_t arrival_time_ms, in InternalExpectTrue() argument
191 arrival_time_ms, in InternalExpectTrue()
Dsend_time_history_unittest.cc50 PacketInfo(int64_t arrival_time_ms, uint16_t sequence_number) in PacketInfo() argument
51 : PacketInfo(arrival_time_ms, 0, sequence_number, 0, false) {} in PacketInfo()
52 PacketInfo(int64_t arrival_time_ms, in PacketInfo() argument
58 arrival_time_ms, in PacketInfo()
64 return arrival_time_ms == other.arrival_time_ms && in operator ==()
99 EXPECT_EQ(kReceiveTime, info.arrival_time_ms); in TEST_F()
134 sent_packet.arrival_time_ms = packet.arrival_time_ms; in TEST_F()
Dinter_arrival.h42 int64_t arrival_time_ms,
71 bool NewTimestampGroup(int64_t arrival_time_ms, uint32_t timestamp) const;
73 bool BelongsToBurst(int64_t arrival_time_ms, uint32_t timestamp) const;
Dremote_bitrate_estimator_abs_send_time.cc233 IncomingPacketInfo(packet_info.arrival_time_ms, in IncomingPacketFeedbackVector()
239 void RemoteBitrateEstimatorAbsSendTime::IncomingPacket(int64_t arrival_time_ms, in IncomingPacket() argument
248 IncomingPacketInfo(arrival_time_ms, header.extension.absoluteSendTime, in IncomingPacket()
253 int64_t arrival_time_ms, in IncomingPacketInfo() argument
291 recv_delta_ms = arrival_time_ms - probes_.back().recv_time_ms; in IncomingPacketInfo()
294 << " ms, recv time=" << arrival_time_ms in IncomingPacketInfo()
298 probes_.push_back(Probe(send_time_ms, arrival_time_ms, payload_size)); in IncomingPacketInfo()
307 if (inter_arrival_->ComputeDeltas(timestamp, arrival_time_ms, payload_size, in IncomingPacketInfo()
312 estimator_.num_of_deltas(), arrival_time_ms); in IncomingPacketInfo()
Dremote_estimator_proxy.cc41 OnPacketArrival(info.sequence_number, info.arrival_time_ms); in IncomingPacketFeedbackVector()
44 void RemoteEstimatorProxy::IncomingPacket(int64_t arrival_time_ms, in IncomingPacket() argument
55 OnPacketArrival(header.extension.transportSequenceNumber, arrival_time_ms); in IncomingPacket()
Dsend_time_history.cc90 int64_t receive_time = packet->arrival_time_ms; in GetInfo()
92 packet->arrival_time_ms = receive_time; in GetInfo()
Dremote_bitrate_estimator_abs_send_time.h75 void IncomingPacket(int64_t arrival_time_ms,
102 void IncomingPacketInfo(int64_t arrival_time_ms,
/external/webrtc/webrtc/modules/remote_bitrate_estimator/test/estimators/
Dremb.cc84 void RembReceiver::ReceivePacket(int64_t arrival_time_ms, in ReceivePacket() argument
92 while ((clock_.TimeInMilliseconds() + step_ms) < arrival_time_ms) { in ReceivePacket()
97 estimator_->IncomingPacket(arrival_time_ms, media_packet.payload_size(), in ReceivePacket()
99 clock_.AdvanceTimeMilliseconds(arrival_time_ms - clock_.TimeInMilliseconds()); in ReceivePacket()
100 ASSERT_TRUE(arrival_time_ms == clock_.TimeInMilliseconds()); in ReceivePacket()
103 BweReceiver::ReceivePacket(arrival_time_ms, media_packet); in ReceivePacket()
Dtcp.cc34 void TcpBweReceiver::ReceivePacket(int64_t arrival_time_ms, in ReceivePacket() argument
36 latest_owd_ms_ = arrival_time_ms - media_packet.sender_timestamp_ms() / 1000; in ReceivePacket()
40 BweReceiver::ReceivePacket(arrival_time_ms, media_packet); in ReceivePacket()
Dsend_side.cc126 void SendSideBweReceiver::ReceivePacket(int64_t arrival_time_ms, in ReceivePacket() argument
129 -1, arrival_time_ms, media_packet.sender_timestamp_ms(), in ReceivePacket()
133 BweReceiver::ReceivePacket(arrival_time_ms, media_packet); in ReceivePacket()
142 packet_feedback_vector_.back().arrival_time_ms; in GetFeedback()
Dnada.cc49 void NadaBweReceiver::ReceivePacket(int64_t arrival_time_ms, in ReceivePacket() argument
55 clock_.AdvanceTimeMilliseconds(arrival_time_ms - clock_.TimeInMilliseconds()); 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()
118 latest->send_time_ms + now_ms - latest->arrival_time_ms; in GetFeedback()
Dnada_unittest.cc337 int64_t arrival_time_ms = send_time_us / 1000 + kOneWayDelayMs; in TEST_F() local
341 nada_receiver_.ReceivePacket(arrival_time_ms, media_packet); in TEST_F()
375 int64_t arrival_time_ms = send_time_us / 1000 + 10 * (i + 1); in TEST_F() local
379 nada_receiver_.ReceivePacket(arrival_time_ms, media_packet); in TEST_F()
382 nada_receiver_.GetFeedback(arrival_time_ms))); in TEST_F()
444 int64_t arrival_time_ms = send_time_us / 1000 + 50 + 200 * i; in TEST_F() local
448 nada_receiver_.ReceivePacket(arrival_time_ms, media_packet); in TEST_F()
451 nada_receiver_.GetFeedback(arrival_time_ms))); in TEST_F()
Dtcp.h26 void ReceivePacket(int64_t arrival_time_ms,
/external/webrtc/webrtc/modules/rtp_rtcp/include/
Drtp_rtcp_defines.h260 PacketInfo(int64_t arrival_time_ms, uint16_t sequence_number) in PacketInfo()
261 : PacketInfo(-1, arrival_time_ms, -1, sequence_number, 0, false) {} in PacketInfo()
263 PacketInfo(int64_t arrival_time_ms, in PacketInfo()
269 arrival_time_ms, in PacketInfo()
276 int64_t arrival_time_ms, in PacketInfo()
282 arrival_time_ms(arrival_time_ms), in PacketInfo()
292 int64_t arrival_time_ms; member
/external/webrtc/webrtc/video/
Dvie_receiver.cc277 int64_t arrival_time_ms; in InsertRTPPacket() local
280 arrival_time_ms = (packet_time.timestamp + 500) / 1000; in InsertRTPPacket()
282 arrival_time_ms = now_ms; in InsertRTPPacket()
292 << ", arrival time: " << arrival_time_ms; in InsertRTPPacket()
302 remote_bitrate_estimator_->IncomingPacket(arrival_time_ms, payload_length, in InsertRTPPacket()
/external/webrtc/webrtc/audio/
Daudio_receive_stream.cc180 int64_t arrival_time_ms = TickTime::MillisecondTimestamp(); in DeliverRtp() local
182 arrival_time_ms = (packet_time.timestamp + 500) / 1000; in DeliverRtp()
184 remote_bitrate_estimator_->IncomingPacket(arrival_time_ms, payload_size, in DeliverRtp()

12