lib/YATTA/Servidor.php

   1 <?php /* vim: set binary expandtab tabstop=4 shiftwidth=4 textwidth=80:
   2 -------------------------------------------------------------------------------
   3                              Ministerio de Economía
   4                                     YATTA!
   5 -------------------------------------------------------------------------------
   6 This file is part of YATTA!.
   7
   8 YATTA! is free software; you can redistribute it and/or modify it under
   9 the terms of the GNU General Public License as published by the Free
  10 Software Foundation; either version 2 of the License, or (at your option)
  11 any later version.
  12
  13 YATTA! is distributed in the hope that it will be useful, but WITHOUT
  14 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
  15 FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
  16
  17 You should have received a copy of the GNU General Public License; if not,
  18 write to the Free Software Foundation, Inc., 59 Temple Place, Suite 330,
  19 Boston, MA  02111-1307  USA
  20 -------------------------------------------------------------------------------
  21 Creado: vie ene  9 17:34:23 ART 2004
  22 Autor:  Martin Marrese <mmarre@mecon.gov.ar>
  23 -------------------------------------------------------------------------------
  24 $Id$
  25 -----------------------------------------------------------------------------*/
  26
  27 /**
  28  * Clase para el manejo de los servidores de YATTA.
  29  *
  30  * @access public
  31  */
  32 class YATTA_Servidor {
  33
  34     /**
  35      * Devuelve el id de un servidor a partir del nombre.
  36      *
  37      * @param  DB $db Conexion a la base de datos.
  38      * @param  string $nombre Nombre del servidor.
  39      *
  40      * @return mixed
  41      * @access public
  42      */
  43     function obtenerId($db, $nombre) {
  44         $res = $db->query('SELECT s.id FROM yatta.servidores AS s
  45                 WHERE s.nombre = '.$db->quote($nombre));
  46         // Si hay error lo devuelve.
  47         if (DB::isError($res)) {
  48             return $res;
  49         }
  50         $res = $res->fetchRow(DB_FETCHMODE_ASSOC);
  51         return  $res['id'];
  52     }
  53
  54     /**
  55      * Agrega un proceso a la cola de procesos del servidor
  56      *
  57      * @param  DB $db Conexion a la base de datos.
  58      * @param  int $id Identificador del servidor.
  59      *
  60      * @return mixed
  61      * @access public
  62      */
  63     function agregarProceso($db, $id) {
  64         return  $db->query('
  65                 UPDATE yatta.servidores
  66                 SET procesos = procesos + 1
  67                 WHERE id = '. $id);
  68     }
  69
  70     /**
  71      * Quita un proceso a la cola de procesos del servidor
  72      *
  73      * @param  DB $db Conexion a la base de datos.
  74      * @param  int $id Identificador del servidor.
  75      *
  76      * @return mixed
  77      * @access public
  78      */
  79     function quitarProceso($db, $id) {
  80         return  $db->query('
  81                 UPDATE yatta.servidores
  82                 SET procesos = procesos - 1
  83                 WHERE id = '. $id);
  84     }
  85
  86     /**
  87      * Devuelve el estado actual del servidor.
  88      * -1 = Error (Mas de un proceso en ejecucion)
  89      * 0 = Idle
  90      * n = PID del proceso en ejecucion
  91      *
  92      * @param  DB $db Conexion a la base de datos.
  93      * @param  string $nombre Nombre del servidor.
  94      *
  95      * @return mixed
  96      * @access public
  97      */
  98     function obtenerEstado($db, $nombre) {
  99         $res = $db->query("SELECT p.pid AS pid
 100             FROM yatta.procesos AS p, yatta.servidores AS s
 101             WHERE s.nombre = '$nombre' AND p.server = s.id
 102             AND p.status = 1");
 103         // Si hay error lo devuelve.
 104         if (DB::isError($res)) {
 105             return $res;
 106         }
 107         if ($res->numRows() > 1) {
 108             return -1;
 109         }
 110         elseif ($res->numRows() == 0) {
 111             return 0;
 112         }
 113         else {
 114             $res = $res->fetchRow(DB_FETCHMODE_ASSOC);
 115             return $res['pid'];
 116         }
 117
 118     }
 119
 120 }
 121 ?>