Esta lista la primer version para pruebas en servidores

diff --git a/lib/YATTA/Controlador.php b/lib/YATTA/Controlador.php
index 63ac16773e5097967e8c4b1848f7cacd36c6ca44..ec4790b7809776f4d39bc8083ff28a4297d64a21 100644 (file)
--- a/lib/YATTA/Controlador.php
+++ b/lib/YATTA/Controlador.php
@@ -25,7 +25,7 @@ $Id$
 -----------------------------------------------------------------------------*/
 
 require_once 'YATTA/Proceso.php';
 -----------------------------------------------------------------------------*/
 
 require_once 'YATTA/Proceso.php';

-require_once 'YATTA/ProcesoWeb.php';
+require_once 'YATTA/ProcesoDB.php';

 require_once 'YATTA/Servidor.php';
 
 /**
 require_once 'YATTA/Servidor.php';
 
 /**


@@ -44,6 +44,10 @@ class YATTA_Controlador {
      * @access private
      */
     function _obtenerServidor($db) {
      * @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');
         $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;
         $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 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
      */
      *
      * @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
     }
 }
 ?>
\ No newline at end of file

diff --git a/lib/YATTA/Proceso.php b/lib/YATTA/Proceso.php
index c193787f9d7c97362fedb4263b7bd4062de8e080..f39ca06eb940a3ffcfa6857c836970d458d22d8a 100644 (file)
--- a/lib/YATTA/Proceso.php
+++ b/lib/YATTA/Proceso.php
@@ -24,484 +24,45 @@ Autor:  Martin Marrese <mmarre@mecon.gov.ar>
 $Id$
 -----------------------------------------------------------------------------*/
 
 $Id$
 -----------------------------------------------------------------------------*/
 

-require_once 'MECON/DBO.php';
-require_once 'PEAR.php';
-require_once 'Date.php';
-

 /**
  * Clase para el manejo de los procesos.
  *
  * @access public
  */
 /**
  * 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
      */
      * @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
      */
      * @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;
      *
      * @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
      */
      * @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
     }
 }
 ?>
\ 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 f253b7afc690b6a9cff3fd1dbab34393b0ca4c08..3540c3f5eb85baeb371a4d47d2b9aa6180d873e3 100644 (file)
--- a/lib/YATTA/ProcesoWeb.php
+++ b/lib/YATTA/ProcesoDB.php
@@ -33,7 +33,7 @@ require_once 'Date.php';
  *
  * @access public
  */
  *
  * @access public
  */

-class YATTA_ProcesoWeb extends MECON_DBO {
+class YATTA_ProcesoDB extends MECON_DBO {

 
     /**
      * Identificador del proceso.
 
     /**
      * Identificador del proceso.

diff --git a/lib/YATTA/Servidor.php b/lib/YATTA/Servidor.php
index e39876a632b75a2115baabb4f36f2727c0d7a0cd..694f39aeba88630f3cc76d203d7624cde6cb6d68 100644 (file)
--- a/lib/YATTA/Servidor.php
+++ b/lib/YATTA/Servidor.php
@@ -31,6 +31,26 @@ $Id$
  */
 class YATTA_Servidor {
 
  */
 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
      *
     /**
      * Agrega un proceso a la cola de procesos del servidor
      *


@@ -47,6 +67,22 @@ class YATTA_Servidor {
                 WHERE id = '. $id);
     }
 
                 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)
     /**
      * 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 06ca1f11082e9e2b895facff89a09d535046e16c..40d38d2c565dad117cb8f8f71b3a796cbd01ae39 100755 (executable)
--- a/script/servidores/YATTA_Server.php
+++ b/script/servidores/YATTA_Server.php
@@ -25,30 +25,141 @@ Autor:  Martin Marrese <mmarre@mecon.gov.ar>
 $Id$
 -----------------------------------------------------------------------------*/
 
 $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 {{{

-require_once 'YATTA/Proceso.php';

 require_once 'DB.php';
 require_once 'DB.php';

+require_once 'PEAR.php';
+require_once 'YATTA/Controlador.php';
+require_once 'YATTA/Servidor.php';

 //}}}
 
 //CREO UNA CONEXION MYSQL{{{
 //}}}
 
 //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
 ?>
\ No newline at end of file

diff --git a/sistema/www/procesos_popup.php b/sistema/www/procesos_popup.php
index 401843ea749e3820f0440d79c65c35c066d0ff82..acd50bee2b3dee6f9aab96477721c1d3493c04c6 100644 (file)
--- 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 info que se pasa por get {{{
 $id = (@$_REQUEST['id']) ? $_REQUEST['id'] : null;
 //}}}

-

 //Obtengo la informacion del proceso {{{
 //Obtengo la informacion del proceso {{{

-$PROCESO = $PROCESO->obtenerProcesoUsuario($DB, $_SESSION['usuario'], $id);
+$PROCESO = $PROCESO->obtenerProcesosUsuario($DB, $_SESSION['usuario'], $id);

 //}}}
 
 //Creo las imagenes {{{
 //}}}
 
 //Creo las imagenes {{{


@@ -76,7 +75,7 @@ $TABLA->addRow(array(
                 '<b>Sistema: '. $PROCESO->nombre_sistema .'</b><br>'.
                 '<b>Descripcion: '. $PROCESO->descripcion .'</b><br>'.
                 '<b>Owner: '. $PROCESO->owner .'</b><br>'.
                 '<b>Sistema: '. $PROCESO->nombre_sistema .'</b><br>'.
                 '<b>Descripcion: '. $PROCESO->descripcion .'</b><br>'.
                 '<b>Owner: '. $PROCESO->owner .'</b><br>'.

-                '<b>Destinos: '. implode(', ', $PROCESO->destinos) .'</b><br>'.
+                '<b>Destinos: '. @implode(', ', $PROCESO->destinos) .'</b><br>'.

                 '<b>Nota: '. $PROCESO->nota .'</b><br>' 
             ));
 $PAGE->addBodyContent($TABLA->toHtml());
                 '<b>Nota: '. $PROCESO->nota .'</b><br>' 
             ));
 $PAGE->addBodyContent($TABLA->toHtml());

diff --git a/test/nuevo_proceso.php b/test/nuevo_proceso.php
index 33dc68945a0a9f8233e65e93a9e4411f3504fac2..e4631c66b1d5d40433c392f368acdad708629c9b 100755 (executable)
--- 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',
             '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.
         );
 
 //Agrego el proceso a traves del controlador.