python类__init__()的实例源码

def __init__(self, cmd_queue, commands, config, sessions, *args, **kwargs):
        """
        Constructor.
        """
        # Commands queue.
        self.cmd_queue = cmd_queue
        # Commands array in shared memory.
        self.commands = commands
        # Sessions array in shared memory.
        self.sessions = sessions
        # Configuration instance.
        self.config = config
        # HTTP server version.
        self.server_version = "temboard-agent/0.0.1"
        # HTTP request method
        self.http_method = None
        # HTTP query.
        self.query = None
        # HTTP POST content in json format.
        self.post_json = None
        # Call HTTP request handler constructor.
        BaseHTTPRequestHandler.__init__(self, *args, **kwargs)

def __init__(self, device, conf):
        super(EspSender, self).__init__()
        self.daemon = True

        self.conf = conf

        self.debugAck = self.conf.ESP_FORCE_ACK_DEBUG

        self.out_queue = Queue.Queue()
        self.signal_queue = Queue.Queue()

        self.device = device
        self.ip = str(self.conf.ipNetwork[device])

        self.last_send = -1

        self.pin_values = {}

        print "#" + str(device) + " UDP to " + str(self.ip)

def __init__(self, device, conf):
        super(EspHandler, self).__init__()
        self.daemon = True

        self.conf = conf

        self.sender = None

        self.device = None
        self.in_queue = None
        self.pin_last_command = {}

        if (device > 0) and (self.conf.ipNetwork is not None) and (device < self.conf.ipNetwork.size):
            self.device = device

            self.sender = EspSender(device, self.conf)
            self.sender.start()

            self.in_queue = Queue.Queue()
            print "#" + str(device) + " Handler to " + str(self.getIp())
        else:
            print "#" + str(device) + " Invalid device or net: " + str(self.conf.ipNetwork)

def __init__(self, *args, **kwargs):
        self.tls = threading.local()
        self.version_table = {10: 'HTTP/1.0', 11: 'HTTP/1.1'}
        self.http_request = HTTPRequest()

        # Address to time series backend
        backend_host, backend_port = self.backend_address
        self.backend_netloc = "{}:{}".format(backend_host, backend_port)

        self.path = None
        self.connection = None
        self.rfile = None
        self.wfile = None
        self.close_connection = 0

        BaseHTTPRequestHandler.__init__(self, *args, **kwargs)

def __init__(self, request, client_address, server):
        BaseHTTPRequestHandler.__init__(self, request, client_address, server)

def __init__(self, *args, **kwargs):
        self.tls = threading.local()
        self.tls.conns = {}
        BaseHTTPRequestHandler.__init__(self, *args, **kwargs)

def __init__(self, resources, *args, **kwargs):
        """
        :arg resources: A dict of resource paths pointing to content bytes

        """
        self.resources = resources
        BaseHTTPRequestHandler.__init__(self, *args, **kwargs)

def __init__(self, config, duration, errors, *args, **kwargs):
        self._config = config
        self._duration = duration
        self._errors = errors
        BaseHTTPRequestHandler.__init__(self, *args, **kwargs)

def __init__(self, request, client_address, server):
        BaseHTTPRequestHandler.__init__(self, request, client_address, server)

def __init__(self, server_address, RequestHandlerClass, thread = {}):
        HTTPServer.__init__(self,  server_address, RequestHandlerClass)
        self.thread = thread

def __init__(self, name=None):
        Thread.__init__(self, name=name)
        self.daemon = True
        self.event = Event()
        self.degree = 90
        self.direction = None
        self.servo = ServoSG90()
        self.channel = {'left':0, 'right':1, 'middle':2, 'claw':3}
        self.name = name

        self.servo.set_pwm_freq(60)
        self.servo.set_degree(self.channel[name], 90)

def __init__(self, resources, *args, **kwargs):
        """
        :arg resources: A dict of resource paths pointing to content bytes

        """
        self.resources = resources
        BaseHTTPRequestHandler.__init__(self, *args, **kwargs)

def __init__(self, request, client_address, server):
        self.tls = threading.local()
        self.tls.conns = {}
        BaseHTTPRequestHandler.__init__(self, request, client_address, server)

    # noinspection PyShadowingBuiltins

