Agrego el abm de servidores

[mecon/yatta.git] / script / servidores / YATTA_Server.php

diff --git a/script/servidores/YATTA_Server.php b/script/servidores/YATTA_Server.php
index 40d38d2c565dad117cb8f8f71b3a796cbd01ae39..55d185d57d37eaef65fa420d669f5fbc4773636d 100755 (executable)
--- a/script/servidores/YATTA_Server.php
+++ b/script/servidores/YATTA_Server.php
@@ -65,6 +65,7 @@ if (DB::isError($db)) {
 
 //CREO LOS OBJETOS NECESARIOS {{{
 $CONTROLADOR =& new YATTA_Controlador;
+$SERVIDOR =& new YATTA_Servidor;
 //}}}
 
 //OBTENGO LOS DATOS DEL SERVER {{{
@@ -89,6 +90,8 @@ while (1) {
 
     //Si hay un proceso lo lanzo {{{
     if (@$proceso) {
+        
+        yatta_log ('Hay un nuevo proceso. Se forkea');
         $pid = pcntl_fork();
 
         //FORK ERROR {{{
@@ -104,9 +107,11 @@ while (1) {
 
         //FORK PADRE {{{
         elseif ($pid) {
+            yatta_log ('Fork Padre.')
             //Espero a que termine el proceso.
             while (($wapid = pcntl_waitpid ($pid, $status, WNOHANG)) != $pid) {
                 if ($CONTROLADOR->abortar($db, $proceso['id'])) {
+                    yatta_log ('Hay que abortar el proceso en ejecucion.');
                     posix_kill($pid, 15); //SIGTERM
                     $CONTROLADOR->terminarProceso($db, $proceso['id'],
                             $YATTA_SERVER['id'], 4);
@@ -118,12 +123,14 @@ while (1) {
         }
         //}}}
 
-        //FORk HIJO {{{
+        //FORK HIJO {{{
         else {
+            yatta_log ('Fork Hijo.')
             require_once $proceso['script'];
             
             if (function_exists('create_process')) {
                 $SCRIPT =& create_process();
+                yatta_log ('Se instancio el proceso. Se ejecuta el metodo run.');
                 $SCRIPT->run();
             }
             else {
@@ -143,6 +150,7 @@ while (1) {
             $CONROLADOR->terminarProceso($db, $proceso['id'],
                     $YATTA_SERVER['id'], $estado, @$SCRIPT->error,
                     @$SCRIPT->archivo, @$SCRIPT->notificar);
+            yatta_log ('Finalizo el proceso.')
         }
         //}}}
 
@@ -151,7 +159,7 @@ while (1) {
 
     //No hay proceso {{{
     else {
-        yatta_log('No hay procesos asignados a este servidor.');
+        yatta_log ('No hay procesos asignados a este servidor.');
         sleep(60);
     }
     //}}}
@@ -160,6 +168,7 @@ while (1) {
 //}}}
 
 //CIERRO EL ARCHIVO DE LOG {{{
+yatta_log ('*************** Finaliza Ejecución ***************');
 fclose ($FH);
 //}}}
 ?>
\ No newline at end of file