File Coverage

blib/lib/FCGI/Restarter.pm

Criterion	Covered	Total	%
statement	12	47	25.5
branch	0	22	0.0
condition	0	2	0.0
subroutine	4	6	66.6
pod	0	2	0.0
total	16	79	20.2

package FCGI::Restarter;
use 5.008001;
use strict;
use Class::Accessor::Tiny qw( new poll_interval watch_file script onidle onaccept);
use FCGI;
our $VERSION = '0.12';
our @expect_file;
our %file;
our $restart_file = "/home/sites/combats.ru/web/start.pl";

my $STDIN_fileno =  fileno STDIN;
my $count;
my $start;
sub new_request{
    my $self = shift;
    -t STDIN && return FCGI::accept() >= 0;
    my $wait = 0;
    FCGI::finish() if $start;

    do {
        my @vector = ( '', '', '' );
        vec( $_, $STDIN_fileno, 1) = 1 for ( $vector[0] );

        my $found = select $vector[0], $vector[1], $vector[2], $self->get_poll_interval() ||5;
        if ( vec( $vector[0], $STDIN_fileno, 1 )){
            my $onaccept = $self->get_onaccept();
            $onaccept->() if ref $onaccept eq 'CODE';
            $wait = 1;
        }
        else {
            exit 1 if $found < 0 ;
            my $onidle = $self->get_onidle();
            $onidle->() if ref $onidle eq 'CODE';
        }
    }
    until( $wait  > 0);

    if ( ! if_modified ( $self ) ){
        $start = 1;
        return FCGI::accept()>=0;
    }
    my $restart_file = $self->get_script();
    exec "$restart_file";
};

my %watch_file;
sub if_modified{
    my $self = shift;
    if ( $start ){
        my $files = $self->get_watch_file();
        my $afiles =  ref $files ? $files : [ $files ];
        for ( @$afiles ){
            my ( $mtime ) = (stat $_)[9];
            if ( $mtime != $watch_file{ $_ }{mtime} ){
                return 1;
            }
        }
        return ! $files;
    }
    else {
        my $files = $self->get_watch_file();
        $files = [ $files ] if ! ref $files;
        for ( @$files ){
            my ( $mtime ) = (stat $_)[9];
            $watch_file{ $_ }{mtime} = $mtime;
        }
        return 0;
    }
}


1;
__END__