X-Git-Url: https://git.llucax.com/software/sercom-old.git/blobdiff_plain/727acb5562491fcd2ffb88d31caec867e7dbef49..219f7ebe037bf26449f4d211cdf7b486fb8b847c:/src/sc_test?ds=sidebyside diff --git a/src/sc_test b/src/sc_test index c06f4e9..34402ff 100755 --- a/src/sc_test +++ b/src/sc_test @@ -4,36 +4,29 @@ # Módulos estándar import os -import sys import pwd import time import signal -import locale import shutil import datetime -import logging -import logging.config import subprocess -import ConfigParser -# Módulos externos -import sqlobject # Módulos locales +import sercom from sercom.dbo import * -class secure: +class secure_process: def __init__(self, chroot, uid, gid, cpu): self.chroot = chroot self.uid = uid self.gid = gid self.cpu = cpu def __call__(self): - def x2(val): - return (val, val) from os import chroot, setuid, setgid import resource chroot(self.chroot) setgid(self.gid) setuid(self.uid) + x2 = lambda val: (val, val) # Devuelve una tupla con val 2 veces resource.setrlimit(resource.RLIMIT_AS, x2(20*1024*1024)) resource.setrlimit(resource.RLIMIT_CORE, x2(0)) resource.setrlimit(resource.RLIMIT_CPU, x2(self.cpu)) @@ -44,14 +37,6 @@ class secure: resource.setrlimit(resource.RLIMIT_NOFILE, x2(100)) resource.setrlimit(resource.RLIMIT_NPROC, x2(0)) -def logger(): - log = None - for log_conf in ('log.ini', os.path.expanduser('~/.sercom/log.ini'), '/etc/sercom/log.ini'): - if (os.access(log_conf, os.R_OK)): - logging.config.fileConfig(log_conf) - log = logging.getLogger('test') - return log - def sigchld(signum, frame): """Signal handler para SIGCHILD.""" #global hijo_muerto @@ -64,40 +49,133 @@ def sigterm(signum, frame): continuar = False log.debug('Señal %d recibida', signum) +def compilar(intento, intento_dir, entrega_dir, log): + # Busco makefile + makefile = os.path.join(entrega_dir, 'Makefile') + if not os.path.exists(makefile): + makefile = os.path.join(data_dir, 'Makefile') + shutil.copy(makefile, intento_dir) + # Compilo + log.debug('Ejecutando: make -f %s', makefile) + intento.inicioCompila = datetime.datetime.now() + make = subprocess.Popen(('make', '-f', makefile), stdout=subprocess.PIPE, + stderr=subprocess.PIPE, cwd=intento_dir) + make.wait() + intento.finCompila = datetime.datetime.now() + log.debug('Fin del comando: make -f %s', makefile) + # Verifico compilación + if make.returncode: + log.debug('Error al compilar, código de retorno: %d, salida estándar: ' + '%s, salida de error: %s)', make.returncode, make.stdout.read(), + make.stderr.read()) + intento.compila = False + #TODO enviar_respuesta(R_ERR, $mail, "ERROR AL COMPILAR!\n\n$err\n\nCódigo de retorno: $ret\n", $intento); + return False + log.debug('Compilado OK') + intento.compila = True + #TODO mail acumulativo + return True -# Seteo locale -locale.setlocale(locale.LC_ALL, '') - -# Obtengo configuración -conf = ConfigParser.SafeConfigParser() -if not conf.read(('/etc/sercom/sercom.ini', os.path.expanduser('~/.sercom/sercom.ini'), 'sercom.ini')): - sys.stderr.write('No se pudo obtener configuración!\n') - sys.exit(1) - -# Obtengo id de usuario con el cual ejecutar las pruebas -(uid, gid) = pwd.getpwnam(conf.get('general', 'user'))[2:4] - -# Cambio UID efectivo -os.seteuid(uid) +def preparar(intento_dir, chroot_dir): + # Creo chroot - TODO copiarlo de algún lado donde ande el valgrind? + ejecutable = os.path.join(chroot_dir, 'tp') + os.mkdir(chroot_dir) + shutil.move(os.path.join(intento_dir, 'tp'), ejecutable) -# Seteo umask para que el grupo pueda leer -os.umask(00027) +def probar(intento, caso_de_prueba, uid, gid, chroot_dir, conf, conn, log): + # Obtengo datos útiles del caso de prueba + tiempo_cpu = caso_de_prueba.tiempoCpu + if tiempo_cpu is None: + tiempo_cpu = conf.get('general', 'tiempo_cpu') + tiempo_cpu = int(tiempo_cpu) + # Creo prueba nueva + prueba = Prueba(intento=intento, casoDePrueba=caso_de_prueba, + inicio=datetime.datetime.now(), connection = conn) + log.debug('Prueba: %s', prueba) + # Abro archivos para fds básicos + #XXX sacar nombres de archivos de prueba???? + #stdin = file(os.path.join(intento_dir, 'stdin'), 'r') + stdout = file(os.path.join(intento_dir, 'stdout'), 'w') + stderr = file(os.path.join(intento_dir, 'stderr'), 'w') + # Ejecuto programa + log.debug('Ejecutando /tp %s', caso_de_prueba.parametros) + os.seteuid(0) # Dios! (para chroot) + # FIXME caso_de_prueba.parametros + try: + proc = subprocess.Popen('/tp', stdout=stdout, stderr=stderr, #stdin=stdin, + preexec_fn=secure_process(chroot_dir, uid, gid, tiempo_cpu)) + except Exception, e: # FIXME poner en el manejo de exceptiones estandar + try: + print e.child_traceback + raise + except: + raise + os.seteuid(uid) # Mortal de nuevo + time.sleep(tiempo_cpu) + # Si el proceso sigue andando lo tenemos que matar + if proc.poll() is None: + log.debug('La prueba tardó más del tiempo permitido (%d segundos)', + tiempo_cpu) + os.seteuid(0) # Dios! (corre como Dios, hay que matarlo como Dios) + os.kill(proc.pid, signal.SIGKILL) + os.seteuid(uid) # Mortal de nuevo + log.debug('Prueba cancelada (kill)') + proc.wait() + prueba.observaciones = 'Excedió el límite de tiempo de ejecución ' \ + '(%d seg)' % tiempo_cpu + prueba.fin = datetime.datetime.now() + prueba.pasada = False + return prueba + proc.wait() # Para que no queden zombies + prueba.fin = str(datetime.datetime.now()) + # Salió con una señal? + if proc.returncode < 0: + sig = -proc.returncode + log.debug('El programa salió con la señal %d', sig) + prueba.pasada = False + #TODO otras señales conocidas + if sig == signal.SIGXCPU: + prueba.observaciones = 'Excedió el límite de tiempo de CPU ' \ + '(%d seg)' % tiempo_cpu + else: + prueba.observaciones = 'Salió con la señal %d' % sig + return prueba + # Si tenemos que verificar el código de retorno + if caso_de_prueba.codigoRetorno is not None: + #FIXME trucho lo de 256 + # Si el código de error esperado es 256 => el código de error debe ser != 0 + # Si no el código de error esperado debe ser igual al obtenido + if caso_de_prueba.codigoRetorno != proc.returncode \ + or caso_de_prueba.codigoRetorno == 256 \ + and proc.returncode != 0: + log.debug('Código de retorno incorrecto (debía ser %d y se obtuvo %d)', + caso_de_prueba.codigoRetorno, proc.returncode) + prueba.pasada = False + prueba.observaciones = 'Código de retorno incorrecto (debía ' \ + 'ser %d y se obtuvo %d)' % (caso_de_prueba.codigoRetorno, + proc.returncode) + #TODO verificar salidas, hacer diff + log.debug('Fin de ejecución de caso de prueba (hijo: %d, ret: %d)', + proc.pid, proc.returncode) + prueba.pasada = True + log.debug('Prueba OK: %s', prueba) + return prueba # Conecto señales signal.signal(signal.SIGCHLD, sigchld) signal.signal(signal.SIGTERM, sigterm) signal.signal(signal.SIGINT, sigterm) -# Conexión a la DB -conn = sqlobject.connectionForURI(conf.get('dbo', 'database')) - -# Cargo config del logger -log = logger() -if not log: - print >>sys.stderr, 'No se pudo cargar archivo de configuración de log.' - sys.exit(1) +# Inicializo +conf, conn, log = sercom.init('test') log.info('Iniciado') +# Obtengo id de usuario con el cual ejecutar las pruebas +(uid, gid) = pwd.getpwnam(conf.get('general', 'user'))[2:4] + +# Cambio UID efectivo +os.seteuid(uid) + # Algunas variables de configuración útiles data_dir = conf.get('general', 'data_dir') intervalo = float(conf.get('general', 'intervalo')) @@ -115,124 +193,21 @@ while continuar: # Obtengo paths intento_dir = os.path.join(data_dir, intento.path('intentos')) entrega_dir = os.path.join(data_dir, 'ejercicios', str(intento.entrega.ejercicioID)) - print entrega_dir - # Busco makefile - makefile = os.path.join(entrega_dir, 'Makefile') - if not os.path.exists(makefile): - makefile = os.path.join(data_dir, 'Makefile') - shutil.copy(makefile, intento_dir) - # Compilo - log.debug('Ejecutando: make -f %s', makefile) - intento.inicioCompila = datetime.datetime.now() - make = subprocess.Popen(('make', '-f', makefile), stdout=subprocess.PIPE, - stderr=subprocess.PIPE, cwd=intento_dir) - make.wait() - intento.finCompila = datetime.datetime.now() - log.debug('Fin del comando: make -f %s', makefile) - # Verifico compilación - if make.returncode: - log.debug('Error al compilar, código de retorno: %d, salida estándar: ' - '%s, salida de error: %s)', make.returncode, make.stdout.read(), - make.stderr.read()) - intento.compila = False - #TODO enviar_respuesta(R_ERR, $mail, "ERROR AL COMPILAR!\n\n$err\n\nCódigo de retorno: $ret\n", $intento); - continue; - else: - log.debug('Compilado OK') - intento.compila = True - #TODO mail acumulativo - # Creo chroot - TODO copiarlo de algún lado donde ande el valgrind? chroot_dir = os.path.join(intento_dir, 'chroot') - ejecutable = os.path.join(chroot_dir, 'tp') - os.mkdir(chroot_dir) - shutil.move(os.path.join(intento_dir, 'tp'), ejecutable) - # Cambio permisos - XXX al pedo? Hice seteuid() - os.chmod(chroot_dir, 02770) - os.chown(chroot_dir, uid, gid) - os.chmod(ejecutable, 0550) - os.chown(ejecutable, uid, gid) + # Compila + if not compilar(intento, intento_dir, entrega_dir, log): + continue + # Prepara archivos + preparar(intento_dir, chroot_dir) # Ejecución de casos de prueba intento.inicioPruebas = datetime.datetime.now() + pruebas = [] for caso_de_prueba in intento.entrega.ejercicio.casosDePrueba: - # Obtengo datos útiles del caso de prueba - tiempo_cpu = caso_de_prueba.tiempoCpu - if tiempo_cpu is None: - tiempo_cpu = conf.get('general', 'tiempo_cpu') - tiempo_cpu = int(tiempo_cpu) - # Creo prueba nueva - prueba = Prueba(intento=intento, casoDePrueba=caso_de_prueba, - inicio=datetime.datetime.now(), connection = conn) - log.debug('Prueba: %s', prueba) - # Abro archivos para fds básicos - #XXX sacar nombres de archivos de prueba???? - #stdin = file(os.path.join(intento_dir, 'stdin'), 'r') - stdout = file(os.path.join(intento_dir, 'stdout'), 'w') - stderr = file(os.path.join(intento_dir, 'stderr'), 'w') - # Ejecuto programa - log.debug('Ejecutando /tp %s', caso_de_prueba.parametros) - os.seteuid(0) # Dios! (para chroot) - # FIXME caso_de_prueba.parametros - try: - proc = subprocess.Popen('/tp', stdout=stdout, stderr=stderr, #stdin=stdin, - preexec_fn=secure(chroot_dir, uid, gid, tiempo_cpu)) - except Exception, e: # FIXME poner en el manejo de exceptiones estandar - try: - print e, e.child_traceback - except: - print e - os.seteuid(uid) # Mortal de nuevo - time.sleep(tiempo_cpu) - # Si el proceso sigue andando lo tenemos que matar - if proc.poll() is None: - log.debug('La prueba tardó más del tiempo permitido (%d segundos)', - tiempo_cpu) - os.seteuid(0) # Dios! (corre como Dios, hay que matarlo como Dios) - os.kill(proc.pid, signal.SIGKILL) - os.seteuid(uid) # Mortal de nuevo - log.debug('Prueba cancelada (kill)') - proc.wait() - prueba.observaciones = 'Excedió el límite de tiempo de ejecución ' \ - '(%d seg)' % tiempo_cpu - prueba.fin = datetime.datetime.now() - prueba.pasada = False - continue - proc.wait() # Para que no queden zombies - prueba.fin = str(datetime.datetime.now()) - # Salió con una señal? - if proc.returncode < 0: - sig = -proc.returncode - log.debug('El programa salió con la señal %d', sig) - prueba.pasada = False - #TODO otras señales conocidas - if sig == signal.SIGXCPU: - prueba.observaciones = 'Excedió el límite de tiempo de CPU ' \ - '(%d seg)' % tiempo_cpu - else: - prueba.observaciones = 'Salió con la señal %d' % sig - continue - # Si tenemos que verificar el código de retorno - if caso_de_prueba.codigoRetorno is not None: - #FIXME trucho lo de 256 - # Si el código de error esperado es 256 => el código de error debe ser != 0 - # Si no el código de error esperado debe ser igual al obtenido - if caso_de_prueba.codigoRetorno != proc.returncode \ - or caso_de_prueba.codigoRetorno == 256 \ - and proc.returncode != 0: - log.debug('Código de retorno incorrecto (debía ser %d y se obtuvo %d)', - caso_de_prueba.codigoRetorno, proc.returncode) - prueba.pasada = False - prueba.observaciones = 'Código de retorno incorrecto (debía ' \ - 'ser %d y se obtuvo %d)' % (caso_de_prueba.codigoRetorno, - proc.returncode) - #TODO verificar salidas, hacer diff - log.debug('Fin de ejecución de caso de prueba (hijo: %d, ret: %d)', - proc.pid, proc.returncode) - prueba.pasada = True - log.debug('Prueba OK: %s', prueba) + pruebas.append(probar(intento, caso_de_prueba, uid, gid, chroot_dir, conf, conn, log)) intento.finPruebas = datetime.datetime.now() #TODO make clean #TODO Armar mail de respuesta al alumno - for prueba in Prueba.selectBy(intentoID=intento.id, connection=conn): + for prueba in pruebas: #TODO Si es publica, veo si se hizo ok o no y voy creando mail pass time.sleep(intervalo)