casa5

import os

import sys

import subprocess

from subprocess import Popen

from enum import Enum

from time import sleep, localtime, strftime

from threading import Thread

import crashrpt_conf

​

from casa_shutdown import add_shutdown_hook

​

class output_option(Enum):

    PIPE = 1

    STDOUT = 2

    DISCARD = 3

​

​

##

##  dgtool's pylot class was a useful reference for creating this class:

##  http://dgtool.treitos.com/2012/05/python-subprocess-manager-pylot.html

##

class procmgr(Thread):

​

    from procmgr import output_option

​

    class proc(Thread):

        def __init__(self, tag, cmd, output=output_option.DISCARD):

            """ tag: identification for this process

            cmd: list of strings representing the command followed by the arguments

            output: disposition of output STDOUT, PIPE, DISCARD (default is to discard output)"""

            Thread.__init__(self)

            self.tag = tag

            self.pid = None

            self.stderr = None

            self.stdout = None

            self.stdin  = None

            self.__cmd = cmd

            self.__output_option = output

            self.__running = False

            self.__proc = None

            self.__watchdog = None

​

        def stop(self):

            """ stop( ) -> None

            stops the process if it is running"""

            if self.__running:

                self.__running = False

                if self.__proc and self.__proc.poll( ) == None:

                    #print "%s => proc %s is being stopped" % (strftime("%y-%m-%d %H:%M:%S", localtime()), self.tag)

                    try:

                        self.__proc.terminate()

                        sleep(0.5)

                        if self.__proc.poll( ) is None:

                            print "%s => proc %s is being killed" % (strftime("%y-%m-%d %H:%M:%S", localtime()), self.tag)

                            self.__proc.kill()

                        if self.__watchdog.poll( ) is None:

                            self.__watchdog.kill()

                    except OSError:

                        pass

​

        def running(self):

            """ running( ) -> Bool

             check to see if the process is still running"""