From: Leandro Lucarella Date: Mon, 19 Apr 2004 15:21:54 +0000 (+0000) Subject: Agrego la posibilidad de seleccionar el nivel del logueo a traves del archivo de... X-Git-Tag: svn_import~4 X-Git-Url: https://git.llucax.com/mecon/yatta.git/commitdiff_plain/ef6642fb710bb00c8f2cfaf105b2e76c43f4769f Agrego la posibilidad de seleccionar el nivel del logueo a traves del archivo de configuración. --- diff --git a/doc/configuracion.ini b/doc/configuracion.ini index 7a633d3..421d0cd 100644 --- a/doc/configuracion.ini +++ b/doc/configuracion.ini @@ -35,8 +35,12 @@ cuota_tamanio = 2 cantidad_dias = 9 ; Link en donde se encuentra yatta (apunta directamente a la seccion archivos). link_archivos = "http://intranet.mecon.ar/sistemas/yatta/archivos" +; Indica el modo de logueo (debug, warning, fatal) +modo_log = "debug" ; Seccion utilizada por el script YATTA_Server.php. [server] ; Path del archivo de log log = "/var/log/apache/YATTA_Server.log" +; Indica el modo de logueo (debug, warning, fatal) +modo_log = "debug" diff --git a/script/servidores/YATTA_Server.php b/script/servidores/YATTA_Server.php index a41ca3b..d868f2d 100755 --- a/script/servidores/YATTA_Server.php +++ b/script/servidores/YATTA_Server.php @@ -25,24 +25,58 @@ Autor: Martin Marrese $Id$ -----------------------------------------------------------------------------*/ -//XXX LANZAR ESTE SCRIPT CON NICE -19 +// TODO FIXME XXX +// Hay problemas con el tiempo de ejecucion del script. No se puede cortar o +// parar asi porque si, si esta ejecutando un proceso hay que esperar hasta que +// este finalice, o hacer que todos manejen interrupciones. -//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. +//XXX LANZAR ESTE SCRIPT CON NICE -19 //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) +define ('YATTA_LOG_DEBUG', 'debug'); +define ('YATTA_LOG_WARNING', 'warning'); +define ('YATTA_LOG_FATAL', 'fatal'); //YATTA LOG {{{ -function yatta_log ($texto) { +//Varia su forma de actuar segun el archivo de configuracion +// +//$texto - Texto a agregar al log +//$modo - uno de debug, warning, fatal +// +//Como root: +//# touch /var/log/apache/YATTA_Tacho.log +//# chown root.www-data /var/log/apache/YATTA_Tacho.log +//# chmod 660 /var/log/apache/YATTA_Tacho.log +function yatta_log ($texto, $modo = YATTA_LOG_FATAL) { GLOBAL $YATTA_SERVER; - GLOBAL $FH; - $linea = strftime("%b %e %H:%M:%S").' '.$YATTA_SERVER['name'].' '. - $YATTA_SERVER['script'].'['.$YATTA_SERVER['pid'].']: '. $texto ."\n"; - fwrite($FH, $linea); + GLOBAL $CONF; + + if (!($FH = fopen ($CONF['server']['log'], "a"))) { + trigger_error("No se pudo abrir el archivo de log.", E_USER_ERROR); + } + else { + $linea = strftime("%b %e %H:%M:%S").' '.$YATTA_SERVER['name'].' '. + $YATTA_SERVER['script'].'['.$YATTA_SERVER['pid'].']: '. $texto ."\n"; + + switch ($CONF['server']['log']) { + case YATTA_LOG_FATAL: + if ($modo == YATTA_LOG_FATAL) { + fwrite($FH, $linea); + } + break; + case YATTA_LOG_WARNING: + if (!($modo == YATTA_LOG_DEBUG)) { + fwrite($FH, $linea); + } + break; + case YATTA_LOG_DEBUG: + fwrite($FH, $linea); + break; + } + fclose ($FH); + } } //}}} @@ -50,16 +84,6 @@ function yatta_log ($texto) { $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 ($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 'PEAR.php'; require_once 'YATTA/Controlador.php'; @@ -70,7 +94,9 @@ require_once 'YATTA/DB.php'; //CREO UNA CONEXION MYSQL{{{ $db = YATTA_DB::connect($CONF['db']); if (DB::isError($db)) { - trigger_error($db->getMessage(), E_USER_ERROR); + yatta_log('Se produjo un error. '. $db->getMessage(), YATTA_LOG_FATAL); + yatta_log('Finaliza la ejecución debido a un error grave.'); + exit; } //}}} @@ -86,7 +112,10 @@ $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'])) { - trigger_error('Error: ' . $YATTA_SERVER['id']->getMessage() . "\n", E_USER_ERROR); + yatta_log('Se produjo un error. '. $YATTA_SERVER['id']->getMessage(), + YATTA_LOG_FATAL); + yatta_log('Finaliza la ejecución debido a un error grave.'); + exit; } yatta_log ('*************** Comienzo Ejecución ***************'); yatta_log (' SCRIPT: ' . $YATTA_SERVER['script']); @@ -108,16 +137,19 @@ while (1) { //Si hay un proceso lo lanzo {{{ if (@$proceso) { - yatta_log ('Hay un nuevo proceso. Se forkea'); + yatta_log ('Hay un nuevo proceso. Se forkea', YATTA_LOG_DEBUG); $pid = pcntl_fork(); //FORK ERROR {{{ if ($pid == -1) { - yatta_log('ERROR: No se pudo forkear.'); + yatta_log('ERROR: No se pudo forkear.', YATTA_LOG_FATAL); $res = $CONTROLADOR->terminarProceso($db, $proceso['id'], $YATTA_SERVER['id'], 3, 'No se pudo forkear el script.'); if (PEAR::isError($res)) { - yatta_log('ERROR: YATTA_Controlador. '.$res->getMessage()); + yatta_log('ERROR: YATTA_Controlador. '.$res->getMessage(), + YATTA_LOG_FATAL); + yatta_log('Finaliza la ejecución debido a un error.', YATTA_LOG_FATAL); + exit; } } @@ -125,52 +157,58 @@ while (1) { //FORK PADRE {{{ elseif ($pid) { - yatta_log ('Fork Padre.'); + yatta_log ('Fork Padre.', YATTA_LOG_DEBUG); //Espero a que termine el proceso. yatta_log ('Se espera a que termine el proceso en ejecución. '. - ' Verifica aborto en 5 segundos.'); + ' Verifica aborto en 5 segundos.', YATTA_LOG_DEBUG); //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.'); + yatta_log ('Hay que abortar el proceso en ejecución.', + YATTA_LOG_WARNING); posix_kill($pid, 15); //SIGTERM $CONTROLADOR->terminarProceso($db, $proceso['id'], $YATTA_SERVER['id'], 4); - yatta_log ('Se aborto el proceso en ejecución.'); + yatta_log ('Se aborto el proceso en ejecución.', + YATTA_LOG_WARNING); } sleep(5); } - yatta_log ('Fin fork Padre.'); + yatta_log ('Fin fork Padre.', YATTA_LOG_DEBUG); } //}}} //FORK HIJO {{{ else { - yatta_log ('Fork Hijo.'); + yatta_log ('Fork Hijo.', YATTA_LOG_DEBUG); //Ejecuto el proceso si existe el archivo {{{ if (is_readable($proceso['script'])) { require_once $proceso['script']; - yatta_log ('Se llama a create_process.'); + yatta_log ('Se llama a create_process.', YATTA_LOG_DEBUG); //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.'); + yatta_log ('Se instancio el proceso. Se ejecuta el metodo + run.', YATTA_LOG_DEBUG); if (!method_exists($SCRIPT, 'run')) { - yatta_log ('No existe el metodo run en el proceso.'); + yatta_log ('No existe el metodo run en el proceso.', + YATTA_LOG_WARNING); 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.'); + yatta_log ('Comienza la ejecución del proceso.', + YATTA_LOG_DEBUG); $SCRIPT->run(unserialize($proceso['parametros'])); - yatta_log ('Finaliza la ejecución del proceso.'); + yatta_log ('Finaliza la ejecución del proceso.', + YATTA_LOG_DEBUG); } } //}}} @@ -181,6 +219,7 @@ while (1) { $SCRIPT =& new YATTA_Proceso; $SCRIPT->error = 'No existe la funcion create_process en'. $proceso['script']; + yatta_log($SCRIPT->error, YATTA_LOG_WARNING); } //}}} @@ -201,13 +240,14 @@ while (1) { //No existe el archivo {{{ else { - yatta_log('No se puede alcanzar el archivo.'); + yatta_log('No se puede alcanzar el archivo '. + $proceso['script'].'.', YATTA_LOG_WARNING); $res = $CONTROLADOR->terminarProceso($db, $proceso['id'], $YATTA_SERVER['id'], 3, 'No se puede alcanzar el archivo.'); } //}}} - yatta_log ('Fin fork Hijo.'); + yatta_log ('Fin fork Hijo.', YATTA_LOG_DEBUG); exit; } //}}} @@ -219,15 +259,10 @@ while (1) { //No hay proceso {{{ else { yatta_log ('No hay procesos asignados a este servidor.'. - ' En 60 segundos se buscara un nuevo proceso.'); + ' En 60 segundos se buscara un nuevo proceso.', YATTA_LOG_DEBUG); sleep(60); } //}}} } //}}} - -//CIERRO EL ARCHIVO DE LOG {{{ -yatta_log ('*************** Finaliza Ejecución ***************'); -fclose ($FH); -//}}} ?> \ No newline at end of file diff --git a/script/servidores/YATTA_Tacho.php b/script/servidores/YATTA_Tacho.php index 931d2a3..624e74d 100755 --- a/script/servidores/YATTA_Tacho.php +++ b/script/servidores/YATTA_Tacho.php @@ -34,14 +34,48 @@ $Id$ //AGREGAR LAS LINEAS DEL LOG //============================================== +define ('YATTA_LOG_DEBUG', 'debug'); +define ('YATTA_LOG_WARNING', 'warning'); +define ('YATTA_LOG_FATAL', 'fatal'); //YATTA LOG {{{ -function yatta_log ($texto) { +//Varia su forma de actuar segun el archivo de configuracion +// +//$texto - Texto a agregar al log +//$modo - uno de debug, warning, fatal +// +//Como root: +//# touch /var/log/apache/YATTA_Tacho.log +//# chown root.www-data /var/log/apache/YATTA_Tacho.log +//# chmod 660 /var/log/apache/YATTA_Tacho.log +function yatta_log ($texto, $modo = YATTA_LOG_FATAL) { GLOBAL $YATTA_SERVER; - GLOBAL $FH; - $linea = strftime("%b %e %H:%M:%S").' '.$YATTA_SERVER['name'].' '. - $YATTA_SERVER['script'].'['.$YATTA_SERVER['pid'].']: '. $texto ."\n"; - fwrite($FH, $linea); + GLOBAL $CONF; + + if (!($FH = fopen ($CONF['tacho']['log'], "a"))) { + trigger_error("No se pudo abrir el archivo de log.", E_USER_ERROR); + } + else { + $linea = strftime("%b %e %H:%M:%S").' '.$YATTA_SERVER['name'].' '. + $YATTA_SERVER['script'].'['.$YATTA_SERVER['pid'].']: '. $texto ."\n"; + + switch ($CONF['tacho']['log']) { + case YATTA_LOG_FATAL: + if ($modo == YATTA_LOG_FATAL) { + fwrite($FH, $linea); + } + break; + case YATTA_LOG_WARNING: + if (!($modo == YATTA_LOG_DEBUG)) { + fwrite($FH, $linea); + } + break; + case YATTA_LOG_DEBUG: + fwrite($FH, $linea); + break; + } + fclose ($FH); + } } //}}} @@ -49,16 +83,6 @@ function yatta_log ($texto) { $CONF = parse_ini_file(dirname(__FILE__) . '/configuracion.ini', true); //}}} -//ABRO EL ARCHIVO DE LOG {{{ -//Como root: -//# touch /var/log/apache/YATTA_Tacho.log -//# chown root.www-data /var/log/apache/YATTA_Tacho.log -//# chmod 660 /var/log/apache/YATTA_Tacho.log -if (!($FH = fopen ($CONF['tacho']['log'], "a"))) { - trigger_error("No se pudo abrir el archivo de log. Se detiene el script.", E_USER_ERROR); -} -//}}} - //REQUIRE ONCE {{{ require_once 'PEAR.php'; require_once 'YATTA/DB.php'; @@ -72,7 +96,9 @@ require_once 'Date/Span.php'; //CREO UNA CONEXION MYSQL{{{ $db = YATTA_DB::connect($CONF['db']); if (DB::isError($db)) { - trigger_error($db->getMessage(), E_USER_ERROR); + yatta_log('Se produjo un error. '. $db->getMessage(), YATTA_LOG_FATAL); + yatta_log('Finaliza la ejecución debido a un error grave.'); + exit; } //}}} @@ -89,7 +115,10 @@ $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'])) { - trigger_error('Error: ' . $YATTA_SERVER['id']->getMessage() . "\n", E_USER_ERROR); + yatta_log('Se produjo un error. '. $YATTA_SERVER['id']->getMessage(), + YATTA_LOG_FATAL); + yatta_log('Finaliza la ejecución debido a un error grave.'); + exit; } yatta_log ('*************** Comienzo Ejecución ***************'); yatta_log (' SCRIPT: ' . $YATTA_SERVER['script']); @@ -102,7 +131,7 @@ yatta_log ('**************************************************'); //BORRO LOS ARCHIVOS CON MAS DE N DIAS {{{ if ($dh = opendir($YATTA_SERVER['path_tacho'])) { - yatta_log('Se borran los archivos antiguos.'); + yatta_log('Se borran los archivos antiguos.', YATTA_LOG_DEBUG); while (false !== ($fh = readdir($dh))) { if ($fh != '.' && $fh != '..' && !in_array($fh, split(',', $CONF['tacho']['ignorar']))) { @@ -116,14 +145,14 @@ if ($dh = opendir($YATTA_SERVER['path_tacho'])) { $archivo->archivo = $fh; $res = $archivo->buscar($DB); if (PEAR::isError($res)) { - trigger_error('Error: ' . $res->getMessage() . "\n", - E_USER_ERROR); + yatta_log('Se produjo un error. '. $res->getMessage(), + YATTA_LOG_WARNING); } $archivo->cargar($res); $res = $archivo->borrar($res); if (PEAR::isError($res)) { - trigger_error('Error: ' . $res->getMessage() . "\n", - E_USER_ERROR); + yatta_log('Se produjo un error. '. $res->getMessage(), + YATTA_LOG_WARNING); } } } @@ -136,28 +165,36 @@ if ($dh = opendir($YATTA_SERVER['path_tacho'])) { //OBTENGO LA LISTA DE USUARIOS QUE TIENEN AL MENOS UNA ENTRADA EN EL MYSQL {{{ $res = $CONTROLADOR->obtenerListaOwners($db, true); if (PEAR::isError($res)) { - trigger_error('Error: ' . $res->getMessage() . "\n", E_USER_ERROR); + yatta_log('Se produjo un error. '. $res->getMessage(), YATTA_LOG_FATAL); + yatta_log('Finaliza la ejecución debido a un error.', YATTA_LOG_FATAL); + exit; } -yatta_log('Se obtiene la lista de owners de los archivos.'); +yatta_log('Se obtiene la lista de owners de los archivos.', YATTA_LOG_DEBUG); //}}} //OBTENGO LA LISTA DE USUARIOS CON CUOTAS EXCEPCIONALES {{{ $cuotas = $CONTROLADOR->obtenerListaCuotas($db); $cuotas = $cuotas->fetchRow(DB_FETCHMODE_ARRAY); if (PEAR::isError($cuotas)) { - trigger_error('Error: ' . $cuotas->getMessage() . "\n", E_USER_ERROR); + yatta_log('Se produjo un error. '. $res->getMessage(), YATTA_LOG_FATAL); + yatta_log('Finaliza la ejecución debido a un error.', YATTA_LOG_FATAL); + exit; } -yatta_log('Se obtienen las cuotas excepcionales.'); +yatta_log('Se obtienen las cuotas excepcionales.', YATTA_LOG_DEBUG); //}}} //WHILEO POR USUARIO {{{ -yatta_log('Se verifica que los usuarios no superen la cuota asignada.'); +yatta_log('Se verifica que los usuarios no superen la cuota asignada.', + YATTA_LOG_DEBUG); while ($usuario = $res->fetchRow(DB_FETCHMODE_ASSOC)) { //VEO EL TIPO DE CUOTA DEL USUARIO {{{ if (@in_array($usuario['owner'], $cuotas)) { if (PEAR::isError($cuotas)) { - trigger_error('Error: ' . $cuotas->getMessage() . "\n", E_USER_ERROR); + yatta_log('Se produjo un error. '. $cuotas->getMessage(), YATTA_LOG_FATAL); + yatta_log('Finaliza la ejecución debido a un error.', YATTA_LOG_FATAL); + exit; } + $cuota = $cuota[$usuario['owner']]; } else { $cuota = $CONF['cuota_tamanio']; @@ -169,13 +206,17 @@ while ($usuario = $res->fetchRow(DB_FETCHMODE_ASSOC)) { $archivo->owner = $usuario['owner']; $res = $archivo->buscar($DB, MECON_DBO_OR, null, false); if (PEAR::isError($res)) { - trigger_error('Error: ' . $res->getMessage() . "\n", E_USER_ERROR); + yatta_log('Se produjo un error. '. $res->getMessage(), YATTA_LOG_FATAL); + yatta_log('Finaliza la ejecución debido a un error.', YATTA_LOG_FATAL); + exit; } $tamanio = 0; $contador = 0; while ($archivo->cargar($res)) { if (PEAR::isError($res)) { - trigger_error('Error: ' . $res->getMessage() . "\n", E_USER_ERROR); + yatta_log('Se produjo un error. '. $res->getMessage(), YATTA_LOG_FATAL); + yatta_log('Finaliza la ejecución debido a un error.', YATTA_LOG_FATAL); + exit; } //Obtengo la fecha, el tamanio de cada archivo. if (file_exists($archivo->archivo)) { @@ -195,7 +236,7 @@ while ($usuario = $res->fetchRow(DB_FETCHMODE_ASSOC)) { //Ordeno los archivos por la fecha, y voy "borrando" los mas viejos //hasta cumplir con el tamaño de la cuota. yatta_log('El usuario '. $usuario['owner'] - .' ha excedido la cuota de su casilla'); + .' ha excedido la cuota de su casilla', YATTA_LOG_WARNING); usort($archivos, 'usort_archivos_callback'); $seguir = true; while ($seguir == true) { @@ -211,7 +252,7 @@ while ($usuario = $res->fetchRow(DB_FETCHMODE_ASSOC)) { //Borros los archivos correspondientes. foreach ($borrar as $b) { yatta_llog('Se borra el archivo '. $b .' perteneciente a '. - $usuario['owner']); + $usuario['owner'], YATTA_LOG_WARNING); unlink($b); } //Envio el email @@ -240,7 +281,8 @@ while ($usuario = $res->fetchRow(DB_FETCHMODE_ASSOC)) { //LEVANTAR DEL ARCHIVO DE CONFIGURACION EL HOST PARA EL LINK (ASI EL //USUARIO VA A VER QUE TIENE, QUE BORRA Y QUE NO) yatta_log('El usuario '. $usuario['owner'] - .' ha superado el limite de aviso. Se envia email. '); + .' ha superado el limite de aviso. Se envia email.', + YATTA_LOG_WARNING); $body = "Su cuota dentro del sistema YATTA esta por completarse, le \n". "pedimos que libere espacio para futuros archivos.\n". @@ -258,10 +300,7 @@ while ($usuario = $res->fetchRow(DB_FETCHMODE_ASSOC)) { //}}} //}}} -//CIERRO EL ARCHIVO DE LOG {{{ -yatta_log ('*************** Finaliza Ejecución ***************'); -fclose ($FH); -//}}} +//FIN SCRIPT //FUNCIONES AUXILIARES {{{ //Ordena los archivos segun la "edad" @@ -272,5 +311,4 @@ function usort_archivos_callback($arg1, $arg2) { return ($arg1['fecha'] < $arg2['fecha']) ? -1 : 1; } //}}} - ?> \ No newline at end of file