def socket_queue_thread(self):
            try:
                while True:
                    client_socket, address = self.socket_queue.get(True, None)

                    # 'self.io_loop' initialized in super class
                    # 'tornado.tcpserver.TCPServer'.
                    # 'self._handle_connection' defined in same super class.
                    self.io_loop.spawn_callback(
                        self._handle_connection, client_socket, address)
            except (KeyboardInterrupt, __HOLE__):
                pass
dataset/ETHPy150Open saltstack/salt/salt/transport/tcp.py/LoadBalancerWorker.socket_queue_thread