gtp_engine.py 文件源码

def _run_gtp_session(engine, read, write):
    while True:
        try:
            line = read()
        except EOFError:
            break
        response, end_session = engine.handle_line(line)
        if response is not None:
            try:
                write(response)
            except IOError, e:
                if e.errno == errno.EPIPE:
                    raise ControllerDisconnected(*e.args)
                else:
                    raise
        if end_session:
            break