Projet

Général

Profil

Paste
Télécharger au format
Statistiques
| Branche: | Révision:

root / plugins / network / qos_ @ dd4afac8

Historique | Voir | Annoter | Télécharger (4,33 ko)

1
#!/usr/bin/perl -w
2
# -*- perl -*-
3
# Wildcard plugin to monitor QoS queues.
4
#
5
# Requirements:
6
# 	- tc program installed and in path
7
#
8
# Parameters supported:
9
#
10
# 	config
11
# 	autoconf
12
# 	suggest
13
#
14
# Configurable variables
15
#
16
# 	tc                - Override default program
17
# 	ignore_queue<n>   - Queue with handle <n>  not be plotted
18
#       label_name<n>     - Queue with handle <n> as defined label
19
#
20
# Magic markers:
21
#%# family=manual
22
#%# capabilities=autoconf suggest
23

    
24
use strict;
25

    
26
my $TC = $ENV{'tc'} || 'tc';
27

    
28
if ($ARGV[0] and $ARGV[0] eq 'suggest') {
29
  my $text = `egrep '^ *(eth|wlan|ath|ra)[0-9]+:' /proc/net/dev | cut -f1 -d:`;
30
  print $text;
31
  exit;
32
}
33

    
34
$0 =~ /qos_(.+)*$/;
35
my $IFACE = $1;
36
exit 2 unless defined $IFACE;
37

    
38
if ( exists $ARGV[0] and $ARGV[0] eq 'autoconf' ) {
39
  # Now see if "tc" can run
40
  my $text = `$TC qdisc show dev $IFACE`;
41
  if ($?) {
42
    if ($? == -1) {
43
      print "no (program $TC not found)\n";
44
    } else {
45
      print "no (program $TC died)\n";
46
    }
47
    exit 1;
48
  }
49
  print "yes\n";
50
  exit 0;
51
}
52

    
53
my %queues;
54
my $qdisc;
55
my $queue;
56
my $handle;
57
my $one;
58
my $sent;
59
my $count;
60
my $haschild;
61

    
62
#open(TEXT, "$TC -s qdisc show dev $IFACE|");
63
#while (! eof(TEXT)) {
64
#  ($qdisc, $queue, $handle) = split(" ", <TEXT>);
65
#  if ($qdisc eq "backlog") {
66
#    ($qdisc, $queue, $handle) = split(" ", <TEXT>);
67
#  }
68
#  ($one, $sent) = split(" ", <TEXT>);
69
#  $handle =~ s/://;
70
#  $queues{$handle} = {
71
#    queue => $queue,
72
#    handle => $handle,
73
#    sent => $sent
74
#  };
75
#}
76

    
77
my @class = `$TC -s class show dev $IFACE`;
78
my( $name, $id1, $id2, $type, $rate, $parent);
79
for( my $x = 0; $x < scalar(@class); $x++ ) {
80
    if($class[$x] =~ m/^class/i ) {
81
	( $name, $id1, $id2, $type, $parent) = ( $class[$x] =~ m/^class\s+(\w+)\s+(\d+):(\d+)\s+(\w+)\s([^\s]+)/i );
82
	if($type eq "parent") {
83
	    $x++;
84
    	    ( $rate ) = ( $class[$x] =~ m/Sent\s+(\d+)\s+/i );
85
	    $handle = "$name"."${id1}_${id2}";
86
	    $queues{$handle} = {
87
		queue => $name,
88
		handle => "${id1}_${id2}",
89
		id => "${id1}:${id2}",
90
		sent => $rate,
91
		parent => $parent
92
	    };
93
	}
94
    }
95
}
96

    
97
if ( exists $ARGV[0] and $ARGV[0] eq 'config' ) {
98
  print "graph_title QoS queue on $IFACE\n";
99
  print "graph_args --base 1000\n";
100
  print "graph_vlabel bits per \${graph_period}\n";
101
  print "graph_category network\n";
102
  print "graph_info This graph shows the QoS queue of the $IFACE network interface.\n";
103
  print "graph_order ";
104
  foreach my $key (sort by_handle keys %queues) {
105
    $haschild = 0;
106
    foreach my $key2 (sort by_handle keys %queues) {
107
	if($queues{$key}->{id} eq $queues{$key2}->{parent}) {
108
	    $haschild = 1;
109
	    last;
110
	}
111
    }
112
    if($haschild == 1) { 
113
	$queues{$key}->{leaf} = 0;
114
	next; 
115
    }
116
    $queues{$key}->{leaf} = 1;
117
    print $queues{$key}->{queue},$queues{$key}->{handle}, " ";
118
  }
119
  print "\n";
120
  $count = 0;
121
  foreach my $key (sort by_handle keys %queues) {
122
    if($queues{$key}->{leaf} == 0) { next; }
123
    print $queues{$key}->{queue},$queues{$key}->{handle}, ".label ";
124
    if (exists $ENV{"label_name$queues{$key}->{handle}"}) {
125
      print $ENV{"label_name$queues{$key}->{handle}"};
126
    } else {
127
      print $queues{$key}->{queue},$queues{$key}->{handle};
128
    }
129
    print "\n";
130
    if (exists $ENV{"max"}) {
131
      print $queues{$key}->{queue},$queues{$key}->{handle}, ".max ",$ENV{"max"},"\n";
132
    } elsif (exists $ENV{"max$queues{$key}->{handle}"}) {
133
      print $queues{$key}->{queue},$queues{$key}->{handle}, ".max ",$ENV{"max$queues{$key}->{handle}"},"\n";
134
    }
135
    print $queues{$key}->{queue},$queues{$key}->{handle}, ".type COUNTER\n";
136
    if($count == 0){
137
	print $queues{$key}->{queue},$queues{$key}->{handle}, ".draw AREA\n";
138
    } else {
139
	print $queues{$key}->{queue},$queues{$key}->{handle}, ".draw STACK\n";
140
    }
141
    print $queues{$key}->{queue},$queues{$key}->{handle}, ".cdef ", $queues{$key}->{queue},$queues{$key}->{handle}, ",8,*\n";
142
    if (exists $ENV{"ignore_queue$queues{$key}->{handle}"}){
143
	print $queues{$key}->{queue},$queues{$key}->{handle}, ".graph no\n" ;
144
    } else {
145
	$count++;
146
    }
147
  }
148
  exit 0;
149
}
150

    
151
sub by_handle {
152
  return $a cmp $b;
153
}
154

    
155
foreach my $key (sort by_handle keys %queues) {
156
    $haschild = 0;
157
    foreach my $key2 (sort by_handle keys %queues) {
158
	if($queues{$key}->{id} eq $queues{$key2}->{parent}) {
159
	    $haschild = 1;
160
	    last;
161
	}
162
    }
163
    if($haschild == 1) { next; }
164
  print $queues{$key}->{queue},$queues{$key}->{handle}, ".value ",$queues{$key}->{sent}, "\n";
165
}
166
#
167
# vim:syntax=perl