Searched refs:now_ms (Results 1 - 25 of 61) sorted by relevance

123

/external/webrtc/webrtc/modules/pacing/
H A Dbitrate_prober_unittest.cc21 int64_t now_ms = 0; local
22 EXPECT_EQ(-1, prober.TimeUntilNextProbe(now_ms));
30 EXPECT_EQ(0, prober.TimeUntilNextProbe(now_ms));
31 prober.PacketSent(now_ms, 1000);
34 EXPECT_EQ(8, prober.TimeUntilNextProbe(now_ms));
35 now_ms += 4;
36 EXPECT_EQ(4, prober.TimeUntilNextProbe(now_ms));
37 now_ms += 4;
38 EXPECT_EQ(0, prober.TimeUntilNextProbe(now_ms));
39 prober.PacketSent(now_ms, 100
[all...]
H A Dbitrate_prober.h39 int TimeUntilNextProbe(int64_t now_ms);
47 void PacketSent(int64_t now_ms, size_t packet_size);
H A Dbitrate_prober.cc80 int BitrateProber::TimeUntilNextProbe(int64_t now_ms) { argument
88 int64_t elapsed_time_ms = now_ms - time_last_send_ms_;
120 void BitrateProber::PacketSent(int64_t now_ms, size_t packet_size) { argument
123 time_last_send_ms_ = now_ms;
/external/webrtc/webrtc/modules/remote_bitrate_estimator/
H A Drate_statistics_unittest.cc25 int64_t now_ms = 0; local
27 EXPECT_EQ(0u, stats_.Rate(now_ms));
28 stats_.Update(1500, now_ms);
30 EXPECT_EQ(24000u, stats_.Rate(now_ms));
33 EXPECT_EQ(0u, stats_.Rate(now_ms));
35 if (now_ms % 10 == 0) {
36 stats_.Update(1500, now_ms);
40 if (now_ms > 0 && now_ms % 500 == 0) {
41 EXPECT_NEAR(1200000u, stats_.Rate(now_ms), 2400
52 int64_t now_ms = 0; local
[all...]
H A Dremote_bitrate_estimator_abs_send_time_unittest.cc108 int64_t now_ms = clock_.TimeInMilliseconds(); local
112 now_ms = clock_.TimeInMilliseconds();
113 IncomingPacket(0, 1000, now_ms, 90 * now_ms, AbsSendTime(now_ms, 1000),
120 now_ms = clock_.TimeInMilliseconds();
121 IncomingPacket(0, 1000, now_ms, 90 * now_ms, AbsSendTime(now_ms, 1000),
133 int64_t now_ms local
157 int64_t now_ms = clock_.TimeInMilliseconds(); local
186 int64_t now_ms = clock_.TimeInMilliseconds(); local
205 int64_t now_ms = clock_.TimeInMilliseconds(); local
223 int64_t now_ms = clock_.TimeInMilliseconds(); local
243 int64_t now_ms = clock_.TimeInMilliseconds(); local
262 int64_t now_ms = clock_.TimeInMilliseconds(); local
[all...]
H A Drate_statistics.h28 void Update(size_t count, int64_t now_ms);
29 uint32_t Rate(int64_t now_ms);
32 void EraseOld(int64_t now_ms);
H A Daimd_rate_control.h41 uint32_t UpdateBandwidthEstimate(int64_t now_ms);
43 void Update(const RateControlInput* input, int64_t now_ms);
44 void SetEstimate(int bitrate_bps, int64_t now_ms);
56 int64_t now_ms);
57 uint32_t MultiplicativeRateIncrease(int64_t now_ms, int64_t last_ms,
59 uint32_t AdditiveRateIncrease(int64_t now_ms, int64_t last_ms,
61 void UpdateChangePeriod(int64_t now_ms);
63 void ChangeState(const RateControlInput& input, int64_t now_ms);
H A Drate_statistics.cc38 void RateStatistics::Update(size_t count, int64_t now_ms) { argument
39 if (now_ms < oldest_time_) {
44 EraseOld(now_ms);
46 int now_offset = static_cast<int>(now_ms - oldest_time_);
56 uint32_t RateStatistics::Rate(int64_t now_ms) { argument
57 EraseOld(now_ms);
61 void RateStatistics::EraseOld(int64_t now_ms) { argument
62 int64_t new_oldest_time = now_ms - num_buckets_ + 1;
H A Daimd_rate_control.cc89 uint32_t AimdRateControl::UpdateBandwidthEstimate(int64_t now_ms) { argument
91 current_input_.incoming_bitrate, now_ms);
92 if (now_ms - time_of_last_log_ > kLogIntervalMs) {
93 time_of_last_log_ = now_ms;
102 void AimdRateControl::Update(const RateControlInput* input, int64_t now_ms) { argument
112 time_first_incoming_estimate_ = now_ms;
114 } else if (now_ms - time_first_incoming_estimate_ > kInitializationTimeMs &&
132 void AimdRateControl::SetEstimate(int bitrate_bps, int64_t now_ms) { argument
135 current_bitrate_bps_ = ChangeBitrate(bitrate_bps, bitrate_bps, now_ms);
140 int64_t now_ms) {
138 ChangeBitrate(uint32_t current_bitrate_bps, uint32_t incoming_bitrate_bps, int64_t now_ms) argument
229 MultiplicativeRateIncrease( int64_t now_ms, int64_t last_ms, uint32_t current_bitrate_bps) const argument
242 AdditiveRateIncrease( int64_t now_ms, int64_t last_ms, int64_t response_time_ms) const argument
284 ChangeState(const RateControlInput& input, int64_t now_ms) argument
[all...]
H A Doveruse_detector.cc80 int64_t now_ms) {
87 BWE_TEST_LOGGING_PLOT(1, "offset", now_ms, T);
88 BWE_TEST_LOGGING_PLOT(1, "threshold", now_ms, threshold_);
117 UpdateThreshold(T, now_ms);
122 void OveruseDetector::UpdateThreshold(double modified_offset, int64_t now_ms) { argument
127 last_update_ms_ = now_ms;
132 last_update_ms_ = now_ms;
138 k * (fabs(modified_offset) - threshold_) * (now_ms - last_update_ms_);
144 last_update_ms_ = now_ms;
77 Detect(double offset, double ts_delta, int num_of_deltas, int64_t now_ms) argument
H A Doveruse_detector.h39 int64_t now_ms);
45 void UpdateThreshold(double modified_offset, int64_t now_ms);
H A Dremote_bitrate_estimator_single_stream.cc77 int64_t now_ms = clock_->TimeInMilliseconds(); local
89 ssrc, new Detector(now_ms, OverUseDetectorOptions(), true)));
93 estimator->last_packet_time_ms = now_ms;
94 incoming_bitrate_.Update(payload_size, now_ms);
107 estimator->estimator.num_of_deltas(), now_ms);
110 uint32_t incoming_bitrate_bps = incoming_bitrate_.Rate(now_ms);
112 remote_rate_->TimeToReduceFurther(now_ms, incoming_bitrate_bps)) {
116 UpdateEstimate(now_ms);
144 void RemoteBitrateEstimatorSingleStream::UpdateEstimate(int64_t now_ms) { argument
152 now_ms
[all...]
H A Dremote_bitrate_estimator_abs_send_time.cc186 void RemoteBitrateEstimatorAbsSendTime::ProcessClusters(int64_t now_ms) { argument
204 probe_bitrate_bps > static_cast<int>(incoming_bitrate_.Rate(now_ms))) {
211 remote_rate_.SetEstimate(probe_bitrate_bps, now_ms);
265 int64_t now_ms = clock_->TimeInMilliseconds();
268 ssrcs_[ssrc] = now_ms;
269 incoming_bitrate_.Update(payload_size, now_ms);
284 now_ms - first_packet_time_ms_ < kInitialProbingIntervalMs)) {
300 ProcessClusters(now_ms);
313 UpdateStats(static_cast<int>(t_delta - ts_delta_ms), now_ms);
316 uint32_t incoming_bitrate_bps = incoming_bitrate_.Rate(now_ms);
[all...]
H A Doveruse_detector_unittest.cc665 int64_t now_ms = 0; local
673 overuse_detector_->Detect(kOffset, kTsDelta, num_deltas, now_ms);
678 now_ms += 5;
686 overuse_detector_->Detect(1.1 * kOffset, kTsDelta, num_deltas, now_ms);
691 now_ms += 5;
699 overuse_detector_->Detect(kOffset, kTsDelta, num_deltas, now_ms);
704 now_ms += 5;
711 overuse_detector_->Detect(0.7 * kOffset, kTsDelta, num_deltas, now_ms);
716 now_ms += 5;
723 overuse_detector_->Detect(kOffset, kTsDelta, num_deltas, now_ms);
737 int64_t now_ms = 0; local
[all...]
/external/webrtc/webrtc/modules/bitrate_controller/
H A Dsend_side_bandwidth_estimation_unittest.cc26 int64_t now_ms = 0; local
28 bwe.UpdateReceiverBlock(0, 50, 1, now_ms);
31 bwe.UpdateReceiverEstimate(now_ms, kRembBps);
32 bwe.UpdateEstimate(now_ms);
40 now_ms += 2001;
41 bwe.UpdateReceiverEstimate(now_ms, kSecondRembBps);
42 bwe.UpdateEstimate(now_ms);
58 int64_t now_ms = 0; local
68 bwe.UpdateReceiverBlock(kFractionLoss, kRttMs, 100, now_ms);
70 now_ms
[all...]
H A Dsend_side_bandwidth_estimation.h33 void UpdateEstimate(int64_t now_ms);
36 void UpdateReceiverEstimate(int64_t now_ms, uint32_t bandwidth);
42 int64_t now_ms);
53 bool IsInStartPhase(int64_t now_ms) const;
55 void UpdateUmaStats(int64_t now_ms, int64_t rtt, int lost_packets);
59 uint32_t CapBitrateToThresholds(int64_t now_ms, uint32_t bitrate);
64 void UpdateMinHistory(int64_t now_ms);
H A Dsend_side_bandwidth_estimation.cc102 int64_t now_ms, uint32_t bandwidth) {
104 bitrate_ = CapBitrateToThresholds(now_ms, bitrate_);
110 int64_t now_ms) {
112 first_report_time_ms_ = now_ms;
137 time_last_receiver_block_ms_ = now_ms;
138 UpdateEstimate(now_ms);
139 UpdateUmaStats(now_ms, rtt, (fraction_loss * number_of_packets) >> 8);
142 void SendSideBandwidthEstimation::UpdateUmaStats(int64_t now_ms, argument
150 now_ms - first_report_time_ms_);
154 if (IsInStartPhase(now_ms)) {
101 UpdateReceiverEstimate( int64_t now_ms, uint32_t bandwidth) argument
107 UpdateReceiverBlock(uint8_t fraction_loss, int64_t rtt, int number_of_packets, int64_t now_ms) argument
175 UpdateEstimate(int64_t now_ms) argument
246 UpdateMinHistory(int64_t now_ms) argument
266 CapBitrateToThresholds( int64_t now_ms, uint32_t bitrate) argument
[all...]
/external/webrtc/webrtc/modules/remote_bitrate_estimator/test/estimators/
H A Dtcp.cc43 FeedbackPacket* TcpBweReceiver::GetFeedback(int64_t now_ms) { argument
44 int64_t corrected_send_time_ms = now_ms - latest_owd_ms_;
46 new TcpFeedback(flow_id_, now_ms * 1000, corrected_send_time_ms, acks_);
47 last_feedback_ms_ = now_ms;
H A Dtcp.h28 FeedbackPacket* GetFeedback(int64_t now_ms) override;
H A Dnada.cc92 FeedbackPacket* NadaBweReceiver::GetFeedback(int64_t now_ms) { argument
95 if (now_ms - last_feedback_ms_ < 100) {
108 static_cast<float>(now_ms - last_feedback_ms_);
110 last_feedback_ms_ = now_ms;
118 latest->send_time_ms + now_ms - latest->arrival_time_ms;
123 return new NadaFeedback(flow_id_, now_ms * 1000, exp_smoothed_delay_ms_,
186 int64_t now_ms = clock_->TimeInMilliseconds(); local
187 float delta_s = now_ms - last_feedback_ms_;
188 last_feedback_ms_ = now_ms;
194 int64_t rtt_ms = now_ms
[all...]
H A Dsend_side.cc136 FeedbackPacket* SendSideBweReceiver::GetFeedback(int64_t now_ms) { argument
137 if (now_ms - last_feedback_ms_ < kFeedbackIntervalMs)
139 last_feedback_ms_ = now_ms;
141 packet_feedback_vector_.back().send_time_ms + now_ms -
144 flow_id_, now_ms * 1000, corrected_send_time_ms, packet_feedback_vector_);
/external/webrtc/webrtc/voice_engine/
H A Dnetwork_predictor.cc29 int64_t now_ms = clock_->TimeInMilliseconds(); local
32 static_cast<float>(now_ms - last_loss_rate_update_time_ms_),
34 last_loss_rate_update_time_ms_ = now_ms;
/external/webrtc/webrtc/modules/video_coding/
H A Dtiming.h61 int64_t now_ms,
69 // is now_ms.
70 int64_t RenderTimeMs(uint32_t frame_timestamp, int64_t now_ms) const;
74 uint32_t MaxWaitingTime(int64_t render_time_ms, int64_t now_ms) const;
99 int64_t RenderTimeMsInternal(uint32_t frame_timestamp, int64_t now_ms) const
H A Dtiming.cc173 int64_t now_ms,
176 codec_timer_.MaxFilter(decode_time_ms, now_ms);
183 first_decoded_frame_ms_ = now_ms;
185 int time_until_rendering_ms = render_time_ms - render_delay_ms_ - now_ms;
193 void VCMTiming::IncomingTimestamp(uint32_t time_stamp, int64_t now_ms) { argument
195 ts_extrapolator_->Update(now_ms, time_stamp);
199 int64_t now_ms) const {
201 const int64_t render_time_ms = RenderTimeMsInternal(frame_timestamp, now_ms);
206 int64_t now_ms) const {
210 estimated_complete_time_ms = now_ms;
171 StopDecodeTimer(uint32_t time_stamp, int32_t decode_time_ms, int64_t now_ms, int64_t render_time_ms) argument
[all...]
/external/webrtc/webrtc/modules/rtp_rtcp/source/
H A Dremote_ntp_time_estimator.cc68 int64_t now_ms = clock_->TimeInMilliseconds(); local
69 if (now_ms - last_timing_log_ms_ > kTimingLogIntervalMs) {
74 last_timing_log_ms_ = now_ms;

Completed in 313 milliseconds

123