## @file # Status process mechanism package Lemonldap::NG::Handler::Lib::Status; use strict; use POSIX qw(setuid setgid); use JSON qw(to_json); use IO::Select; use IO::Socket::INET; use Lemonldap::NG::Handler::Lib::StatusConstants qw(portalConsts); our $VERSION = '2.0.9'; our $status = {}; our $activity = []; our $start = int( time / 60 ); use constant MN_COUNT => 5; our $page_title = 'Lemonldap::NG statistics'; eval { setgid( ( getgrnam( $ENV{APACHE_RUN_GROUP} ) )[2] ); setuid( ( getpwnam( $ENV{APACHE_RUN_USER} ) )[2] ); }; ## @rfn void run() # Main. # Reads requests from STDIN to : # - update counts # - display results sub run { my ( $lastMn, $mn, $count, $cache, @ready ); my $sel = IO::Select->new; $sel->add( \*STDIN ); while ( my $opt = shift @ARGV ) { if ( $opt eq '--udp' ) { my $hp = shift @ARGV; my $s = IO::Socket::INET->new( Proto => 'udp', LocalAddr => $hp ); $sel->add($s); } else { die "Unknown option $opt"; } } while ( @ready = $sel->can_read ) { foreach my $fh (@ready) { if ( $fh == \*STDIN and $fh->eof ) { exit; } $_ = $fh->getline or next; $mn = int( time / 60 ) - $start + 1; # Cleaning activity array if ( $mn > $lastMn ) { for ( my $i = 0 ; $i < $mn - $lastMn ; $i++ ) { unshift @$activity, {}; delete $activity->[ MN_COUNT + 1 ]; } } $lastMn = $mn; # Activity collect if ( /^(\S+)\s+=>\s+(\S+)\s+(OK|REJECT|REDIRECT|LOGOUT|UNPROTECT|\-?\d+)$/ ) { my ( $user, $uri, $code ) = ( $1, $2, $3 ); # Portal error translation $code = portalConsts->{$code} || $code if ( $code =~ /^\-?\d+$/ ); # Per user activity $status->{user}->{$user}->{$code}++; # Per uri activity $uri =~ s/^(.*?)\?.*$/$1/; $status->{uri}->{$uri}->{$code}++; $count->{uri}->{$uri}++; # Per vhost activity my ($vhost) = ( $uri =~ /^([^\/]+)/ ); $status->{vhost}->{$vhost}->{$code}++; $count->{vhost}->{$vhost}++; # Last 5 minutes activity $activity->[0]->{$code}++; } elsif (/^RELOADCACHE(?:\s+(\S+?),(.+))?$/) { if ( my ( $cacheModule, $cacheOptions ) = ( $1, $2 ) ) { eval "use $cacheModule;" . "\$cache = new $cacheModule($cacheOptions);"; print STDERR "$@\n" if ($@); # TODO: use logger instead } else { $cache = undef; } } # Status requests # $args contains parameters passed to url status page (a=1 for example # if request is http://test.example.com/status?a=1). To be used # later... elsif (/^STATUS\s*(.+)?$/) { my $tmp = $1; my $out; if ( $fh == \*STDIN ) { $out = \*STDOUT; } elsif ( $tmp =~ s/\s*host=(\S+)$// ) { $out = IO::Socket::INET->new( Proto => "udp", PeerAddr => $1 ); unless ($out) { print STDERR "Unable to open UDP connection\n"; next; } } else { print STDERR "No host given, skipping\n"; next; } $out->autoflush(1); my $args = {}; %$args = split( /[=&]/, $tmp ) if ($tmp); &head($out) unless ( $args->{json} ); my ( $c, $m, $u ); foreach my $user ( keys %{ $status->{user} } ) { my $v = $status->{user}->{$user}; $u++ unless ( $user =~ /^\d+\.\d+\.\d+\.\d+$/ ); # Total requests foreach ( keys %$v ) { $c->{$_} += $v->{$_}; } } for ( my $i = 1 ; $i < @$activity ; $i++ ) { $m->{$_} += $activity->[$i]->{$_} foreach ( keys %{ $activity->[$i] } ); } foreach ( keys %$m ) { $m->{$_} = sprintf( "%.2f", $m->{$_} / MN_COUNT ); $m->{$_} = int( $m->{$_} ) if ( $m->{$_} > 99 ); } # JSON values if ( $args->{json} ) { $out->print( to_json( { average => $m, total => $c } ) . "\nEND\n" ); } # Raw values (Dump) elsif ( $args->{'dump'} ) { require Data::Dumper; $out->print("
\n"); $out->print( Data::Dumper::Dumper( $status, $activity, $count ) ); $out->print("
\n"); $out->print( sprintf( "%-30s : \%6d (%.02f / mn)\n", $_, $c->{$_}, $c->{$_} / $mn ) ) foreach ( sort keys %$c ); $out->print("\n
\n" ); $out->print( sprintf( "%-30s : %6s / mn\n", $_, $m->{$_} ) ) foreach ( sort keys %$m ); $out->print("\n
\nTotal users : $u\n
\nLocal Cache : " . @t . " objects\n
\nServer up for : " . &timeUp( $out, $mn ) . "\n
\n" ); foreach ( sort { $count->{vhost}->{$b} <=> $count->{vhost}->{$a} } keys %{ $count->{vhost} } ) { $out->print( sprintf( "%-40s : %6d\n", $_, $count->{vhost}->{$_} ) ); } $out->print("\n
\n"); my $i = 0; foreach ( sort { $count->{uri}->{$b} <=> $count->{uri}->{$a} } keys %{ $count->{uri} } ) { last if ( $i == $args->{top} ); last unless ( $count->{uri}->{$_} ); $i++; $out->print( sprintf( "%-80s : %6d\n", $_, $count->{uri}->{$_} ) ); } $out->print("\n
Code | Top |
---|---|
$cat | \n \n"
);
topByCat( $out, $cat, $args->{top} );
$out->print(" \n |
\n"); foreach ( sort { $status->{uri}->{$b}->{$cat} <=> $status->{uri}->{$a}->{$cat} } keys %{ $status->{uri} } ) { last if ( $i == $max ); last unless ( $status->{uri}->{$_}->{$cat} ); $i++; $out->print( sprintf( "%-80s : %6d\n", $_, $status->{uri}->{$_}->{$cat} ) ); } $out->print("\n"); } ## @rfn private void head() # Display head of HTML status responses. sub head { my $out = shift; $out->print( <<"EOF");
$page_title |