mDNS.py 文件源码

def socket_handler(self, queue, running):
        self.logger = logging.getLogger("mDNSResponder.schedule_handler")
        self.logger.info("PID: %s" % os.getpid())
        register_worker_signal_handler(self.logger)
        while running.value:
            try:
                ready = select.select([self.multi_sock], [], [], 10)
                for sock in ready[0]:
                    rec = sock.recvfrom(self.buffer_size, socket.MSG_DONTWAIT)
                    self.logger.log(0, rec)
                    queue.put(rec)
            except socket.error as se:
                pass
            except Exception as e:
                self.logger.exception("Message")
            except KeyboardInterrupt as ki:
                time.sleep(1)

        for sock in self.socks:
            sock.close()
        self.multi_sock.close()
        self.logger.warn("Socket Handler shutting down...")