

def message_pump_greenthread(connection):
    logging.debug('Starting message pump')
    exit_code = 0
    try:
        while (exit_code is not None):
            connection.read_frames()
            gevent.sleep()
    except Exception as exc:
        logger.exception(exc)
        exit_code = 1
    finally:
        logging.debug('Leaving message pump')
    return exit_code

dataset/ETHPy150Open seatgeek/cronq/cronq/runner.py message_pump_greenthread/VarMisuse@27/42 `connection`->`exit_code`