upnp_reciever.py 文件源码

def socket_handler(self, queue, running):
        self.logger = logging.getLogger("UPnPServiceResponder.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)
                    # Don't log packets from out IP Addresses
                    if not rec[1][0] in self.ip_addresses:
                        self.logger.debug(rec)
                    queue.put(rec)
            except socket.error as se:
                pass
            except Exception as e:
                self.logger.error(e)

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