diff options
author | Stephen Hemminger <stephen.hemminger@vyatta.com> | 2009-05-23 08:57:19 -0700 |
---|---|---|
committer | Stephen Hemminger <stephen.hemminger@vyatta.com> | 2009-05-23 15:19:54 -0700 |
commit | 87794a3d5ddb55af9cc298ec97b2892918e657d4 (patch) | |
tree | da72c22470325ba2b891350e7c435a0bad2a2960 /lib/Vyatta/Qos/WeightedRandom.pm | |
parent | a7ec99d913b0169b987a4ebdf2d26a36670b20bb (diff) | |
download | vyatta-cfg-qos-87794a3d5ddb55af9cc298ec97b2892918e657d4.tar.gz vyatta-cfg-qos-87794a3d5ddb55af9cc298ec97b2892918e657d4.zip |
Reimplementation of WRED
Make a simpler version of WRED that acts more like Cisco.
Use Diffserv on Linux paper for example of how to use DSMARK and GRED
to achieve similar result.
Diffstat (limited to 'lib/Vyatta/Qos/WeightedRandom.pm')
-rw-r--r-- | lib/Vyatta/Qos/WeightedRandom.pm | 185 |
1 files changed, 0 insertions, 185 deletions
diff --git a/lib/Vyatta/Qos/WeightedRandom.pm b/lib/Vyatta/Qos/WeightedRandom.pm deleted file mode 100644 index 0b1dc37..0000000 --- a/lib/Vyatta/Qos/WeightedRandom.pm +++ /dev/null @@ -1,185 +0,0 @@ -# Weighted Random i.e. GRED (Generic Random Early Detect) -# -# **** License **** -# This program is free software; you can redistribute it and/or modify -# it under the terms of the GNU General Public License version 2 as -# published by the Free Software Foundation. -# -# This program is distributed in the hope that it will be useful, but -# WITHOUT ANY WARRANTY; without even the implied warranty of -# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU -# General Public License for more details. -# -# This code was originally developed by Vyatta, Inc. -# Portions created by Vyatta are Copyright (C) 2008 Vyatta, Inc. -# All Rights Reserved. -# **** End License **** - -package Vyatta::Qos::WeightedRandom; -use strict; -use warnings; - -require Vyatta::Config; -require Vyatta::Qos::ShaperClass; -use Vyatta::Qos::Util qw/getRate getAutoRate getTime RedParam/; - -my $wred = 'weighted-random'; - -# Create a new instance based on config information -sub new { - my ( $that, $config, $name ) = @_; - my $level = $config->setLevel(); - my $rate = $config->returnValue("bandwidth"); - die "$level bandwidth configuration missing" unless $rate; - - my @classes = _getClasses($level); - - _checkClasses( $level, $rate, @classes ); - - my $self = {}; - my $class = ref($that) || $that; - bless $self, $class; - $self->{_rate} = $rate; - $self->{_level} = $level; - $self->{_classes} = \@classes; - - return $self; -} - -sub _getClasses { - my $level = shift; - my @classes; - my $config = new Vyatta::Config; - - $config->setLevel($level); - $config->exists("default") - or die "$level configuration not complete: missing default class\n"; - - $config->setLevel("$level default"); - push @classes, new Vyatta::Qos::ShaperClass($config); - $config->setLevel($level); - - foreach my $id ( $config->listNodes("class") ) { - $config->setLevel("$level class $id"); - push @classes, new Vyatta::Qos::ShaperClass( $config, $id ); - } - - return @classes; -} - -# Check constraints on class bandwidth values -sub _checkClasses { - my $level = shift; - my $rate = shift; - my $default = shift; - - # if auto, can't check at create must wait for policy to be applied - $rate = ( $rate eq "auto" ) ? undef : getRate($rate); - $default->rateCheck( $rate, "$level default" ) if $rate; - - foreach my $class (@_) { - die "$class->{level} bandwidth not defined\n" unless $class->{_rate}; - $class->rateCheck( $rate, "$level class $class->{id}" ) if $rate; - } -} - -sub commands { - my ( $self, $dev ) = @_; - my $rate = getAutoRate( $self->{_rate}, $dev ); - my $classes = $self->{_classes}; - my $default = shift @$classes; - my $maxid = 1; - - $default->rateCheck( $rate, "$self->{_level} default" ); - foreach my $class (@$classes) { - $class->rateCheck( $rate, "$self->{_level} class $class->{id}" ); - - # find largest class id - if ( defined $class->{id} && $class->{id} > $maxid ) { - $maxid = $class->{id}; - } - } - - # fill in id of default - $default->{id} = ++$maxid; - push @$classes, $default; - - print "qdisc add dev $dev handle 1: root gred"; - printf " setup DPs %d default %d\n", $maxid+1, $maxid; - - foreach my $class (@$classes) { - my $classbw = $class->get_rate($rate); - my $avg = $class->{_avgpkt}; - my $latency = getTime( $class->{_latency} ); - - my ( $qmin, $qmax, $burst, $maxp ) - = RedParam( $classbw, $latency, $avg ); - - print "qdisc change dev $dev root gred"; - printf " prio %d", $class->{_priority} if $class->{_priority}; - printf " limit %d min %d max %d avpkt %d probability %f", - 4 * $qmax, $qmin, $qmax, $avg, $maxp; - printf " burst %d bandwidth %d DP %d", - $burst, $rate, $class->{id}; - print " probability 0.1\n"; - - foreach my $match ( $class->matchRules() ) { - $match->filter( $dev, 1, $class->{_priority} ); - printf " flowid :%x\n", $class->{id}; - } - } -} - -# Walk configuration tree and look for changed nodes -# The configuration system should do this but doesn't do it right -sub isChanged { - my ( $self, $name ) = @_; - my $config = new Vyatta::Config; - my @attributes = - qw(bandwidth burst latency packet-length priority queue-limit); - - $config->setLevel("qos-policy $wred $name"); - - return 'bandwidth' if ( $config->isChanged('bandwidth') ); - - foreach my $attr (@attributes) { - return "default $attr" if ( $config->isChanged("default $attr") ); - } - - my %classNodes = $config->listNodeStatus('class'); - while ( my ( $class, $status ) = each %classNodes ) { - return "class $class" if ( $status ne 'static' ); - - foreach my $attr (@attributes) { - return "class $class $attr" - if ( $config->isChanged("class $class $attr") ); - } - - my %matchNodes = $config->listNodeStatus("class $class match"); - while ( my ( $match, $status ) = each %matchNodes ) { - my $level = "class $class match $match"; - return $level if ( $status ne 'static' ); - - foreach my $parm ( - 'vif', - 'ether destination', - 'ether source', - 'ether protocol', - 'interface', - 'ip dscp', - 'ip protocol', - 'ip source address', - 'ip destination address', - 'ip source port', - 'ip destination port' - ) - { - return "$level $parm" if ( $config->isChanged("$level $parm") ); - } - } - } - - return; # false -} - -1; |