File Coverage

blib/lib/Proc/LoadMonitor.pm

Criterion	Covered	Total	%
statement	50	50	100.0
branch	6	10	60.0
condition	7	11	63.6
subroutine	9	9	100.0
pod	3	4	75.0
total	75	84	89.2

package Proc::LoadMonitor;
$Proc::LoadMonitor::VERSION = '1.000';
use Time::HiRes qw(tv_interval gettimeofday);
use Moo;
use strict;
use warnings;

has '__load_log' => ( is => 'ro', default => sub { [] } );

has '__start_busy' => ( is => 'rw' );

has '__start_idle' => ( is => 'rw' );

has '__start_time' => ( is => 'rw' );

has 'state' => ( is => 'rw' );

has 'jobs' => ( is => 'rw', default => 0 );

has 'loops' => ( is => 'rw', default => 0 );

sub BUILD {
    my ($self) = @_;
    my $timeofday = [gettimeofday];
    $self->__start_idle($timeofday);
    $self->__start_time($timeofday);
    $self->state('idle');
}

sub busy {
    my ($self) = @_;
    return if $self->state eq 'busy';
    $self->__start_busy( [gettimeofday] );
    $self->jobs( $self->jobs + 1 );
    $self->state('busy');
}

sub idle {
    my ($self) = @_;
    $self->loops( $self->loops + 1 );
    return if $self->state eq 'idle';
    $self->__start_idle( [gettimeofday] );
    my $elapsed   = tv_interval( $self->__start_busy );
    my $time_slot = __time_slot();
    my $load_log  = $self->__load_log;
    $load_log->[$time_slot] += $elapsed;
    $load_log->[ __time_slot( $time_slot, $_ ) ] = undef for 1 .. 15;
    $self->state('idle');
}

sub report {
    my ($self)    = @_;
    my $time_slot = __time_slot();
    my $load_log  = $self->__load_log;
    my $seconds   = (localtime)[0];
    my $sum_05    = $load_log->[$time_slot];
    $sum_05 += $load_log->[ __time_slot( $time_slot, -$_ ) ] // 0 for 1 .. 5;
    my $load_05 = $sum_05 / ( 300 + $seconds );
    my $sum_10 = $sum_05;
    $sum_10 += $load_log->[ __time_slot( $time_slot, -$_ ) ] // 0 for 6 .. 10;
    my $load_10 = $sum_10 / ( 600 + $seconds );
    my $sum_15 = $sum_10;
    $sum_15 += $load_log->[ __time_slot( $time_slot, -$_ ) ] // 0 for 11 .. 15;
    my $load_15 = $sum_15 / ( 900 + $seconds );
    return {
        load_05 => sprintf( '%.3f', $load_05 > 1 ? 1 : $load_05 ),
        load_10 => sprintf( '%.3f', $load_10 > 1 ? 1 : $load_10 ),
        load_15 => sprintf( '%.3f', $load_15 > 1 ? 1 : $load_15 ),
        total => tv_interval( $self->__start_time ),
        loops => $self->loops,
        jobs  => $self->jobs,
        state => $self->state,
    };
}

sub __time_slot {
    my ( $base, $offset ) = @_;
    $base   //= (localtime)[1];    # minutes
    $offset //= 0;
    return ( $base + $offset + 60 ) % 60;
}

1;                                 # track-id: 3a59124cfcc7ce26274174c962094a20

__END__