def __init__(self, conf):
        super(EspNetHandler, self).__init__()
        self.daemon = True

        self.conf = conf
        self.debugAck = self.conf.ESP_FORCE_ACK_DEBUG

        self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        self.sock.bind((conf.ESP_LISTEN_IP, self.conf.ESP_LISTEN_PORT))
        print("Listening ESP on " + self.conf.ESP_LISTEN_IP + ":" +
              str(conf.ESP_LISTEN_PORT) + ", sending to :" + str(conf.ESP_PORT))

def MakeHandlerClass(base_url):
    #This class will handles any incoming request from
    #the JMX service
    # Needed during installation of the JAR
    class CustomHandler(BaseHTTPRequestHandler):

        def __init__(self, *args, **kwargs):
             self._base_url = base_url
             BaseHTTPRequestHandler.__init__(self, *args, **kwargs)

        #Handler for the GET requests
        def do_GET(self):
            if self.path=="/":
                mlet_code = '<html><mlet code="de.siberas.lab.SiberasPayload" archive="siberas_mlet.jar" name="Siberas:name=payload,id=1" codebase="' + self._base_url + '"></mlet></html>'

                self.send_response(200)
                self.send_header('Pragma', 'no-cache')
                self.end_headers()
                self.wfile.write(mlet_code)

            elif self.path=="/siberas_mlet.jar":
                f = open("./payloads/siberas_mlet.jar")
                self.send_response(200)
                self.send_header('Content-type', 'application/jar')
                self.end_headers()
                self.wfile.write(f.read())
                f.close()

            else:
                self.send_error(404, 'File not found: ' + self.path)
                #
                # except IOError:
                #   self.send_error(404,'File Not Found: %s' % self.path)

    return CustomHandler

### /INSTALL MODE ###


### UNINSTALL MODE ###

def __init__(self,PORT):
        self.port = PORT
        self.logger = Logger('server.py')
        self.run()

def __init__(self, request, client_address, server):
            self.sqlite = sqlite3.connect(DB_CONFIG['SQLITE'])
            self.table_name = 'proxy'
            BaseHTTPRequestHandler.__init__(self, request, client_address, server)

def __init__(self, request, client_address, server):
        self.timeout = 1

        BaseHTTPRequestHandler.__init__(self, request, client_address, server)

def __init__(self, configfile, pidfile):
        self.configfile = configfile
        self.receiver = None
        self.config = None
        Daemon.__init__(self, pidfile)

def __init__(self, port):
        self.port = int(port)
        self.run()

def __init__(self, request, client_address, server):
            try:
                self.sqlite = DatabaseObject(DB_CONFIG['SQLITE'])
                self.table_name = 'proxy'
            except Exception, e:
                self.sqlite = ''
                logger.error('SQLite error: %s', e)
            BaseHTTPRequestHandler.__init__(self, request, client_address, server)

def __init__(self, port):
        self.port = int(port)
        self.run()

def __init__(self, request, client_address, server):
            try:
                self.sqlite = DatabaseObject(DB_CONFIG['SQLITE'])
                self.table_name = 'proxy'
            except Exception, e:
                self.sqlite = ''
                logger.error('SQLite error: %s', e)
            BaseHTTPRequestHandler.__init__(self, request, client_address, server)

def __init__(self, appRequestHandler, *args, **kwargs):
        self.handleRequest = appRequestHandler
        BaseHTTPRequestHandler.__init__(self, *args, **kwargs)

def __init__(self, *args, **kwargs):
        self.tls = threading.local()
        self.tls.conns = {}
        BaseHTTPRequestHandler.__init__(self, *args, **kwargs)

def __init__(self, config):
        super(AgentApi, self).__init__(config)
        self._enabled = config.fetch('agent', 'enabled', bool)
        self.host = config.fetch('agent', 'host')
        self.port = config.fetch('agent', 'port', int)

def __init__(self, config):
        def handler(*args):
            AgentApiHandler(config, *args)
        server = HTTPServer((config.host, config.port), handler)
        server.serve_forever()

def __init__(self, config, *args):
        self.sender = config.sender
        BaseHTTPRequestHandler.__init__(self, *args)

def __init__(self, filelike, blksize=8192):
        self.filelike = filelike
        self.blksize = blksize
        if hasattr(filelike,'close'):
            self.close = filelike.close

def __init__(self,headers):
        if not isinstance(headers, list):
            raise TypeError("Headers must be a list of name/value tuples")
        self._headers = headers