File Coverage

blib/lib/MMM/Batch.pm

Criterion	Covered	Total	%
statement	12	34	35.2
branch	0	14	0.0
condition			n/a
subroutine	4	6	66.6
pod	2	2	100.0
total	18	56	32.1

package MMM::Batch;

use strict;
use warnings;

use base qw(MMM);
use base qw(MMM::Report::Mail);

=head1 NAME

MMM::Batch

=head1 SYNOPSIS

    use MMM::Batch;
    my $mmm = MMM::Batch->new() or die "Cannot find MMM installation";
    $mmm->run();

=head1 DESCRIPTION

A daemon for mmm system

=cut

sub new {
    my ($class, @args) = @_;
    my $mmm = $class->SUPER::new(@args) or return;

    if (!$mmm->{nofork}) {
        Sys::Syslog::openlog('mmm', 'pid', $mmm->configval('default', 'syslog_facilities', 'daemon'));
        $mmm->{use_syslog} = 1;
    }

    $mmm
}

sub run {
    my ( $self ) = @_;

    $self->load();

    my @started_tasks = ();
    foreach my $q ($self->get_tasks_by_name($self->list_tasks)) {
        $q->is_disable() and next;
        $q->frequency or next;
        $q->next_run_time <= scalar(time) or next;
        push(@started_tasks, $q->name);
        $self->_run_fork($q);
    }

    if (@started_tasks) {
        $self->log('DEBUG', 'Started tasks: %s', join(', ', @started_tasks));
    } else {
        $self->log('INFO', 'No task need to be run currently');
    }

    $self->_reap_message();
    $self->_reap_child();

    if ( $self->configval( 'default', 'publish_list' ) ) {
        $self->write_list();
    }
}

1;

__END__