File Coverage

blib/lib/System/Introspector/Probe/Processes.pm

Criterion	Covered	Total	%
statement	25	25	100.0
branch	1	2	50.0
condition			n/a
subroutine	5	5	100.0
pod	0	1	0.0
total	31	33	93.9

package System::Introspector::Probe::Processes;
use Moo;

use System::Introspector::Util qw(
    handle_from_command
    transform_exceptions
);

# args is automatically included, since it has to be last
my @Included = qw(
    blocked
    c
    class
    cputime
    egid egroup
    etime
    euid euser
    fgid fgroup
    flags
    fuid fuser
    ignored
    lwp
    nice
    nlwp
    pgid pgrp
    pid ppid
    pri
    psr
    rgid rgroup
    rss
    ruid ruser
    sgid sgroup
    sid
    size
    start_time
    stat
    suid suser
    tid
    time
    tname
    wchan
);

sub gather {
    my ($self) = @_;
    my @names = (@Included, 'args');
    return transform_exceptions {
        my $pipe = $self->_open_ps_pipe;
        my $spec = <$pipe>;
        $spec =~ s{(?:^\s+|\s+$)}{}g;
        my @fields = map lc, split m{\s+}, $spec;
        my @rows;
        while (defined( my $line = <$pipe> )) {
            chomp $line;
            $line =~ s{(?:^\s+|\s+$)}{}g;
            my @values = split m{\s+}, $line, scalar @fields;
            my %row;
            @row{ @names } = @values;
            push @rows, \%row;
        }
        return { processes => [ sort {
            ($a->{args} cmp $b->{args})
            ||
            ($a->{pid} <=> $b->{pid})
        } @rows ] };
    };
}

sub _open_ps_pipe {
    my ($self) = @_;
    return handle_from_command sprintf
        'ps -eo %s',
        join(',', @Included, 'args');
}

1;

__END__