src/HOL/Tools/Sledgehammer/MaSh/src/mash.py

MaSh error handling

#!/usr/bin/env python
#     Title:      HOL/Tools/Sledgehammer/MaSh/src/mash
#     Author:     Daniel Kuehlwein, ICIS, Radboud University Nijmegen
#     Copyright   2012 - 2013
#
# Entry point for MaSh (Machine Learning for Sledgehammer).

'''
MaSh - Machine Learning for Sledgehammer

MaSh allows to use different machine learning algorithms to predict relevant fact for Sledgehammer.

Created on July 12, 2012

@author: Daniel Kuehlwein
'''

import socket,sys,time,logging,os
from os.path import realpath,dirname

from spawnDaemon import spawnDaemon
from parameters import init_parser

def communicate(data,host,port):
    logger = logging.getLogger('communicate')
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)    
    try:
        sock.connect((host,port))
        sock.sendall(data+'\n')        
        received = ''
        cont = True
        counter = 0
        while cont and counter < 100000:
            rec = sock.recv(4096)
            if rec.endswith('stop'):
                cont = False
                received += rec[:-4]
            else:
                received += rec
            counter += 1
        if rec == '':
            logger.warning('No response from server. Check server log for details.')
    except:        
        logger.warning('Communication with server failed.')
        received = -1
    finally:
        sock.close()    
    return received

def start_server(host,port):
    logger = logging.getLogger('start_server')
    logger.info('Starting Server.')
    path = dirname(realpath(__file__))
    spawnDaemon(os.path.join(path,'server.py'),os.path.join(path,'server.py'),host,str(port))
    serverIsUp=False
    for _i in range(20):
        # Test if server is up
        try:
            sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
            sock.connect((host,port))       
            sock.close()
            serverIsUp = True
            break
        except:
            time.sleep(0.5)
    if not serverIsUp:
        logger.error('Could not start server.')
        sys.exit(-1)
    return True

def mash(argv = sys.argv[1:]):
    # Initializing command-line arguments
    args = init_parser(argv)
    # Set up logging
    logging.basicConfig(level=logging.DEBUG,
                        format='%(asctime)s %(name)-12s %(levelname)-8s %(message)s',
                        datefmt='%d-%m %H:%M:%S',
                        filename=args.log,
                        filemode='w')    
    logger = logging.getLogger('mash')

    if args.quiet:
        logger.setLevel(logging.WARNING)
    else:
        console = logging.StreamHandler(sys.stdout)
        console.setLevel(logging.INFO)
        formatter = logging.Formatter('# %(message)s')
        console.setFormatter(formatter)
        logging.getLogger('').addHandler(console)
        
    if not os.path.exists(args.outputDir):
        os.makedirs(args.outputDir)

    # Shutdown commands need not start the server fist.
    if args.shutdownServer:
        logger.info('Sending shutdown command.')
        try:
            received = communicate('shutdown',args.host,args.port)
            logger.info(received)
        except:
            pass
        return

    # If server is not running, start it.
    startedServer = False
    received = communicate(' '.join(('ping',args.modelFile,args.dictsFile)),args.host,args.port)
    if received == -1:
        startedServer = start_server(args.host,args.port)
    elif received.startswith('Files do not match'):
        logger.error('Filesnames do not match!')
        logger.error('Modelfile server: '+ received.split()[-2])
        logger.error('Modelfile argument: '+ args.modelFile)
        logger.error('Dictsfile server: '+ received.split()[-1])
        logger.error('Dictsfile argument: '+ args.dictsFile)
        return
    
    if args.init or startedServer:
        logger.info('Initializing Server.')
        data = "i "+";".join(argv)
        received = communicate(data,args.host,args.port)
        logger.info(received)     
    
    if not args.inputFile == None:
        logger.debug('Using the following settings: %s',args)
        # IO Streams
        OS = open(args.predictions,'w')
        IS = open(args.inputFile,'r')
        lineCount = 0
        for line in IS:
            lineCount += 1
            if lineCount % 100 == 0:
                logger.info('On line %s', lineCount)
            received = communicate(line,args.host,args.port)
            if not received == '':
                OS.write('%s\n' % received)
        OS.close()
        IS.close()
        
        # Statistics
        if args.statistics:
            received = communicate('avgStats',args.host,args.port)
            logger.info(received)

    if args.saveModels:
        communicate('save',args.host,args.port)


if __name__ == "__main__":
    sys.exit(mash())