//Si hay un proceso lo lanzo {{{
if (@$proceso) {
+
+ yatta_log ('Hay un nuevo proceso. Se forkea');
$pid = pcntl_fork();
//FORK ERROR {{{
//FORK PADRE {{{
elseif ($pid) {
+ yatta_log ('Fork Padre.')
//Espero a que termine el proceso.
while (($wapid = pcntl_waitpid ($pid, $status, WNOHANG)) != $pid) {
if ($CONTROLADOR->abortar($db, $proceso['id'])) {
+ yatta_log ('Hay que abortar el proceso en ejecucion.');
posix_kill($pid, 15); //SIGTERM
$CONTROLADOR->terminarProceso($db, $proceso['id'],
$YATTA_SERVER['id'], 4);
}
//}}}
- //FORk HIJO {{{
+ //FORK HIJO {{{
else {
+ yatta_log ('Fork Hijo.')
require_once $proceso['script'];
if (function_exists('create_process')) {
$SCRIPT =& create_process();
+ yatta_log ('Se instancio el proceso. Se ejecuta el metodo run.');
$SCRIPT->run();
}
else {
$CONROLADOR->terminarProceso($db, $proceso['id'],
$YATTA_SERVER['id'], $estado, @$SCRIPT->error,
@$SCRIPT->archivo, @$SCRIPT->notificar);
+ yatta_log ('Finalizo el proceso.')
}
//}}}
//No hay proceso {{{
else {
- yatta_log('No hay procesos asignados a este servidor.');
+ yatta_log ('No hay procesos asignados a este servidor.');
sleep(60);
}
//}}}
//}}}
//CIERRO EL ARCHIVO DE LOG {{{
+yatta_log ('*************** Finaliza Ejecución ***************');
fclose ($FH);
//}}}
?>
\ No newline at end of file