]> git.llucax.com Git - mecon/yatta.git/blobdiff - script/servidores/YATTA_Server.php
BugFixes.
[mecon/yatta.git] / script / servidores / YATTA_Server.php
index bb82bf3a943b657d49e7b13b41d374893d3a0c66..2f502c47da741fdbbc0ae2964772c993504db240 100755 (executable)
@@ -100,7 +100,8 @@ while (1) {
     if (@$proceso) {
         
         yatta_log ('Hay un nuevo proceso. Se forkea');
-        $pid = pcntl_fork();
+//        $pid = pcntl_fork();
+        $pid = -1;
 
         //FORK ERROR {{{
         if ($pid == -1) {
@@ -110,6 +111,7 @@ while (1) {
             if (PEAR::isError($res)) {
                 yatta_log('ERROR: YATTA_Controlador. '.$res->getMessage());
             }
+            
         }
         //}}}
 
@@ -136,41 +138,47 @@ while (1) {
         //FORK HIJO {{{
         else {
             yatta_log ('Fork Hijo.');
-            require_once $proceso['script'];
-           
-            yatta_log ('Se crea el proceso..');
-            if (function_exists('create_process')) {
-                $SCRIPT =& create_process();
-                yatta_log ('Se instancio el proceso. Se ejecuta el metodo run.');
-                if (!method_exists($SCRIPT, 'run')) {
-                    yatta_log ('No existe el metodo run en el proceso.');
+
+            if (is_readable($proceso['script'])) {
+                require_once $proceso['script'];
+                yatta_log ('Se crea el proceso..');
+                if (function_exists('create_process')) {
+                    $SCRIPT =& create_process();
+                    yatta_log ('Se instancio el proceso. Se ejecuta el metodo run.');
+                    if (!method_exists($SCRIPT, 'run')) {
+                        yatta_log ('No existe el metodo run en el proceso.');
+                        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.');
+                        $SCRIPT->run(unserialize($proceso['parametros']));
+                        yatta_log ('Finaliza la ejecución del proceso.');
+                    }
+                }
+                else {
                     require_once 'YATTA/Proceso.php';
                     $SCRIPT =& new YATTA_Proceso;
-                    $SCRIPT->error = 'No existe el metodo run en'. 
+                    $SCRIPT->error = 'No existe la funcion create_process en'.
                         $proceso['script'];
                 }
+
+                if (@$SCRIPT->error) {
+                    $estado = 3;
+                }
                 else {
-                    yatta_log ('Comienza la ejecución del proceso.');
-                    $SCRIPT->run(unserialize($proceso['parametros']));
-                    yatta_log ('Finaliza la ejecución del proceso.');
+                    $estado = 2;
                 }
+                $CONROLADOR->terminarProceso($db, $proceso['id'],
+                        $YATTA_SERVER['id'], $estado, @$SCRIPT->error,
+                        @$SCRIPT->archivo, @$SCRIPT->notificar);
             }
             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;
+                yatta_log('No se puede alcanzar el archivo.');
             }
-            $CONROLADOR->terminarProceso($db, $proceso['id'],
-                    $YATTA_SERVER['id'], $estado, @$SCRIPT->error,
-                    @$SCRIPT->archivo, @$SCRIPT->notificar);
+           
             
             yatta_log ('Fin fork Hijo.');
         }