def _receive(self):
        while True:
            try:
                record = self.queue.get()
                # None is sent as a sentinel to tell the listener to quit
                if record is None:
                    break
                self.logger.handle(record)
            except (KeyboardInterrupt, __HOLE__):
                raise
            except EOFError:
                break
            except:
                traceback.print_exc(file=sys.stderr)
dataset/ETHPy150Open openstack/stacktach/stacktach/stacklog.py/LogListener._receive