Clickx 47/Clickx 47.iso/assets/software/Miro_Installer.exe/Miro_Downloader.exe/dl_daemon/command.pyc

Python Compiled Bytecode | 2008-01-10 | 10.1 KB | 274 lines

# Source Generated with Decompyle++
# File: in.pyc (Python 2.5)

import time
import random
import socket
import eventloop
import logging
DAEMONIC_THREAD_TIMEOUT = 2

class Command:

    def __init__(self, daemon, *args, **kws):
        self.id = 'cmd%08d' % random.randint(0, 99999999)
        self.orig = True
        self.args = args
        self.kws = kws
        self.daemon = daemon


    def setDaemon(self, daemon):
        self.daemon = daemon


    def send(self, callback = None):
        if self.daemon.shutdown:
            return None

        (None, eventloop.addIdle)((lambda : self.daemon.send(self, callback)), 'sending command %s' % repr(self))


    def setReturnValue(self, ret):
        self.orig = False
        self.ret = ret


    def getReturnValue(self):
        return self.ret


    def action(self):
        logging.warning('no action defined for command %s', self.id)


    def __getstate__(self):
        out = {
            'id': self.id,
            'args': self.args,
            'kws': self.kws,
            'orig': self.orig }

        try:
            out['ret'] = self.ret
        except AttributeError:
            pass

        return out


    def __setstate__(self, data):
        self.id = data['id']
        self.kws = data['kws']
        self.args = data['args']
        self.orig = data['orig']

        try:
            self.ret = data['ret']
        except KeyError:
            pass




class FindHTTPAuthCommand(Command):

    def action(self):
        import httpauth
        id = self.args[0]
        args = self.args[1:]

        def callback(authHeader):
            c = GotHTTPAuthCommand(self.daemon, id, authHeader)
            c.send()

        httpauth.findHTTPAuth(callback, *args)



class AskForHTTPAuthCommand(Command):

    def action(self):
        import httpauth
        id = self.args[0]
        args = self.args[1:]

        def callback(authHeader):
            c = GotHTTPAuthCommand(self.daemon, id, authHeader)
            c.send()

        httpauth.askForHTTPAuth(callback, *args)



class UpdateDownloadStatus(Command):

    def action(self):
        RemoteDownloader = RemoteDownloader
        import downloader
        return RemoteDownloader.updateStatus(*self.args, **self.kws)



class BatchUpdateDownloadStatus(Command):

    def action(self):
        RemoteDownloader = RemoteDownloader
        import downloader
        for status in self.args[0]:
            RemoteDownloader.updateStatus(status)




class DownloaderErrorCommand(Command):

    def action(self):
        import util
        util.failed('In Downloader process', details = self.args[0])



class ShutDownResponseCommand(Command):

    def action(self):
        self.daemon.shutdownResponse()



class InitialConfigCommand(Command):

    def action(self):
        import config
        download = download
        import dl_daemon
        config.setDictionary(*self.args, **self.kws)
        download.configReceived()



class UpdateConfigCommand(Command):

    def action(self):
        import config
        config.updateDictionary(*self.args, **self.kws)



class StartNewDownloadCommand(Command):

    def action(self):
        download = download
        import dl_daemon
        return download.startNewDownload(*self.args, **self.kws)



class StartDownloadCommand(Command):

    def action(self):
        download = download
        import dl_daemon
        return download.startDownload(*self.args, **self.kws)



class PauseDownloadCommand(Command):

    def action(self):
        download = download
        import dl_daemon
        return download.pauseDownload(*self.args, **self.kws)



class StopDownloadCommand(Command):

    def action(self):
        download = download
        import dl_daemon
        return download.stopDownload(*self.args, **self.kws)



class StopUploadCommand(Command):

    def action(self):
        download = download
        import dl_daemon
        return download.stopUpload(*self.args, **self.kws)



class GetDownloadStatusCommand(Command):

    def action(self):
        download = download
        import dl_daemon
        return download.getDownloadStatus(*self.args, **self.kws)



class RestoreDownloaderCommand(Command):

    def action(self):
        download = download
        import dl_daemon
        return download.restoreDownloader(*self.args, **self.kws)



class MigrateDownloadCommand(Command):

    def action(self):
        download = download
        import dl_daemon
        return download.migrateDownload(*self.args, **self.kws)



class GotHTTPAuthCommand(Command):

    def action(self):
        (id, authHeader) = self.args
        import httpauth
        httpauth.handleHTTPAuthResponse(id, authHeader)



class ShutDownCommand(Command):

    def response_sent(self):
        import eventloop
        eventloop.quit()
        logging.info('Shutdown complete')


    def action(self):
        starttime = time.time()
        download = download
        import dl_daemon
        download.shutDown()
        import threading
        eventloop.threadPoolQuit()
        for thread in threading.enumerate():
            if thread != threading.currentThread() and not thread.isDaemon():
                thread.join()
                continue

        endtime = starttime + DAEMONIC_THREAD_TIMEOUT
        for thread in threading.enumerate():
            if thread != threading.currentThread():
                timeout = endtime - time.time()
                if timeout <= 0:
                    break

                thread.join(timeout)
                continue

        c = ShutDownResponseCommand(self.daemon)
        c.send(callback = self.response_sent)
        self.daemon.shutdown = True