mirror/librenms-librenms-agent
1
0
Fork 0
mirror of https://github.com/librenms/librenms-agent.git synced 2024-05-09 09:54:52 +00:00
Code Releases Activity

Merge pull request #225 from VVelox/pa-fix

Browse Source 
portactivity fixes
This commit is contained in:
VVelox
2019-03-19 02:53:30 -05:00
committed by GitHub
parent cb04f8c0ac 38acc2bd3d
commit 8fbfbd5b39
1 changed files with 20 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
snmp/portactivity
View File

@ -1,6 +1,6 @@
#!/usr/bin/env perl #!/usr/bin/env perl
#Copyright (c) 2018, Zane C. Bowers-Hadley #Copyright (c) 2019, Zane C. Bowers-Hadley
#All rights reserved. #All rights reserved.
# #
#Redistribution and use in source and binary forms, with or without modification, #Redistribution and use in source and binary forms, with or without modification,
@ -91,7 +91,7 @@ use Parse::Netstat qw(parse_netstat);
$Getopt::Std::STANDARD_HELP_VERSION = 1; $Getopt::Std::STANDARD_HELP_VERSION = 1;
sub main::VERSION_MESSAGE { sub main::VERSION_MESSAGE {
print "Port Activity SNMP stats extend 0.0.0\n"; print "Port Activity SNMP stats extend 0.0.1\n";
} }
sub main::HELP_MESSAGE { sub main::HELP_MESSAGE {
@ -175,7 +175,7 @@ sub return_json{
} }
print $j->encode( \%to_return ); print $j->encode( \%to_return );
if ( ! $pretty ){ if ( ! $pretty ){
print "\n"; print "\n";
} }
@ -218,6 +218,7 @@ my @protos_array=split(/\,/, $opts{p});
#holds the various protocol hashes #holds the various protocol hashes
my %protos; my %protos;
my %proto_lookup;
#make sure each one specificied is defined and build the hash that will be returned #make sure each one specificied is defined and build the hash that will be returned
my $protos_array_int=0; my $protos_array_int=0;
@ -234,27 +235,17 @@ while ( defined( $protos_array[$protos_array_int] ) ){
return_json(\%to_return, $opts{P}); return_json(\%to_return, $opts{P});
exit 4; exit 4;
} }
$proto_lookup{ $port } = $protos_array [$protos_array_int ];
$protos_array_int++; $protos_array_int++;
} }
my $netstat='netstat -n';
my $os=$^O; my $os=$^O;
my $netstat; my $res = parse_netstat(output => join("", `$netstat`), flavor=>$os, udp=>0, unix=>0);
#make sure this is a supported OS
if ( $os eq 'freebsd' ){
$netstat='netstat -S -p tcp'
}elsif( $os eq 'linux' ){
$netstat='netstat -n'
}else{
$to_return{errorString}=$os.' is not a supported OS as of currently';
$to_return{error}=3;
return_json(\%to_return, $opts{P});
exit 3;
}
my $res = parse_netstat(output => join("", `$netstat`), flavor=>$os);
#check to make sure that it was able to parse the output #check to make sure that it was able to parse the output
if ( if (
@ -273,7 +264,9 @@ while ( defined( $res->[2]{'active_conns'}[$active_conns_int] ) ){
my $conn=$res->[2]{active_conns}[$active_conns_int]; my $conn=$res->[2]{active_conns}[$active_conns_int];
#we only care about TCP currently #we only care about TCP currently
if ( $conn->{proto} =~ /^[Tt][Cc][Pp]/ ){ if ( defined( $conn->{proto} ) &&
( $conn->{proto} =~ /^[Tt][Cc][Pp]/ )
){
$protos_array_int=0; $protos_array_int=0;
my $service; my $service;
while( while(
@ -282,8 +275,8 @@ while ( defined( $res->[2]{'active_conns'}[$active_conns_int] ) ){
){ ){
#check if this matches either ports #check if this matches either ports
if ( if (
( $protos_array[ $protos_array_int ] eq $conn->{'local_port'} ) || ( defined($proto_lookup{ $conn->{'local_port'} }) ) ||
( $protos_array[ $protos_array_int ] eq $conn->{'foreign_port'} ) ( defined($proto_lookup{ $conn->{'foreign_port'} }) )
){ ){
$service=$protos_array[ $protos_array_int ]; $service=$protos_array[ $protos_array_int ];
} }
@ -294,7 +287,7 @@ while ( defined( $res->[2]{'active_conns'}[$active_conns_int] ) ){
#only handle it if is a service we are watching for #only handle it if is a service we are watching for
if ( defined( $service ) ){ if ( defined( $service ) ){
my $processed=0; my $processed=0;
my $state=$conn->{'state'}; my $state=$conn->{'state'};
#translate the state names #translate the state names
if ( $os eq 'linux' ){ if ( $os eq 'linux' ){
@ -311,7 +304,7 @@ while ( defined( $res->[2]{'active_conns'}[$active_conns_int] ) ){
if ( $state ne 'LISTEN' ){ if ( $state ne 'LISTEN' ){
$protos{$service}{'total_conns'}++; $protos{$service}{'total_conns'}++;
} }
#make sure the state is a valid one #make sure the state is a valid one
# if it is not a valid one, set it to other, meaning something unexpected was set for the state that should not be # if it is not a valid one, set it to other, meaning something unexpected was set for the state that should not be
if ( ! defined( $valid_states{$state} ) ){ if ( ! defined( $valid_states{$state} ) ){
@ -338,11 +331,11 @@ while ( defined( $res->[2]{'active_conns'}[$active_conns_int] ) ){
$protos{$service}{'total_to'}++; $protos{$service}{'total_to'}++;
$protos{$service}{'to'}{$state}++; $protos{$service}{'to'}{$state}++;
} }
} }
} }
$active_conns_int++; $active_conns_int++;
} }