git.rot13.org Git - dell-switch/blob - sbw-parse.pl

   1 #!/usr/bin/perl
   2 use warnings;
   3 use strict;
   4 use autodie;
   5
   6 # ./sw-name-mac.sh
   7
   8 # usage: NAME_MAC=/dev/shm/file-with-name-space-mac sbw-parse.pl [optional-switch-snmpbulkwalk-dump]
   9 #
  10 # cat /dev/shm/neighbors.tab | grep MikroTik | tee /dev/stderr | awk '{ print $7 "_" $8 " " $3 }' > /tmp/name-mac
  11 # NAME_MAC=/tmp/name-mac ./sbw-parse.pl
  12
  13 use Data::Dump qw(dump);
  14
  15 $|=1; # flush stdout
  16
  17 my $debug = $ENV{DEBUG} || 0;
  18
  19 my @cols = qw( ifName ifHighSpeed ifAdminStatus ifOperStatus ifType dot1dStpPortPathCost ifAlias );
  20
  21 my @name_mac_files = ( qw( /dev/shm/sw-name-mac /dev/shm/wap-name-mac ), $ENV{NAME_MAC}, glob '/dev/shm/name-mac*' );
  22 my $mac2name;
  23 my $mac_name_use;
  24
  25 foreach my $name_mac ( @name_mac_files ) {
  26         next unless -e $name_mac;
  27         open(my $f, '<'. $name_mac);
  28         my $count = 0;
  29         while(<$f>) {
  30                 chomp;
  31                 #my ( $ip, $name, $mac ) = split(/ /,$_);
  32                 my ( $name, $mac ) = split(/ /,$_);
  33                 $mac = lc($mac);
  34                 $mac2name->{$mac} = $name;
  35                 $mac_name_use->{$name} = 0;
  36                 $count++;
  37         }
  38         warn "## $name_mac $count";
  39 }
  40
  41 sub mac2name {
  42         my ( $mac, $name ) = @_;
  43
  44         $mac = lc($mac);
  45
  46         if ( exists $mac2name->{$mac} ) {
  47                 my $mac_name = $mac2name->{$mac};
  48                 warn "ERROR: name different $name != $mac_name" if $name && $name ne $mac_name;
  49                 return ( $mac, $mac_name );
  50         }
  51         return ( $mac, $name );
  52 }
  53
  54 warn "# mac2name = ",dump($mac2name) if $debug;
  55
  56
  57 my $sw;
  58
  59 sub fix_mac {
  60         my $mac = shift;
  61         $mac = lc($mac);
  62         $mac =~ s/^([0-9a-f]):/0$1:/;
  63         while ( $mac =~ s/:([0-9a-f]):/:0$1:/g ) {};
  64         $mac =~ s/:([0-9a-f])$/:0$1/;
  65 #       warn "# $mac\n";
  66         return $mac;
  67 }
  68
  69 sub sw_name_mac_port {
  70         my ( $name, $mac, $port ) = @_;
  71         $mac = fix_mac($mac);
  72         if ( exists $mac2name->{$mac} ) {
  73                 my $sw_name = $mac2name->{$mac};
  74                 $sw->{$name}->{port_for_switch}->{$port}->{ $sw_name }++;
  75                 #print "## $name $port $sw_name\n";
  76         }
  77 }
  78
  79 my $gv; # collect for graphviz
  80
  81 my @files = @ARGV;
  82 @files = glob('snmpbulkwalk/*') unless @files;
  83
  84 foreach my $file ( @files ) {
  85         my ( undef, $name ) = split(/\//, $file);
  86         print "# $name $file\n" if $debug;
  87
  88         if ( -s "/dev/shm/$file" ) {
  89                 if ( -M $file < -M "/dev/shm/$file" ) {
  90                         warn "UPDATE $file\n";
  91                         system "cp -pv /dev/shm/$file $file";
  92                 }
  93                 $file="/dev/shm/$file";
  94         } else {
  95                 warn "WARNING: using old file $file\n";
  96         }
  97
  98         open(my $f, '<', $file);
  99         while(<$f>) {
 100                 chomp;
 101                 if ( m/::(sysName|sysLocation|ipDefaultTTL|dot1dStpPriority|dot1dStpTopChanges|dot1dStpDesignatedRoot|dot1dStpRootCost|dot1dStpRootPort|dot1qNumVlans)\./ ) {
 102                         my ( undef, $v ) = split(/ = \w+: /,$_,2);
 103                         $sw->{$name}->{$1} = $v;
 104                 } elsif ( m/::(ifMtu|ifHighSpeed|ifSpeed)\[(\d\d?)\] = (?:INTEGER|Gauge32): (\d+)/ ) {
 105                         $sw->{$name}->{$1}->[$2] = $3;
 106                         # Dell PowerConnect 5548 doeesn't have ifHighSpeed
 107                         if ( $1 eq 'ifSpeed' && ! exists $sw->{$name}->{'ifHighSpeed'}->[$2] ) {
 108                                 $sw->{$name}->{'ifHighSpeed'}->[$2] = $3 / 1_000_000;
 109                         }
 110                 } elsif ( m/::(ifPhysAddress)\[(\d\d?)\] = STRING: ([0-9a-f:]+)/ ) {
 111                         $sw->{$name}->{$1}->[$2] = fix_mac($3);
 112                 } elsif ( m/::(ifDescr|ifName|ifAlias)\[(\d\d?)\] = STRING: (.+)/ ) {
 113                         $sw->{$name}->{$1}->[$2] = $3;
 114                         if ( $1 eq 'ifName' ) {
 115                                 my ( $if_name, $port ) = ($3,$2);
 116                                 $sw->{$name}->{port_name_to_number}->{$if_name} = $port;
 117                         }
 118                         if ( $1 eq 'ifDescr' ) { # some switches miss ifName
 119                                 my ( $if_name, $port ) = ($3,$2);
 120                                 $if_name =~ s/gigabitethernet/ge/;
 121                                 $if_name =~ s/tengigabitethernet/te/;
 122                                 $sw->{$name}->{'ifName'}->[$port] = $if_name
 123                                         if ( ! exists $sw->{name}->{'ifName'} );
 124                                 $sw->{$name}->{port_name_to_number}->{$if_name} = $port
 125                                         if ( ! exists $sw->{$name}->{port_name_to_number}->{$if_name} );
 126                         }
 127                 } elsif ( m/::(ifAdminStatus|ifOperStatus|ifType|dot3StatsDuplexStatus)\[(\d\d?)\] = INTEGER: (\w+)\(/ ) {
 128                         $sw->{$name}->{$1}->[$2] = $3;
 129                 } elsif ( m/::(dot1dStpPortPathCost)\[(\d\d?)\] = INTEGER: (\d+)/ ) {
 130                         $sw->{$name}->{$1}->[$2] = $3;
 131                 } elsif ( m/::(dot1dTpFdbPort)\[STRING: ([0-9a-f:]+)\] = INTEGER: (\d+)/ ) {
 132                         $sw->{$name}->{$1}->{ fix_mac($2) } = $3;
 133                         sw_name_mac_port( $name, $2, $3 );
 134                 } elsif ( m/::(dot1qTpFdbPort)\[(\d+)\]\[STRING: ([0-9a-f:]+)\] = INTEGER: (\d+)/ ) {
 135                         $sw->{$name}->{$1}->{ fix_mac($3) } = [ $4, $2 ]; # port, vlan
 136                         sw_name_mac_port( $name, $3, $4 );
 137                 }
 138
 139                 # dot1qVlanCurrentEgressPorts
 140                 # dot1qVlanCurrentUntaggedPorts
 141                 # dot1qVlanStaticName
 142                 # dot1qVlanStaticEgressPorts
 143                 # dot1qVlanStaticUntaggedPorts
 144                 # dot1qPvid
 145
 146                 # entPhysicalDescr
 147                 # entPhysicalClass
 148
 149                 #print "## $_<--\n";
 150         }
 151         warn "# sw $name = ",dump($sw->{$name}) if $debug;
 152
 153         foreach my $port ( 1 .. $#{ $sw->{$name}->{ifDescr} } ) {
 154                 print "$name $port";
 155                 foreach my $oid ( @cols ) {
 156                         if ( $oid eq 'ifAlias' ) {
 157                                 if ( defined( $sw->{$name}->{$oid}->[$port] ) ) {
 158                                         print " [",$sw->{$name}->{$oid}->[$port],"]";
 159                                 }
 160                         } elsif ( defined $sw->{$name}->{$oid}->[$port] ) {
 161                                 print " ", $sw->{$name}->{$oid}->[$port];
 162                         } else {
 163                                 print " ?";
 164                                 #warn "MISSING $name $oid $port\n";
 165                         }
 166
 167                 }
 168                 if ( exists( $sw->{$name}->{port_for_switch}->{ $port } ) ) {
 169                         my @visible = sort keys %{ $sw->{$name}->{port_for_switch}->{ $port } };
 170                         print " ",join(',', @visible);
 171
 172                         if ( scalar @visible == 1 ) {
 173                                 $gv->{$name}->{$port}->{ $visible[0] }->{ 'no_port' } = [$port,0]; # no port
 174                         }
 175                 }
 176                 print "\n";
 177         }}
 178
 179 # fix ifPhysAddress
 180
 181 # read neighbour visibility from lldp
 182
 183 sub port2number {
 184         my ($name,$port) = @_;
 185
 186         return $port if $port =~ m/^\d+$/;
 187         $port =~ s{bridge\d*/}{};  # remove mikrotik port prefix
 188         $port =~ s{,bridge\d*$}{}; # remove mikrotik port suffix
 189         $port =~ s{,bonding\d*$}{}; # remove mikrotik port suffix
 190
 191         if ( exists $sw->{$name}->{port_name_to_number}->{$port} ) {
 192                 return $sw->{$name}->{port_name_to_number}->{$port};
 193         }
 194
 195         # gigabitethernet1/0/45 or gi1/0/45
 196         if ( $port =~ m{(.+)1/0/(\d+)$} ) {
 197                 my ($type,$port) = ($1,$2);
 198                 if ( $type =~ m{gi}i ) {
 199                         return $port;
 200                 } elsif ( $type =~ m{te}i ) {
 201                         return $port <= 4 ? $port + 10000 : $port;
 202                 } else {
 203                         die "unknown [$type]";
 204                 }
 205         }
 206
 207         # linux
 208         if ( $port =~ m{eth(\d+)} ) {
 209                 return $1;
 210         }
 211
 212         my @fuzzy = grep { m/^$port/ } keys %{ $sw->{$name}->{port_name_to_number} };
 213         if ( scalar @fuzzy == 1 ) {
 214                 return $sw->{$name}->{port_name_to_number}->{$fuzzy[0]}
 215         }
 216
 217         warn "ERROR [$_] can't find port $port for $name in ",dump( $sw->{$name}->{port_name_to_number} );
 218 }
 219
 220 sub fix_sw_name {
 221         my $name = shift;
 222         if ( $name eq 'rack3-lib' ) {
 223                 $name = 'sw-lib-srv';
 224         }
 225         return $name;
 226 }
 227
 228
 229 open(my $n_fh, '<', '/dev/shm/neighbors.tab');
 230 while(<$n_fh>) {
 231         chomp;
 232         my ( $sw1, $port1, undef, $port2, $sw2, undef ) = split(/\t/, $_, 6 );
 233         next if $port2 =~ m/:/; # skip mac in port number (wap lldp leek)
 234         next unless $sw2 && $port2;
 235         $sw1 = fix_sw_name($sw1);
 236         my $port1_nr = port2number( $sw1, $port1 );
 237         my $port2_nr = port2number( $sw2, $port2 );
 238
 239         if ( $sw->{$sw1}->{ifType}->[$port1_nr] ne 'ethernetCsmacd' ) {
 240                 warn "SKIP $sw1 $port1_nr $sw->{$sw1}->{ifType}->[$port1_nr]\n";
 241                 next;
 242         } elsif ( $port1 =~ m{bridge} ) { # skip mikrotik bridges
 243 #               warn "SKIP $sw1 $port1_nr $port1\n";
 244 #               next;
 245         }
 246
 247         $gv->{$sw1}->{$port1_nr}->{$sw2}->{$port2_nr} = [ $port1, $port2 ];
 248         delete $gv->{$sw1}->{$port1_nr}->{$sw2}->{'no_port'} if exists $gv->{$sw1}->{$port1_nr}->{$sw2}->{'no_port'};
 249 }
 250
 251 # FIXME sw-b101 doesn't have lldp so we insert data here manually from pictures
 252 sub fake_gv {
 253         my ($sw1, $p1, $sw2, $p2) = @_;
 254         $gv->{$sw1}->{$p1}->{$sw2}->{$p2} = [ $p1, $p2 ];
 255         $gv->{$sw2}->{$p2}->{$sw1}->{$p1} = [ $p2, $p1 ];
 256 }
 257 delete $gv->{'sw-b101'};
 258 fake_gv( 'sw-b101' => 3, 'sw-b101' => 4 ); # vlan1-to-vlan2 / vlan2-to-vlan1
 259
 260 fake_gv( 'sw-b101' => 21, 'sw-rack2' => 50 );
 261 fake_gv( 'sw-b101' => 23, 'sw-lib-srv' => 48 );
 262 fake_gv( 'sw-b101' => 24, 'sw-rack1' => 48 );
 263
 264 #delete $gv->{'sw-ganeti'};
 265 # spf-16 -> "sw-rack2"        => { 2 => ["16-sfp-uplink-b101,bridge", "te1/0/2"] },
 266
 267 print "# gv = ",dump( $gv );
 268
 269 open(my $dot_fh, '>', '/dev/shm/network.dot');
 270 print $dot_fh qq|
 271 digraph topology {
 272 graph [ rankdir = LR ]
 273 node [ shape = record ]
 274 edge [ color = "gray" ]
 275 |;
 276
 277 my @edges;
 278 my $node;
 279
 280 foreach my $sw1 ( sort keys %$gv ) {
 281         foreach my $p1 ( sort { $a <=> $b } keys %{ $gv->{$sw1} } ) {
 282                 foreach my $sw2 ( sort keys %{ $gv->{$sw1}->{$p1} } ) {
 283                         if ( $sw1 eq $sw2 ) {
 284                                 warn "SKIP same switch $sw1 == $sw2\n";
 285                                 next;
 286                         }
 287                         #push @{ $node->{$sw1} }, [ $p1, $sw2 ];
 288                         foreach my $p2 ( keys %{ $gv->{$sw1}->{$p1}->{$sw2} } ) {
 289                                 push @edges, [ $sw1, $sw2, $p1, $p2 ];
 290                                 ##push @{ $node->{$sw2} }, [ $p2, $sw1 ];
 291                                 push @{ $node->{$sw1} }, [ $p1, $sw2, $p2 ];
 292                         }
 293                 }
 294         }
 295 }
 296
 297 foreach my $n ( sort keys %$node ) {
 298         no warnings;
 299         my @port_sw =
 300                 sort { join(' ',@$a) <=> join(' ',@$b) }
 301                 @{ $node->{$n} };
 302         print $dot_fh qq!"$n" [ label="!.uc($n).'|' . join('|', map {
 303                 $mac_name_use->{$_->[1]}++;
 304                 sprintf "<%d>%2d %s%s", $_->[0], $_->[0], $_->[1], $_->[2] eq 'no_port' ? '' : ' ' . $_->[2]
 305         } @port_sw ) . qq!" ];\n!;
 306 }
 307
 308 foreach my $e ( sort { join(' ',@$a) cmp join(' ', @$b) } @edges ) {
 309         no warnings;
 310         if ( $e->[3] == 0 ) {
 311                 print $dot_fh sprintf qq{ "%s":%d -> "%s"\n}, $e->[0], $e->[2], $e->[1];
 312         } else {
 313                 print $dot_fh sprintf qq{ "%s":%d -> "%s":%d\n}, $e->[0], $e->[2], $e->[1], $e->[3];
 314         }
 315 }
 316
 317 sub git_commit {
 318         return if $debug;
 319         my $file = shift;
 320         $file =~ s{/dev/shm/}{} && warn "## git_commit $file";
 321         system qq{git -C /dev/shm add -f $file && git -C /dev/shm commit -m "\$( date +%Y-%m-%d ) $file" $file };
 322 }
 323
 324 warn "## mac_name_use ",dump( $mac_name_use );
 325
 326 my @mac_name_use_zero = sort grep { $mac_name_use->{$_} == 0 } keys %$mac_name_use;
 327 warn "# mac_name_use_zero=",dump( \@mac_name_use_zero );
 328 open(my $zero_fh, '>', '/dev/shm/mac_name_use.0');
 329 print $zero_fh "$_\n" foreach map {
 330         s/^msw_//; $_; # remote msw_ prefix and leave only mac
 331 } @mac_name_use_zero;
 332 close($zero_fh);
 333 git_commit 'mac_name_use.0';
 334
 335 print $dot_fh qq|
 336 }
 337 |;
 338 close($dot_fh);
 339 git_commit 'network.dot';
 340
 341 system "dot -Tsvg /dev/shm/network.dot > /var/www/network.svg";
 342 #system 'git -C /dev/shm commit -m $( date +%Y-%m-%d ) network.dot' if ! $debug;
 343
 344 warn "# strange neihbours:";
 345 system "grep -f /dev/shm/mac_name_use.0 /dev/shm/neighbors.tab";