# ./sw-name-mac.sh
# usage: NAME_MAC=/dev/shm/file-with-name-space-mac sbw-parse.pl [optional-switch-snmpbulkwalk-dump]
+#
+# cat /dev/shm/neighbors.tab | grep MikroTik | tee /dev/stderr | awk '{ print $7 "_" $8 " " $3 }' > /tmp/name-mac
+# NAME_MAC=/tmp/name-mac ./sbw-parse.pl
use Data::Dump qw(dump);
+$|=1; # flush stdout
+
my $debug = $ENV{DEBUG} || 0;
my @cols = qw( ifName ifHighSpeed ifAdminStatus ifOperStatus ifType dot1dStpPortPathCost ifAlias );
+my @name_mac_files = ( qw( /dev/shm/sw-name-mac /dev/shm/wap-name-mac ), $ENV{NAME_MAC}, glob '/dev/shm/name-mac*' );
my $mac2name;
+my $mac_name_use;
-foreach my $name_mac ( qw( /dev/shm/sw-name-mac /dev/shm/wap-name-mac ), $ENV{NAME_MAC} ) {
+foreach my $name_mac ( @name_mac_files ) {
next unless -e $name_mac;
open(my $f, '<'. $name_mac);
+ my $count = 0;
while(<$f>) {
chomp;
#my ( $ip, $name, $mac ) = split(/ /,$_);
my ( $name, $mac ) = split(/ /,$_);
+ $name =~ s/_/ /g; # replace underscore with space
$mac = lc($mac);
$mac2name->{$mac} = $name;
+ $mac_name_use->{$name} = 0;
+ $count++;
}
+ warn "## $name_mac $count";
}
sub mac2name {
}
}
+my $gv; # collect for graphviz
+
my @files = @ARGV;
@files = glob('snmpbulkwalk/*') unless @files;
if ( m/::(sysName|sysLocation|ipDefaultTTL|dot1dStpPriority|dot1dStpTopChanges|dot1dStpDesignatedRoot|dot1dStpRootCost|dot1dStpRootPort|dot1qNumVlans)\./ ) {
my ( undef, $v ) = split(/ = \w+: /,$_,2);
$sw->{$name}->{$1} = $v;
- } elsif ( m/::(ifMtu|ifHighSpeed)\[(\d\d?)\] = (?:INTEGER|Gauge32): (\d+)/ ) {
+ } elsif ( m/::(ifMtu|ifHighSpeed|ifSpeed)\[(\d\d?)\] = (?:INTEGER|Gauge32): (\d+)/ ) {
$sw->{$name}->{$1}->[$2] = $3;
+ # Dell PowerConnect 5548 doeesn't have ifHighSpeed
+ if ( $1 eq 'ifSpeed' && ! exists $sw->{$name}->{'ifHighSpeed'}->[$2] ) {
+ $sw->{$name}->{'ifHighSpeed'}->[$2] = $3 / 1_000_000;
+ }
} elsif ( m/::(ifPhysAddress)\[(\d\d?)\] = STRING: ([0-9a-f:]+)/ ) {
$sw->{$name}->{$1}->[$2] = fix_mac($3);
- } elsif ( m/::(ifName|ifAlias)\[(\d\d?)\] = STRING: (.+)/ ) {
+ } elsif ( m/::(ifDescr|ifName|ifAlias)\[(\d\d?)\] = STRING: (.+)/ ) {
$sw->{$name}->{$1}->[$2] = $3;
+ if ( $1 eq 'ifName' ) {
+ my ( $if_name, $port ) = ($3,$2);
+ $sw->{$name}->{port_name_to_number}->{$if_name} = $port;
+ }
+ if ( $1 eq 'ifDescr' ) { # some switches miss ifName
+ my ( $if_name, $port ) = ($3,$2);
+ $if_name =~ s/gigabitethernet/ge/;
+ $if_name =~ s/tengigabitethernet/te/;
+ $sw->{$name}->{'ifName'}->[$port] = $if_name
+ if ( ! exists $sw->{name}->{'ifName'} );
+ $sw->{$name}->{port_name_to_number}->{$if_name} = $port
+ if ( ! exists $sw->{$name}->{port_name_to_number}->{$if_name} );
+ }
} elsif ( m/::(ifAdminStatus|ifOperStatus|ifType|dot3StatsDuplexStatus)\[(\d\d?)\] = INTEGER: (\w+)\(/ ) {
$sw->{$name}->{$1}->[$2] = $3;
} elsif ( m/::(dot1dStpPortPathCost)\[(\d\d?)\] = INTEGER: (\d+)/ ) {
}
warn "# sw $name = ",dump($sw->{$name}) if $debug;
- foreach my $port ( 1 .. $#{ $sw->{$name}->{ifName} } ) {
+ foreach my $port ( 1 .. $#{ $sw->{$name}->{ifDescr} } ) {
print "$name $port";
foreach my $oid ( @cols ) {
if ( $oid eq 'ifAlias' ) {
}
if ( exists( $sw->{$name}->{port_for_switch}->{ $port } ) ) {
- print " ",join(',', sort keys %{ $sw->{$name}->{port_for_switch}->{ $port } } );
+ my @visible = sort keys %{ $sw->{$name}->{port_for_switch}->{ $port } };
+ print " ",join(',', @visible);
+
+ if ( scalar @visible == 1 ) {
+ $gv->{$name}->{$port}->{ $visible[0] }->{ 'no_port' } = [$port,0]; # no port
+ }
}
print "\n";
}}
# fix ifPhysAddress
+# read neighbour visibility from lldp
+
+sub port2number {
+ my ($name,$port) = @_;
+
+ return $port if $port =~ m/^\d+$/;
+ $port =~ s{bridge\d*/}{}; # remove mikrotik port prefix
+ $port =~ s{,bridge\d*$}{}; # remove mikrotik port suffix
+ $port =~ s{,bonding\d*$}{}; # remove mikrotik port suffix
+
+ if ( exists $sw->{$name}->{port_name_to_number}->{$port} ) {
+ return $sw->{$name}->{port_name_to_number}->{$port};
+ }
+
+ # gigabitethernet1/0/45 or gi1/0/45
+ if ( $port =~ m{(.+)1/0/(\d+)$} ) {
+ my ($type,$port) = ($1,$2);
+ if ( $type =~ m{gi}i ) {
+ return $port;
+ } elsif ( $type =~ m{te}i ) {
+ return $port <= 4 ? $port + 10000 : $port;
+ } else {
+ die "unknown [$type]";
+ }
+ }
+
+ # linux
+ if ( $port =~ m{eth(\d+)} ) {
+ return $1;
+ }
+
+ my @fuzzy = grep { m/^$port/ } keys %{ $sw->{$name}->{port_name_to_number} };
+ if ( scalar @fuzzy == 1 ) {
+ return $sw->{$name}->{port_name_to_number}->{$fuzzy[0]}
+ }
+
+ warn "ERROR [$_] can't find port $port for $name in ",dump( $sw->{$name}->{port_name_to_number} );
+}
+
+sub fix_sw_name {
+ my $name = shift;
+ if ( $name eq 'rack3-lib' ) {
+ $name = 'sw-lib-srv';
+ }
+ return $name;
+}
+
+
+open(my $n_fh, '<', '/dev/shm/neighbors.tab');
+while(<$n_fh>) {
+ chomp;
+ my ( $sw1, $port1, undef, $port2, $sw2, undef ) = split(/\t/, $_, 6 );
+ next if $port2 =~ m/:/; # skip mac in port number (wap lldp leek)
+ next unless $sw2 && $port2;
+ $sw1 = fix_sw_name($sw1);
+ my $port1_nr = port2number( $sw1, $port1 );
+ my $port2_nr = port2number( $sw2, $port2 );
+
+ if ( $sw->{$sw1}->{ifType}->[$port1_nr] ne 'ethernetCsmacd' ) {
+ warn "SKIP $sw1 $port1_nr $sw->{$sw1}->{ifType}->[$port1_nr]\n";
+ next;
+ } elsif ( $port1 =~ m{bridge} ) { # skip mikrotik bridges
+# warn "SKIP $sw1 $port1_nr $port1\n";
+# next;
+ }
+
+ $gv->{$sw1}->{$port1_nr}->{$sw2}->{$port2_nr} = [ $port1, $port2 ];
+ delete $gv->{$sw1}->{$port1_nr}->{$sw2}->{'no_port'} if exists $gv->{$sw1}->{$port1_nr}->{$sw2}->{'no_port'};
+}
+
+# FIXME sw-b101 doesn't have lldp so we insert data here manually from pictures
+sub fake_gv {
+ my ($sw1, $p1, $sw2, $p2) = @_;
+ $gv->{$sw1}->{$p1}->{$sw2}->{$p2} = [ $p1, $p2 ];
+ $gv->{$sw2}->{$p2}->{$sw1}->{$p1} = [ $p2, $p1 ];
+}
+delete $gv->{'sw-b101'};
+fake_gv( 'sw-b101' => 3, 'sw-b101' => 4 ); # vlan1-to-vlan2 / vlan2-to-vlan1
+
+fake_gv( 'sw-b101' => 21, 'sw-rack2' => 50 );
+fake_gv( 'sw-b101' => 23, 'sw-lib-srv' => 48 );
+fake_gv( 'sw-b101' => 24, 'sw-rack1' => 48 );
+
+#delete $gv->{'sw-ganeti'};
+# spf-16 -> "sw-rack2" => { 2 => ["16-sfp-uplink-b101,bridge", "te1/0/2"] },
+
+print "# gv = ",dump( $gv );
+
+open(my $dot_fh, '>', '/dev/shm/network.dot');
+print $dot_fh qq|
+digraph topology {
+graph [ rankdir = LR ]
+node [ shape = record; fontname="Helvetica" ]
+edge [ color = "gray" ]
+|;
+
+my @edges;
+my $node;
+
+foreach my $sw1 ( sort keys %$gv ) {
+ foreach my $p1 ( sort { $a <=> $b } keys %{ $gv->{$sw1} } ) {
+ foreach my $sw2 ( sort keys %{ $gv->{$sw1}->{$p1} } ) {
+ if ( $sw1 eq $sw2 ) {
+ warn "SKIP same switch $sw1 == $sw2\n";
+ next;
+ }
+ #push @{ $node->{$sw1} }, [ $p1, $sw2 ];
+ foreach my $p2 ( keys %{ $gv->{$sw1}->{$p1}->{$sw2} } ) {
+ push @edges, [ $sw1, $sw2, $p1, $p2 ];
+ ##push @{ $node->{$sw2} }, [ $p2, $sw1 ];
+ push @{ $node->{$sw1} }, [ $p1, $sw2, $p2 ];
+ }
+ }
+ }
+}
+
+foreach my $n ( sort keys %$node ) {
+ no warnings;
+ my @port_sw =
+ sort { join(' ',@$a) <=> join(' ',@$b) }
+ @{ $node->{$n} };
+ print $dot_fh qq!"$n" [ label="!.uc($n).'|' . join('|', map {
+ $mac_name_use->{$_->[1]}++;
+ sprintf "<%d>%2d %s%s", $_->[0], $_->[0], $_->[1], $_->[2] eq 'no_port' ? '' : ' ' . $_->[2]
+ } @port_sw ) . qq!" ];\n!;
+}
+
+foreach my $e ( sort { join(' ',@$a) cmp join(' ', @$b) } @edges ) {
+ no warnings;
+ if ( $e->[3] == 0 ) {
+ #print $dot_fh sprintf qq{ "%s":%d -> "%s"\n}, $e->[0], $e->[2], $e->[1];
+ } else {
+ print $dot_fh sprintf qq{ "%s":%d -> "%s":%d\n}, $e->[0], $e->[2], $e->[1], $e->[3];
+ }
+}
+
+sub git_commit {
+ return if $debug;
+ my $file = shift;
+ $file =~ s{/dev/shm/}{} && warn "## git_commit $file";
+ system qq{git -C /dev/shm add -f $file && git -C /dev/shm commit -m "\$( date +%Y-%m-%d ) $file" $file };
+}
+
+warn "## mac_name_use ",dump( $mac_name_use );
+
+my @mac_name_use_zero = sort grep { $mac_name_use->{$_} == 0 } keys %$mac_name_use;
+warn "# mac_name_use_zero=",dump( \@mac_name_use_zero );
+open(my $zero_fh, '>', '/dev/shm/mac_name_use.0');
+print $zero_fh "$_\n" foreach map {
+ s/^\w+\s//; $_; # remote msw_ prefix and leave only mac
+} @mac_name_use_zero;
+close($zero_fh);
+git_commit 'mac_name_use.0';
+
+print $dot_fh qq|
+}
+|;
+close($dot_fh);
+git_commit 'network.dot';
+
+system "dot -Tsvg /dev/shm/network.dot > /var/www/network.svg";
+#system 'git -C /dev/shm commit -m $( date +%Y-%m-%d ) network.dot' if ! $debug;
+
+warn "# strange neihbours:";
+system "grep -f /dev/shm/mac_name_use.0 /dev/shm/neighbors.tab";
projects / dell-switch / blobdiff