TokenBucketRateLimiter Class Reference

#include <rate-limit-strategy.h>

Inheritance diagram for TokenBucketRateLimiter:

[legend]Collaboration diagram for TokenBucketRateLimiter:

[legend]List of all members.

Public Member Functions
	TokenBucketRateLimiter ()
int	rateLimit (Packet *p, double estRate, double targetRate, int mine, int lowDemand)
void	reset ()
Public Attributes
double	bucket_depth_
double	tbucket_
double	time_last_token_
double	total_passed_
double	total_dropped_

---

Constructor & Destructor Documentation

TokenBucketRateLimiter::TokenBucketRateLimiter (   )

Definition at line 214 of file rate-limit-strategy.cc. References bucket_depth_, Scheduler::clock(), DEFAULT_BUCKET_DEPTH, Scheduler::instance(), tbucket_, time_last_token_, total_dropped_, and total_passed_. { bucket_depth_ = DEFAULT_BUCKET_DEPTH; tbucket_ = bucket_depth_; total_passed_ = 0.0; total_dropped_ = 0.0; time_last_token_ = Scheduler::instance().clock(); }

Here is the call graph for this function:

---

Member Function Documentation

int TokenBucketRateLimiter::rateLimit (  Packet *  p, double  estRate, double  targetRate, int  mine, int  lowDemand )  [virtual]

Implements RateLimiter. Definition at line 224 of file rate-limit-strategy.cc. References bucket_depth_, Scheduler::clock(), HDR_CMN, Scheduler::instance(), hdr_cmn::size_, tbucket_, time_last_token_, total_dropped_, and total_passed_. { hdr_cmn* hdr = HDR_CMN(p); double now = Scheduler::instance().clock(); double time_elapsed = now - time_last_token_; //printf("TB: now = %g last_sent = %g elapsed = %g\n", now, time_last_token_, time_elapsed); tbucket_ += (time_elapsed * targetRate)/8.0; time_last_token_ = now; if (tbucket_ > bucket_depth_) tbucket_ = bucket_depth_; /* never overflow */ //printf("TB: tbucket_ = %g pktSize = %g\n", tbucket_, (double)hdr->size_); //printf("TB: in = %g out = %g\n", total_passed_, total_dropped_); if ((double)hdr->size_ < tbucket_ || (mine && lowDemand) ) { tbucket_ -= hdr->size_; total_passed_ += (double) hdr->size_; //printf("Passed Packet in Rate Limiter\n"); return 0; } else { total_dropped_ += (double) hdr->size_; // printf("Dropped Packet in Rate Limiter\n"); return 1; } }

Here is the call graph for this function:

void TokenBucketRateLimiter::reset (   )  [virtual]

Implements RateLimiter. Definition at line 262 of file rate-limit-strategy.cc. References Scheduler::clock(), Scheduler::instance(), tbucket_, time_last_token_, total_dropped_, and total_passed_. { total_dropped_ = 0; total_passed_ = 0; tbucket_ = 0; time_last_token_ = Scheduler::instance().clock(); }

Here is the call graph for this function:

---

Member Data Documentation

double TokenBucketRateLimiter::bucket_depth_

Definition at line 102 of file rate-limit-strategy.h. Referenced by rateLimit(), and TokenBucketRateLimiter().

double TokenBucketRateLimiter::tbucket_

Definition at line 105 of file rate-limit-strategy.h. Referenced by rateLimit(), reset(), and TokenBucketRateLimiter().

double TokenBucketRateLimiter::time_last_token_

Definition at line 106 of file rate-limit-strategy.h. Referenced by rateLimit(), reset(), and TokenBucketRateLimiter().

double TokenBucketRateLimiter::total_dropped_

Definition at line 108 of file rate-limit-strategy.h. Referenced by rateLimit(), reset(), and TokenBucketRateLimiter().

double TokenBucketRateLimiter::total_passed_

Definition at line 107 of file rate-limit-strategy.h. Referenced by rateLimit(), reset(), and TokenBucketRateLimiter().

---

The documentation for this class was generated from the following files:

• rate-limit-strategy.h
• rate-limit-strategy.cc

---