rate_limiter.h 1.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758
  1. /*
  2. * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved.
  3. *
  4. * Use of this source code is governed by a BSD-style license
  5. * that can be found in the LICENSE file in the root of the source
  6. * tree. An additional intellectual property rights grant can be found
  7. * in the file PATENTS. All contributing project authors may
  8. * be found in the AUTHORS file in the root of the source tree.
  9. */
  10. #ifndef RTC_BASE_RATE_LIMITER_H_
  11. #define RTC_BASE_RATE_LIMITER_H_
  12. #include <stddef.h>
  13. #include <stdint.h>
  14. #include "rtc_base/constructor_magic.h"
  15. #include "rtc_base/critical_section.h"
  16. #include "rtc_base/rate_statistics.h"
  17. #include "rtc_base/thread_annotations.h"
  18. namespace webrtc {
  19. class Clock;
  20. // Class used to limit a bitrate, making sure the average does not exceed a
  21. // maximum as measured over a sliding window. This class is thread safe; all
  22. // methods will acquire (the same) lock befeore executing.
  23. class RateLimiter {
  24. public:
  25. RateLimiter(Clock* clock, int64_t max_window_ms);
  26. ~RateLimiter();
  27. // Try to use rate to send bytes. Returns true on success and if so updates
  28. // current rate.
  29. bool TryUseRate(size_t packet_size_bytes);
  30. // Set the maximum bitrate, in bps, that this limiter allows to send.
  31. void SetMaxRate(uint32_t max_rate_bps);
  32. // Set the window size over which to measure the current bitrate.
  33. // For example, irt retransmissions, this is typically the RTT.
  34. // Returns true on success and false if window_size_ms is out of range.
  35. bool SetWindowSize(int64_t window_size_ms);
  36. private:
  37. Clock* const clock_;
  38. rtc::CriticalSection lock_;
  39. RateStatistics current_rate_ RTC_GUARDED_BY(lock_);
  40. int64_t window_size_ms_ RTC_GUARDED_BY(lock_);
  41. uint32_t max_rate_bps_ RTC_GUARDED_BY(lock_);
  42. RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(RateLimiter);
  43. };
  44. } // namespace webrtc
  45. #endif // RTC_BASE_RATE_LIMITER_H_