view release on metacpan or  search on metacpan

lib/AC/MrGamoo/Task/Running.pm  view on Meta::CPAN

75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
}
 
sub _setup_stdio_etal {
 
    # move socket to parent from STDOUT -> STATUS
    # so user code doesn't trample
 
    open( STATUS, ">&STDOUT" );
    close STDOUT; open( STDOUT, ">/dev/null");
    close STDIN;  open( STDIN,  "/dev/null");
    select STATUS; $| = 1; select STDOUT;
    $SIG{CHLD} = sub{};
    $SIG{ALRM} = sub{ die "timeout\n" };
    openlog('mrgamoo', 'ndelay, pid', (conf_value('syslog') || 'local4'));
 
    alarm( $MAXRUN );
}
 
sub _setup_console {
    my $me = shift;

lib/AC/MrGamoo/Task/Running.pm  view on Meta::CPAN

317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
    my $me = shift;
    my $fd = shift;
 
    my $fn = fileno($fd);
    my $rfd = "\0\0\0\0";
 
    # send progress updates to master while sort is sorting
    while(1){
        vec($rfd, $fn, 1) = 1;
 
        select($rfd, undef, undef, 5);
        return if vec($rfd, $fn, 1);
        _maybe_update_status( $me, 'RUNNING', 0);
    }
 
}
 
################################################################
 
 
1;