From 3225d15c2b09b1ad7a8eef85a7b0fb98f29ff80b Mon Sep 17 00:00:00 2001 From: =?utf8?q?Mart=C3=ADn=20Marrese?= Date: Tue, 13 Jan 2004 19:12:21 +0000 Subject: [PATCH] Esta lista la primer version para pruebas en servidores --- lib/YATTA/Controlador.php | 102 ++++- lib/YATTA/Proceso.php | 463 +------------------- lib/YATTA/{ProcesoWeb.php => ProcesoDB.php} | 2 +- lib/YATTA/Servidor.php | 36 ++ script/servidores/YATTA_Server.php | 139 +++++- sistema/www/procesos_popup.php | 5 +- test/nuevo_proceso.php | 2 +- 7 files changed, 267 insertions(+), 482 deletions(-) rename lib/YATTA/{ProcesoWeb.php => ProcesoDB.php} (99%) diff --git a/lib/YATTA/Controlador.php b/lib/YATTA/Controlador.php index 63ac167..ec4790b 100644 --- a/lib/YATTA/Controlador.php +++ b/lib/YATTA/Controlador.php @@ -25,7 +25,7 @@ $Id$ -----------------------------------------------------------------------------*/ require_once 'YATTA/Proceso.php'; -require_once 'YATTA/ProcesoWeb.php'; +require_once 'YATTA/ProcesoDB.php'; require_once 'YATTA/Servidor.php'; /** @@ -44,6 +44,10 @@ class YATTA_Controlador { * @access private */ function _obtenerServidor($db) { + + //@FIXME La ponderacion esta mal. No tengo que buscar el que tenga mas + //alta o mas baja OJO!!! Volver a pensar el calculo. + $res = $db->query('SELECT s.id, s.escala * s.procesos AS ponderacion FROM yatta.servidores AS s ORDER BY ponderacion ASC, s.escala DESC'); @@ -110,27 +114,101 @@ class YATTA_Controlador { $proceso->owner = $owner; if (@$id) { $proceso->id = $id; + $res = $proceso->buscar($db, MECON_DBO_AND, ' id ASC'); + $res = $proceso->cargar($res); + return $proceso; + } + else { + return $proceso->buscar($db, MECON_DBO_AND, ' id ASC'); } - return $proceso->buscar($db, MECON_DBO_AND, ' id ASC'); } /** - * Obtiene un proceso de un usuario. + * Actualiza los datos de un proceso al terminar. * * @param DB $db Conexion a la base de datos. - * @param string $owner Usuario duenio de los procesos. - * @param int $id Identificador del proceso a buscar + * @param int $id_proceso Identificador del proceso. + * @param int $id_server Identificador del Servidor. + * @param int $status Identificador del estado de finalizacion. + * @param string $nota Nota de error o similar. + * @param string $archivo Nombre del archivo temporal que esta en el fs. + * @param int $notificar Indica si hay que notificar al owner. * * @return mixed * @access public */ - function obtenerProcesoUsuario($db, $owner, $id) { - $proceso =& new YATTA_ProcesoDB; - $proceso->owner = $owner; - $proceso->id = $id; - $res = $proceso->buscar($db, MECON_DBO_AND, ' id ASC'); - $res = $proceso->cargar($res); - return $proceso; + function terminarProceso($db, $id_proceso, $id_server, $status, $nota = + null, $archivo = null, $notificar = 0) { + + //Actualizo la base procesos + $sql = 'UPDATE yatta.procesos SET status = '. $status; + + if (@$nota) { + $sql.= ', nota = '. $nota; + } + if (@$archivo) { + $sql.= ', archivo = '. $archivo; + } + if (@$notificar) { + $sql.= ', notificar = '. $notificar; + } + $sql.= ' WHERE id = '. $id_proceso; + + $res = $db->query($sql); + // Si hay error lo devuelve. + if (DB::isError($res)) { + return $res; + } + + //@TODO Aca notificar +// if (@$notificar) { +// } + + //Actualizo los servidores + $SERVER =& new YATTA_Servidor; + return $SERVER->quitarProceso($db, $id_server); + } + + /** + * Busca un proceso en cola para el servidor + * + * @param DB $db Conexion a la base de datos. + * @param int $id Identificador del servidor. + * + * @return mixed + * @access public + */ + function obtenerNuevoProceso($db, $id) { + $res = $db->query('SELECT p.id AS id, p.script AS script + FROM yatta.procesos AS p + WHERE p.server = '.$id.' AND status = 0 + ORDER BY p.prioridad, p.id'); + // Si hay error lo devuelve. + if (DB::isError($res)) { + return $res; + } + return $res->fetchRow(DB_FETCHMODE_ASSOC); + } + + /** + * Busca si un proceso que se esta ejecutando tiene pedido de cancelacion. + * + * @param DB $db Conexion a la base de datos. + * @param int $id Identificador del proceso. + * + * @return mixed + * @access public + */ + function abortar($db, $id) { + $res = $db->query('SELECT count(*) AS cuenta + FROM yatta.procesos + WHERE id = '.$id.' AND status = 5'); + // Si hay error lo devuelve. + if (DB::isError($res)) { + return $res; + } + $res = $res->fetchRow(DB_FETCHMODE_ASSOC); + return $res['cuenta']; } } ?> \ No newline at end of file diff --git a/lib/YATTA/Proceso.php b/lib/YATTA/Proceso.php index c193787..f39ca06 100644 --- a/lib/YATTA/Proceso.php +++ b/lib/YATTA/Proceso.php @@ -24,484 +24,45 @@ Autor: Martin Marrese $Id$ -----------------------------------------------------------------------------*/ -require_once 'MECON/DBO.php'; -require_once 'PEAR.php'; -require_once 'Date.php'; - /** * Clase para el manejo de los procesos. * * @access public */ -class YATTA_Proceso extends MECON_DBO { +class YATTA_Proceso { /** - * Identificador del proceso. + * Indica si hay que notificar o no al owner del resultado del script. * - * @var int $id - * @access public - */ - var $id = null; - - /** - * Fecha cuando se agrego el proceso. - * Formato = DD/MM/YYYY - * Puede ser un objeto Date. - * - * @var string $fecha - * @access public - */ - var $fecha = null; - - /** - * Proceso a ejecutar. - * - * @var string $script + * @var int $notificar * @access public */ - var $script = null; + var $notificar = 0; /** - * Identificador del sistema en el cual se lanzo el proceso. - * - * @var int $id_sistema - * @access public - */ - var $id_sistema = null; - - /** - * Nombre del sistema en el cual se lanzo el proceso. + * Contiene el texto del error. * - * @var string $nombre_sistema + * @var string $error * @access public */ - var $nombre_sistema = null; + var $error = 'Desconocido'; /** - * Descripcion del proceso. - * - * @var string $descripcion - * @access public - */ - var $descripcion = null; - - /** - * PID del proceso en el servidor de proceso. - * - * @var int $pid - * @access public - */ - var $pid = null; - - /** - * Servidor en donde se ejecuto/a/ara el proceso. - * - * @var int $server - * @access public - */ - var $server = null; - - /** - * Estado del proceso. - * 0 = En Espera - * 1 = Procesando - * 2 = Finalizado - * 3 = Error - * 4 = Abortado - * - * @var int $status - * @access public - */ - var $status = null; - - /** - * Identificador del usuario responsable por el proceso. - * - * @var string $owner - * @access public - */ - var $owner = null; - - /** - * Destinos para el resultado. - * array ('mmarre@mecon', 'gmeray@mecon') - * - * @var array $destinos - * @access public - */ - var $destinos = null; - - /** - * Prioridad el proceso. - * - * @var int $prioridad - * @access public - */ - var $prioridad = null; - - /** - * Fecha de ejecucion fijada. - * - * @var string $scheduling - * @access public - */ - var $scheduling = null; - - /** - * Indica si se debe notificar o no al owner sobre el resultado. - * - * @var int $notificar - * @access public - */ - var $notificar = null; - - /** - * Nombre del archivo resultado - * - * @var string $resultado - * @access public - */ - var $resultado = null; - - /** - * Nombre del archivo en el tacho + * Indica el nombre del archivo en el filesystem. * * @var string $archivo * @access public */ var $archivo = null; - - /** - * Nota explicativa sobre el error producido o el motivo por el cual se - * aborto el proceso. - * - * @var string $nota - * @access public - */ - var $nota = null; - - /** - * Descripcion del estado. - * - * @var string $icono - * @access public - */ - var $icono = null; - + /** - * Carga el objeto con los datos que se pasan por parametro. - * - * @param DB $db DB o DB_Result a usar para la carga. + * Funcion que realiza la ejecucion del script. * - * @return mixed - * @access public - */ - function cargar($db = null) - { - // Si es un resultado, obtengo los elemento. - if (is_a($db, 'db_result')) { - $this->predefinirAtributos(); - $res = $db->fetchRow(DB_FETCHMODE_ASSOC); - // Si hay error lo devuelve. - if (DB::isError($res)) { - return $res; - } - elseif (!$res) { - return false; - } - $this->id = $res['id']; - $this->fecha = $res['fecha']; - $this->script = $res['script']; - $this->id_sistema = $res['id_sistema']; - $this->nombre_sistema = $res['nombre_sistema']; - $this->descripcion = $res['descripcion']; - $this->pid = $res['pid']; - $this->server = $res['server']; - $this->status = $res['status']; - $this->owner = $res['owner']; - $this->destinos = split(',', $res['destinos']); - $this->prioridad = $res['prioridad']; - $this->scheduling = $res['scheduling']; - $this->notificar = $res['notificar']; - $this->resultado = $res['resultado']; - $this->archivo = $res['archivo']; - $this->nota = $res['nota']; - $this->icono = $res['icono']; - return true; - } - return false; - } - - /** - * Borra el objeto de una base de datos. - * - * @param DB $db Base de datos de donde borrar el objeto. - * - * @return mixed - * @access public - */ - function borrar($db = null) - { - trigger_error('Not implemented!', E_USER_WARNING); - } - - /** - * Busca los datos en la base. - * - * @param DB $db Conexion a la base de datos. - * @param string $operador Indica como deben concatenarse las condiciones de busqueda - * @param string $orden Indica de que manera deben ordenarse los resultados de la busqueda - * - * @return mixed - * @access public - */ - function buscar($db = null, $operador = MECON_DBO_OR, $orden = null) - { - // Armo el WHERE. - if (is_null($this->owner)) { - return new PEAR_Error ('Debe definirse el Owner del proceso.'); - } - $where = array(); - if (!is_null($this->id)) { - $where[] = 'p.id = '.$this->id; - } - if (!is_null($this->fecha)) { - if (is_object($this->fecha) ) { - $fecha = $this->fecha->format("%Y-%m-%d"); - } - else { - list ($dia, $mes, $anio) = split ('[/.-]', $this->fecha); - $fecha = $anio.'-'.$mes.'-'.$dia; - } - $where[] = 'p.fecha = '. $db->quote("$fecha"); - } - if (!is_null($this->script)) { - $where[] = 'p.script LIKE '. $db->quote("%$this->script%"); - } - if (!is_null($this->id_sistema)) { - $where[] = 'p.id_sistema = '. $this->id_sistema; - } - if (!is_null($this->nombre_sistema)) { - $where[] = 's.nombre_sistema LIKE '. $db->quote("%$this->nombre_sistema%"); - } - if (!is_null($this->descripcion)) { - $where[] = 'p.descripcion LIKE '. $db->quote("%$this->descripcion%"); - } - if (!is_null($this->pid)) { - $where[] = 'p.pid = '.$this->pid; - } - if (!is_null($this->server)) { - $where[] = 'p.server = '.$this->server; - } - if (!is_null($this->status)) { - $where[] = 'p.status = '.$this->status; - } - if (!is_null($this->destinos)) { - if (is_array($this->destinos)) { - foreach ($this->destinos as $destino) { - $where[] = 'p.destinos LIKE '. $db->quote("%$destino"); - } - } - else { - $where[] = 'p.destinos LIKE '. $db->quote("%$this->destinos%"); - } - } - if (!is_null($this->prioridad)) { - $where[] = 'p.prioridad = '.$this->prioridad; - } - if (!is_null($this->scheduling)) { - $where[] = 'p.scheduling LIKE '. $db->quote("%$this->scheduling%"); - } - if (!is_null($this->notificar)) { - $where[] = 'p.notificar ='. $this->notificar; - } - if (!is_null($this->resultado)) { - $where[] = 'p.resultado LIKE '. $db->quote("%$this->resultado%"); - } - if (!is_null($this->nota)) { - $where[] = 'p.nota LIKE '. $db->quote("%$this->nota%"); - } - if ($where) { - $where = 'WHERE p.owner = '. $db->quote("$this->owner"). - 'AND p.id_sistema = s.id_sistema AND ('. join ("$operador - ", $where).')'; - } - else { - $where = 'WHERE p.owner = '. $db->quote("$this->owner"). - 'AND p.id_sistema = s.id_sistema'; - } - // Armo el ORDER BY. - if (is_string($orden)) - { - $orden = array($orden); - } - if ($orden) - { - $orden = 'ORDER BY '.join(',',$orden); - } - else { - $orden = ''; - } - - return $db->query("SELECT p.id AS id, - DATE_FORMAT(p.fecha, '%d-%m-%Y') AS fecha, - p.script AS - script, p.id_sistema AS id_sistema, s.nombre_sistema AS - nombre_sistema, p.descripcion AS descripcion, p.pid AS pid, - p.server AS server, p.status AS status, p.owner AS owner, - p.destinos AS destinos, p.prioridad AS prioridad, p.scheduling - AS scheduling, p.notificar AS notificar, p.resultado AS - resultado, p.nota AS nota, p.archivo AS archivo, ". - "IF (p.status = 0, 'El proceso esta en cola. Aun no se ejecuto.". - "', ". - "IF(p.status = 1, 'El proceso se esta ejecutando en este momento.". - "',". - "IF(p.status = 2, 'El proceso ha finalizado. ". - "',". - "IF(p.status = 3, 'Se produjo un error durante la ejecucion". - " del proceso.". - "',". - "'El proceso fue detenido por alguna persona (el responsable o". - " el administrador).". - "'". - ")". - ")". - ")". - ") AS icono - FROM yatta.procesos AS p, samurai.sistema AS s - $where - $orden"); - } - - /** - * Guarda los datos en la base. - * - * @param DB $db Conexion a la base de datos. - * @param bool $nuevo Indica si se trata de un nuevo registro en la base. - * - * @return mixed - * @access public - */ - function guardar($db = null, $nuevo = true) - { -/* - //@TODO PASAR ESTO A UNA CLASE SERVIDOR - //Busco el servidor - $res = $db->query('SELECT id, escala * procesos AS ponderacion - FROM yatta.servidores - ORDER BY ponderacion, escala'); - $res = $res->fetchRow(DB_FETCHMODE_ASSOC); - // Si hay error lo devuelve. - if (DB::isError($res)) { - return $res; - } - $this->server = $res['id']; - //Asigno la fecha - if (@is_null($this->fecha)) { - $this->fecha = date ('Y-m-d'); - } - - if ($nuevo) { - $datos = array ( - 'fecha' => $this->fecha, - 'script' => $this->script, - 'id_sistema' => $this->id_sistema, - 'descripcion' => $this->descripcion, - 'pid' => $this->pid, - 'server' => $this->server, - 'status' => $this->status, - 'owner' => $this->owner, - 'destinos' => $this->destinos, - 'prioridad' => $this->prioridad, - 'scheduling' => $this->scheduling, - 'notificar' => $this->notificar, - 'resultado' => $this->resultado, - 'archivo' => $this->archivo, - 'nota' => $this->nota - ); - - $res = $db->autoExecute('yatta.procesos', $datos, - DB_AUTOQUERY_INSERT); - } - else { - $datos = array ( - 'fecha' => $this->fecha, - 'script' => $this->script, - 'id_sistema' => $this->id_sistema, - 'descripcion' => $this->descripcion, - 'pid' => $this->pid, - 'server' => $this->server, - 'status' => $this->status, - 'owner' => $this->owner, - 'destinos' => $this->destinos, - 'prioridad' => $this->prioridad, - 'scheduling' => $this->scheduling, - 'notificar' => $this->notificar, - 'resultado' => $this->resultado, - 'archivo' => $this->archivo, - 'nota' => $this->nota - ); - - $res = $db->autoExecute('yatta.procesos', $datos, - DB_AUTOQUERY_UPDATE, 'id = '.$this->id); - - } - - if (DB::isError($res)) { - return $res; - } - - return $db->query(' - UPDATE yatta.servidores - SET procesos = procesos + 1 - WHERE id = '. $this->server); -*/ - } - - /** - * Hace un reset de los atributos. - * * @return void * @access public */ - function predefinirAtributos() { - $this->id = null; - $this->fecha = null; - $this->script = null; - $this->id_sistema = null; - $this->nombre_sistema = null; - $this->descripcion = null; - $this->pid = null; - $this->server = null; - $this->status = null; - $this->owner = null; - $this->destinos = null; - $this->prioridad = null; - $this->scheduling = null; - $this->notificar = null; - $this->resultado = null; - $this->archivo = null; - $this->nota = null; - $this->icono = null; - } - - /** - * Devuelve un array asociativo con los valores del proceso. - * - * @return array - * @access public - */ - function obtenerDatos() { - return array ( - 'script' => $this->script, - 'id_sistema' => $this->id_sistema, - 'descripcion' => $this->descripcion, - 'owner' => $this->owner, - 'destinos' => $this->destinos, - 'prioridad' => $this->prioridad, - 'scheduling' => $this->scheduling, - 'notificar' => $this->notificar, - ); + function run() { + $this->error = 'No se implemento el metodo RUN.'; } } ?> \ No newline at end of file diff --git a/lib/YATTA/ProcesoWeb.php b/lib/YATTA/ProcesoDB.php similarity index 99% rename from lib/YATTA/ProcesoWeb.php rename to lib/YATTA/ProcesoDB.php index f253b7a..3540c3f 100644 --- a/lib/YATTA/ProcesoWeb.php +++ b/lib/YATTA/ProcesoDB.php @@ -33,7 +33,7 @@ require_once 'Date.php'; * * @access public */ -class YATTA_ProcesoWeb extends MECON_DBO { +class YATTA_ProcesoDB extends MECON_DBO { /** * Identificador del proceso. diff --git a/lib/YATTA/Servidor.php b/lib/YATTA/Servidor.php index e39876a..694f39a 100644 --- a/lib/YATTA/Servidor.php +++ b/lib/YATTA/Servidor.php @@ -31,6 +31,26 @@ $Id$ */ class YATTA_Servidor { + /** + * Devuelve el id de un servidor a partir del nombre. + * + * @param DB $db Conexion a la base de datos. + * @param string $nombre Nombre del servidor. + * + * @return mixed + * @access public + */ + function obtenerId($db, $nombre) { + $res = $db->query('SELECT s.id FROM yatta.servidores AS s + WHERE s.nombre = '.$db->quote($nombre)); + // Si hay error lo devuelve. + if (DB::isError($res)) { + return $res; + } + $res = $res->fetchRow(DB_FETCHMODE_ASSOC); + return $res['id']; + } + /** * Agrega un proceso a la cola de procesos del servidor * @@ -47,6 +67,22 @@ class YATTA_Servidor { WHERE id = '. $id); } + /** + * Quita un proceso a la cola de procesos del servidor + * + * @param DB $db Conexion a la base de datos. + * @param int $id Identificador del servidor. + * + * @return mixed + * @access public + */ + function quitarProceso($db, $id) { + return $db->query(' + UPDATE yatta.servidores + SET procesos = procesos - 1 + WHERE id = '. $id); + } + /** * Devuelve el estado actual del servidor. * -1 = Error (Mas de un proceso en ejecucion) diff --git a/script/servidores/YATTA_Server.php b/script/servidores/YATTA_Server.php index 06ca1f1..40d38d2 100755 --- a/script/servidores/YATTA_Server.php +++ b/script/servidores/YATTA_Server.php @@ -25,30 +25,141 @@ Autor: Martin Marrese $Id$ -----------------------------------------------------------------------------*/ -//Sacar el \n al final -$SERVIDOR = substr(file_get_contents('/etc/hostname'), 0, strpos - (file_get_contents('/etc/hostname'), "\n")); +//XXX LANZAR ESTE SCRIPT CON NICE -19 + +//@TODO Agregar las linea de logueo -var_dump($SERVIDOR); -exit; +//YATTA LOG {{{ +function yatta_log ($texto) { + 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); +} +//}}} + +//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."); +} +//}}} //REQUIRE ONCE {{{ -require_once 'YATTA/Proceso.php'; require_once 'DB.php'; +require_once 'PEAR.php'; +require_once 'YATTA/Controlador.php'; +require_once 'YATTA/Servidor.php'; //}}} //CREO UNA CONEXION MYSQL{{{ -$DB =& DB::connect('mysql://intranet:intranet@bal747f/yatta', true); -if (DB::isError($DB)) { - die ($DB->getMessage()); +$db =& DB::connect('mysql://intranet:intranet@bal747f/yatta', true); +if (DB::isError($db)) { + die ($db->getMessage()); +} +//}}} + +//CREO LOS OBJETOS NECESARIOS {{{ +$CONTROLADOR =& new YATTA_Controlador; +//}}} + +//OBTENGO LOS DATOS DEL SERVER {{{ +$YATTA_SERVER['script'] = $argv[0]; +$YATTA_SERVER['pid'] = getmypid(); +$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"); } +yatta_log ('*************** Comienzo Ejecución ***************'); //}}} -//BUSCO EL ESTADO DEL SERVIDOR EN LA BASE {{{ -$sql = 'SELECT count(procesos.id) AS cuenta - FROM procesos, servidores - WHERE servidores.nombre = ? and procesos.server = servidores.id and - procesos.status = 1;'; //Status 1 -> Procesando +//WHILEO LAS OPCIONES {{{ +while (1) { + + //Busco un nuevo proceso {{{ + $proceso = $CONTROLADOR->obtenerNuevoProceso($db, + $YATTA_SERVER['id']); + //}}} + + //Si hay un proceso lo lanzo {{{ + if (@$proceso) { + $pid = pcntl_fork(); + + //FORK ERROR {{{ + if ($pid == -1) { + yatta_log('ERROR: No se pudo forkear.'); + $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()); + } + } + //}}} + + //FORK PADRE {{{ + elseif ($pid) { + //Espero a que termine el proceso. + while (($wapid = pcntl_waitpid ($pid, $status, WNOHANG)) != $pid) { + if ($CONTROLADOR->abortar($db, $proceso['id'])) { + posix_kill($pid, 15); //SIGTERM + $CONTROLADOR->terminarProceso($db, $proceso['id'], + $YATTA_SERVER['id'], 4); + } + sleep(10); + } + //Cuando un proceso hijo termina no hay que hacer nada, de eso se + //encargo YATTA_Controlador::terminarProceso + } + //}}} + + //FORk HIJO {{{ + else { + require_once $proceso['script']; + + if (function_exists('create_process')) { + $SCRIPT =& create_process(); + $SCRIPT->run(); + } + else { + require_once 'YATTA/Proceso.php'; + $SCRIPT =& new YATTA_Proceso; + $SCRIPT->error = 'No existe la funcion create_process en'. + $proceso['script']; + } + + + if (@$SCRIPT->error) { + $estado = 3; + } + else { + $estado = 2; + } + $CONROLADOR->terminarProceso($db, $proceso['id'], + $YATTA_SERVER['id'], $estado, @$SCRIPT->error, + @$SCRIPT->archivo, @$SCRIPT->notificar); + } + //}}} + + } + // }}} + + //No hay proceso {{{ + else { + yatta_log('No hay procesos asignados a este servidor.'); + sleep(60); + } + //}}} + +} //}}} +//CIERRO EL ARCHIVO DE LOG {{{ +fclose ($FH); +//}}} ?> \ No newline at end of file diff --git a/sistema/www/procesos_popup.php b/sistema/www/procesos_popup.php index 401843e..acd50be 100644 --- a/sistema/www/procesos_popup.php +++ b/sistema/www/procesos_popup.php @@ -52,9 +52,8 @@ $PROCESO =& new YATTA_Controlador; //Obtengo la info que se pasa por get {{{ $id = (@$_REQUEST['id']) ? $_REQUEST['id'] : null; //}}} - //Obtengo la informacion del proceso {{{ -$PROCESO = $PROCESO->obtenerProcesoUsuario($DB, $_SESSION['usuario'], $id); +$PROCESO = $PROCESO->obtenerProcesosUsuario($DB, $_SESSION['usuario'], $id); //}}} //Creo las imagenes {{{ @@ -76,7 +75,7 @@ $TABLA->addRow(array( 'Sistema: '. $PROCESO->nombre_sistema .'
'. 'Descripcion: '. $PROCESO->descripcion .'
'. 'Owner: '. $PROCESO->owner .'
'. - 'Destinos: '. implode(', ', $PROCESO->destinos) .'
'. + 'Destinos: '. @implode(', ', $PROCESO->destinos) .'
'. 'Nota: '. $PROCESO->nota .'
' )); $PAGE->addBodyContent($TABLA->toHtml()); diff --git a/test/nuevo_proceso.php b/test/nuevo_proceso.php index 33dc689..e4631c6 100755 --- a/test/nuevo_proceso.php +++ b/test/nuevo_proceso.php @@ -18,7 +18,7 @@ $datos = array ( 'script' => 'Prueba con Controlador', 'id_sistema' => 74, 'descripcion' => 'Prueba para probar los controladores', - 'owner' => 'MARTIN' + 'owner' => 'mmarre@mecon' ); //Agrego el proceso a traves del controlador. -- 2.43.0