X-Git-Url: https://git.llucax.com/mecon/yatta.git/blobdiff_plain/3225d15c2b09b1ad7a8eef85a7b0fb98f29ff80b..85bf75618ce08e9d9c419a63f2a08e3f321bf12c:/script/servidores/YATTA_Server.php diff --git a/script/servidores/YATTA_Server.php b/script/servidores/YATTA_Server.php index 40d38d2..4ccd109 100755 --- a/script/servidores/YATTA_Server.php +++ b/script/servidores/YATTA_Server.php @@ -27,7 +27,14 @@ $Id$ //XXX LANZAR ESTE SCRIPT CON NICE -19 -//@TODO Agregar las linea de logueo +//TODO No mantener abierto el archivo de log durante toda la ejecucion, porque +//se afecta con el logrotate. Ver de capturar alguna señal por esto. + +//TODO Ver si es conveniente que la conexion al mysql esta abierta desde el +//principio. Hay problemas con eso? + +//TODO Que el logueo sea selectivo segun un parametro en el archivo de +//configuracion (tipo modo histerico, normal, tranquilo, nada) //YATTA LOG {{{ function yatta_log ($texto) { @@ -39,32 +46,37 @@ function yatta_log ($texto) { } //}}} +//LEO EL ARCHIVO DE CONFIGURACION {{{ +$CONF = parse_ini_file(dirname(__FILE__) . '/configuracion.ini', true); +//}}} + //ABRO EL ARCHIVO DE LOG {{{ //Como root: //# touch /var/log/apache/YATTA_Server.log //# chown root.www-data /var/log/apache/YATTA_Server.log //# chmod 660 /var/log/apache/YATTA_Server.log -if (!($FH = fopen ("/var/log/apache/YATTA_Server.log", "a"))) { - die ("No se pudo abrir el archivo de log. Se detiene el script."); +if (!($FH = fopen ($CONF['server']['log'], "a"))) { + trigger_error("No se pudo abrir el archivo de log. Se detiene el script.", E_USER_ERROR); } //}}} //REQUIRE ONCE {{{ -require_once 'DB.php'; require_once 'PEAR.php'; require_once 'YATTA/Controlador.php'; require_once 'YATTA/Servidor.php'; +require_once 'YATTA/DB.php'; //}}} //CREO UNA CONEXION MYSQL{{{ -$db =& DB::connect('mysql://intranet:intranet@bal747f/yatta', true); +$db = YATTA_DB::connect($CONF['db']); if (DB::isError($db)) { - die ($db->getMessage()); + trigger_error($db->getMessage(), E_USER_ERROR); } //}}} //CREO LOS OBJETOS NECESARIOS {{{ $CONTROLADOR =& new YATTA_Controlador; +$SERVIDOR =& new YATTA_Servidor; //}}} //OBTENGO LOS DATOS DEL SERVER {{{ @@ -74,12 +86,18 @@ $YATTA_SERVER['name'] = substr(file_get_contents('/etc/hostname'), 0, strpos (file_get_contents('/etc/hostname'), "\n")); $YATTA_SERVER['id'] = $SERVIDOR->obtenerId($db, $YATTA_SERVER['name']); if (PEAR::isError($YATTA_SERVER['id'])) { - die('Error: ' . $YATTA_SERVER['id']->getMessage() . "\n"); + trigger_error('Error: ' . $YATTA_SERVER['id']->getMessage() . "\n", E_USER_ERROR); } yatta_log ('*************** Comienzo Ejecución ***************'); +yatta_log (' SCRIPT: ' . $YATTA_SERVER['script']); +yatta_log (' PID: ' . $YATTA_SERVER['pid']); +yatta_log (' SERVER NAME: ' . $YATTA_SERVER['name']); +yatta_log (' SERVER ID: ' . $YATTA_SERVER['id']); +yatta_log ('**************************************************'); //}}} //WHILEO LAS OPCIONES {{{ +yatta_log ('Se busca un nuevo proceso.'); while (1) { //Busco un nuevo proceso {{{ @@ -89,6 +107,8 @@ while (1) { //Si hay un proceso lo lanzo {{{ if (@$proceso) { + + yatta_log ('Hay un nuevo proceso. Se forkea'); $pid = pcntl_fork(); //FORK ERROR {{{ @@ -99,67 +119,115 @@ while (1) { if (PEAR::isError($res)) { yatta_log('ERROR: YATTA_Controlador. '.$res->getMessage()); } + } //}}} //FORK PADRE {{{ elseif ($pid) { + yatta_log ('Fork Padre.'); //Espero a que termine el proceso. - while (($wapid = pcntl_waitpid ($pid, $status, WNOHANG)) != $pid) { + yatta_log ('Se espera a que termine el proceso en ejecución. '. + ' Verifica aborto en 5 segundos.'); + + //Pregunto si el hijo que se forkeo arriba termino, pero pido que no + //corte la ejecucion (WNOHANG) para poder entrar en el while. + //$res sera el pid del hijo, en este caso $res = $pid. + while (!($res = pcntl_waitpid($pid, $status, WNOHANG))) { if ($CONTROLADOR->abortar($db, $proceso['id'])) { + yatta_log ('Hay que abortar el proceso en ejecución.'); posix_kill($pid, 15); //SIGTERM $CONTROLADOR->terminarProceso($db, $proceso['id'], $YATTA_SERVER['id'], 4); + yatta_log ('Se aborto el proceso en ejecución.'); } - sleep(10); + sleep(5); } - //Cuando un proceso hijo termina no hay que hacer nada, de eso se - //encargo YATTA_Controlador::terminarProceso + yatta_log ('Fin fork Padre.'); } //}}} - //FORk HIJO {{{ + //FORK HIJO {{{ else { - require_once $proceso['script']; + yatta_log ('Fork Hijo.'); + + //Ejecuto el proceso si existe el archivo {{{ + if (is_readable($proceso['script'])) { + require_once $proceso['script']; + yatta_log ('Se llama a create_process.'); + + //Llamo a la funcion create_process {{{ + if (function_exists('create_process')) { + $SCRIPT =& create_process(); + yatta_log ('Se instancio el proceso. Se ejecuta el metodo run.'); + if (!method_exists($SCRIPT, 'run')) { + yatta_log ('No existe el metodo run en el proceso.'); + require_once 'YATTA/Proceso.php'; + $SCRIPT =& new YATTA_Proceso; + $SCRIPT->error = 'No existe el metodo run en'. + $proceso['script']; + } + else { + yatta_log ('Comienza la ejecución del proceso.'); + $SCRIPT->run(unserialize($proceso['parametros'])); + yatta_log ('Finaliza la ejecución del proceso.'); + } + } + //}}} + + //No existe la funcion {{{ + else { + require_once 'YATTA/Proceso.php'; + $SCRIPT =& new YATTA_Proceso; + $SCRIPT->error = 'No existe la funcion create_process en'. + $proceso['script']; + } + //}}} + + //Finalizo el script {{{ + if (@$SCRIPT->error) { + $estado = 3; + } + else { + $estado = 2; + } + $CONTROLADOR->terminarProceso($db, $proceso['id'], + $YATTA_SERVER['id'], $estado, @$SCRIPT->error, + @$SCRIPT->archivo, @$SCRIPT->notificar); + //}}} - if (function_exists('create_process')) { - $SCRIPT =& create_process(); - $SCRIPT->run(); } + //}}} + + //No existe el archivo {{{ else { - require_once 'YATTA/Proceso.php'; - $SCRIPT =& new YATTA_Proceso; - $SCRIPT->error = 'No existe la funcion create_process en'. - $proceso['script']; + yatta_log('No se puede alcanzar el archivo.'); + $res = $CONTROLADOR->terminarProceso($db, $proceso['id'], + $YATTA_SERVER['id'], 3, 'No se puede alcanzar el archivo.'); } + //}}} - - if (@$SCRIPT->error) { - $estado = 3; - } - else { - $estado = 2; - } - $CONROLADOR->terminarProceso($db, $proceso['id'], - $YATTA_SERVER['id'], $estado, @$SCRIPT->error, - @$SCRIPT->archivo, @$SCRIPT->notificar); + yatta_log ('Fin fork Hijo.'); + exit; } //}}} + unset($proceso); } // }}} //No hay proceso {{{ else { - yatta_log('No hay procesos asignados a este servidor.'); + yatta_log ('No hay procesos asignados a este servidor.'. + ' En 60 segundos se buscara un nuevo proceso.'); sleep(60); } //}}} - } //}}} //CIERRO EL ARCHIVO DE LOG {{{ +yatta_log ('*************** Finaliza Ejecución ***************'); fclose ($FH); //}}} ?> \ No newline at end of file