blob: 25e3997c8a04968761d94f9f4e6ed054b30476cc [file] [log] [blame]
/*
* 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 "api/units/data_size.h"
#include "api/units/time_delta.h"
#include "api/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_