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