zorroSkulkManager.py 文件源码

def __init__(self, inputQueue=None ):
        QtCore.QThread.__init__(self)

        self.verbose = 3
        self.DEBUG = False

        # Processible file extensions
        self.globPattern = ['*.dm4', '*.dm3', '*.mrc', '*.mrcz', '*.tif', '*.tiff',
                            '*.mrcs', '*.mrcsz', '*.hdf5', '*.h5', '*.bz2', '*.gz', '*.7z' ]

        # Default object for copying the parameters (also accessed by Automator)    
        self.zorroDefault = zorro.ImageRegistrator()

        # Mutex-protected queues of the image stacks to be worked on
        self.__globalHeap = skulkHeap()
        self.__newHeap = skulkHeap()
        self.__syncHeap = skulkHeap()
        self.__procHeap = skulkHeap()
        self.__archiveHeap = skulkHeap()
        self.completedCount = 0

        # Messages from the hosts to the skulkManager (i.e. I've finished, or, I've fallen and I can't get up again)
        # This is unidirectional from the hosts to the skulk manager
        self.messageQueue = queue.Queue(maxsize=0) 

        # Servers that will accept jobs, is a dict of skulkHosts
        self.procHosts = {}
        self.syncHosts = {}
        self.archiveHosts = {}

        # Path manager, for keeping real and normed paths manageable.  
        self.paths = skulkPaths()

        # TODO: Do we want Paramiko for running remote jobs via SSH?  Or restrict ourselves to qsub locally?
        # https://github.com/paramiko/paramiko
        # It's not in Anaconda by default, but it's in both conda and pip

        self.__STOP_POLLING = False
        # bytes, should be bigger than Digital Micrograph header size, but smaller than any conceivable image

        self.sleepTime = 1.0
        pass