91c237e374
Bug: webrtc:9155 Change-Id: Ib10f0a5ac6155364e9b5748002bad72ff21c083e Reviewed-on: https://webrtc-review.googlesource.com/73368 Commit-Queue: Sebastian Jansson <srte@webrtc.org> Reviewed-by: Björn Terelius <terelius@webrtc.org> Cr-Commit-Position: refs/heads/master@{#23124}
50 lines
1.8 KiB
C++
50 lines
1.8 KiB
C++
/*
|
|
* Copyright (c) 2018 The WebRTC project authors. All Rights Reserved.
|
|
*
|
|
* Use of this source code is governed by a BSD-style license
|
|
* that can be found in the LICENSE file in the root of the source
|
|
* tree. An additional intellectual property rights grant can be found
|
|
* in the file PATENTS. All contributing project authors may
|
|
* be found in the AUTHORS file in the root of the source tree.
|
|
*/
|
|
#ifndef MODULES_CONGESTION_CONTROLLER_BBR_DATA_TRANSFER_TRACKER_H_
|
|
#define MODULES_CONGESTION_CONTROLLER_BBR_DATA_TRANSFER_TRACKER_H_
|
|
|
|
#include <deque>
|
|
#include "modules/congestion_controller/network_control/units/data_size.h"
|
|
#include "modules/congestion_controller/network_control/units/time_delta.h"
|
|
#include "modules/congestion_controller/network_control/units/timestamp.h"
|
|
|
|
namespace webrtc {
|
|
namespace bbr {
|
|
class DataTransferTracker {
|
|
public:
|
|
struct Result {
|
|
TimeDelta ack_timespan = TimeDelta::Zero();
|
|
TimeDelta send_timespan = TimeDelta::Zero();
|
|
DataSize acked_data = DataSize::Zero();
|
|
};
|
|
DataTransferTracker();
|
|
~DataTransferTracker();
|
|
void AddSample(DataSize size_delta, Timestamp send_time, Timestamp ack_time);
|
|
void ClearOldSamples(Timestamp excluding_end);
|
|
|
|
// Get the average data rate in the window that starts with the last ack which
|
|
// comes before covered_start and ends at the first ack that comes after or at
|
|
// including_end.
|
|
Result GetRatesByAckTime(Timestamp covered_start, Timestamp including_end);
|
|
|
|
private:
|
|
struct Sample {
|
|
Timestamp ack_time = Timestamp::Infinity();
|
|
Timestamp send_time = Timestamp::Infinity();
|
|
DataSize size_delta = DataSize::Zero();
|
|
DataSize size_sum = DataSize::Zero();
|
|
};
|
|
std::deque<Sample> samples_;
|
|
DataSize size_sum_ = DataSize::Zero();
|
|
};
|
|
} // namespace bbr
|
|
} // namespace webrtc
|
|
#endif // MODULES_CONGESTION_CONTROLLER_BBR_DATA_TRANSFER_TRACKER_H_
|