1// Copyright (c) 2013 The Chromium Authors. All rights reserved.
2// Use of this source code is governed by a BSD-style license that can be
3// found in the LICENSE file.
4
5#include "content/browser/renderer_host/p2p/socket_host_throttler.h"
6#include "third_party/webrtc/base/ratelimiter.h"
7#include "third_party/webrtc/base/timing.h"
8
9namespace content {
10
11namespace  {
12
13const int kMaxIceMessageBandwidth = 256 * 1024;
14
15}  // namespace
16
17
18P2PMessageThrottler::P2PMessageThrottler()
19    : timing_(new rtc::Timing()),
20      rate_limiter_(new rtc::RateLimiter(kMaxIceMessageBandwidth, 1.0)) {
21}
22
23P2PMessageThrottler::~P2PMessageThrottler() {
24}
25
26void P2PMessageThrottler::SetTiming(scoped_ptr<rtc::Timing> timing) {
27  timing_ = timing.Pass();
28}
29
30void P2PMessageThrottler::SetSendIceBandwidth(int bandwidth_kbps) {
31  rate_limiter_.reset(new rtc::RateLimiter(bandwidth_kbps, 1.0));
32}
33
34bool P2PMessageThrottler::DropNextPacket(size_t packet_len) {
35  double now = timing_->TimerNow();
36  if (!rate_limiter_->CanUse(packet_len, now)) {
37    // Exceeding the send rate, this packet should be dropped.
38    return true;
39  }
40
41  rate_limiter_->Use(packet_len, now);
42  return false;
43}
44
45}  // namespace content
46