/external/webrtc/webrtc/modules/pacing/ |
H A D | bitrate_prober_unittest.cc | 21 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 D | bitrate_prober.h | 39 int TimeUntilNextProbe(int64_t now_ms); 47 void PacketSent(int64_t now_ms, size_t packet_size);
|
H A D | bitrate_prober.cc | 80 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 D | rate_statistics_unittest.cc | 25 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 D | remote_bitrate_estimator_abs_send_time_unittest.cc | 108 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 D | rate_statistics.h | 28 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 D | aimd_rate_control.h | 41 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 D | rate_statistics.cc | 38 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 D | aimd_rate_control.cc | 89 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 D | overuse_detector.cc | 80 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 D | overuse_detector.h | 39 int64_t now_ms); 45 void UpdateThreshold(double modified_offset, int64_t now_ms);
|
H A D | remote_bitrate_estimator_single_stream.cc | 77 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 D | remote_bitrate_estimator_abs_send_time.cc | 186 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 D | overuse_detector_unittest.cc | 665 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 D | send_side_bandwidth_estimation_unittest.cc | 26 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 D | send_side_bandwidth_estimation.h | 33 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 D | send_side_bandwidth_estimation.cc | 102 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 D | tcp.cc | 43 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 D | tcp.h | 28 FeedbackPacket* GetFeedback(int64_t now_ms) override;
|
H A D | nada.cc | 92 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 D | send_side.cc | 136 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 D | network_predictor.cc | 29 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 D | timing.h | 61 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 D | timing.cc | 173 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 D | remote_ntp_time_estimator.cc | 68 int64_t now_ms = clock_->TimeInMilliseconds(); local 69 if (now_ms - last_timing_log_ms_ > kTimingLogIntervalMs) { 74 last_timing_log_ms_ = now_ms;
|