Verificar código de retorno del subproceso.

[software/sercom.git] / sercom / model.py

diff --git a/sercom/model.py b/sercom/model.py
index 6191710fbe69a4b946e0df62e3ab4ca5279a4f56..07ad64e4dcd66b9b269f095d6355afa1038cdc5b 100644 (file)
--- a/sercom/model.py
+++ b/sercom/model.py
@@ -324,12 +324,19 @@ class TareaPrueba(Tarea): #{{{
 #}}}
 
 class Comando(InheritableSQLObject): #{{{
+    # Tipos de retorno especiales
     RET_ANY = None
-    RET_FAIL = -1
+    RET_FAIL = -256
+    # Archivos especiales
+    STDIN = '__stdin__'
+    STDOUT = '__stdout__'
+    STDERR = '__stderr__'
+    STDOUTERR = '__stdouterr__'
     # Campos
     comando             = UnicodeCol(length=255, notNone=True)
     descripcion         = UnicodeCol(length=255, default=None)
-    retorno             = IntCol(default=None) # None es que no importa
+    retorno             = IntCol(default=None) # Ver RET_XXX y si es negativo
+                                               # se espera una señal
     max_tiempo_cpu      = IntCol(default=None) # En segundos
     max_memoria         = IntCol(default=None) # En MB
     max_tam_archivo     = IntCol(default=None) # En MB
@@ -341,13 +348,24 @@ class Comando(InheritableSQLObject): #{{{
     archivos_entrada    = BLOBCol(default=None) # ZIP con archivos de entrada
                                                 # __stdin__ es caso especial
     archivos_a_comparar = BLOBCol(default=None) # ZIP con archivos de salida
-                                                # __stdout__ y __stderr__
+                                                # __stdout__, __stderr__ y
+                                                # __stdouterr__ (ambos juntos)
                                                 # son casos especiales
-    archivos_a_guardar  = TupleCol(notNone=True, default=())
-                                                # __stdout__ y __stderr__
+    archivos_a_guardar  = TupleCol(notNone=True, default=()) # TODO SetCol
+                                                # __stdout__, __stderr__ y
+                                                # __stdouterr__ (ambos juntos)
                                                 # son casos especiales
     activo              = BoolCol(notNone=True, default=True)
 
+    def _get_guardar_stdout(self):
+        return self.STDOUT in self.archivos_a_guardar
+
+    def _get_guardar_stderr(self):
+        return self.STDERR in self.archivos_a_guardar
+
+    def _get_guardar_stdouterr(self):
+        return self.STDOUTERR in self.archivos_a_guardar
+
     def __repr__(self, clave='', mas=''):
         return ('%s(%s comando=%s, descripcion=%s, retorno=%s, '
             'max_tiempo_cpu=%s, max_memoria=%s, max_tam_archivo=%s, '
@@ -358,7 +376,7 @@ class Comando(InheritableSQLObject): #{{{
                     self.max_memoria, self.max_tam_archivo,
                     self.max_cant_archivos, self.max_cant_procesos,
                     self.max_locks_memoria, self.terminar_si_falla,
-                    self.rechazar_si_falla))
+                    self.rechazar_si_falla, mas))
 
     def shortrepr(self):
         return '%s (%s)' % (self.comando, self.descripcion)
@@ -798,7 +816,7 @@ class ComandoEjecutado(InheritableSQLObject): #{{{
     def __repr__(self, clave='', mas=''):
         return ('%s(%s inicio=%s, fin=%s, exito=%s, observaciones=%s%s)'
             % (self.__class__.__name__, clave, self.inicio, self.fin,
-            self.exito, self.observaciones))
+            self.exito, self.observaciones, mas))
 #}}}
 
 class ComandoFuenteEjecutado(ComandoEjecutado): #{{{