Method run

phxsqlproxy/io_routine.cpp:125–172

}

int IORoutine::run() {
    co_enable_hook_sys();

    while (true) {
        if (client_fd_ == -1) {
            io_routine_mgr_->AddIORoutine(this);
            yield();
            continue;
        }

        int byte_size_tot = 0;
        do {
            SetNoDelay(client_fd_);
            int read_proxy_hdr = proxy_protocol_handler_->ProcessProxyHeader(client_fd_);
            if (read_proxy_hdr < 0) {
                LOG_ERR("process proxy protocol failed, ret %d", read_proxy_hdr);
                break;
            }
            LOG_DEBUG("process proxy protocol succ, header size %d", read_proxy_hdr);

            int fd = io_router_->ConnectDest();
            if (fd < 0) {
                LOG_ERR("connect dest failed, ret %d", fd);
                break;
            }
            LOG_DEBUG("connect dest succ, fd %d", fd);
            sqlsvr_fd_ = fd;
            SetNoDelay(sqlsvr_fd_);

            int send_proxy_hdr = proxy_protocol_handler_->SendProxyHeader(sqlsvr_fd_);
            if (send_proxy_hdr < 0) {
                LOG_ERR("send proxy protocol failed, ret %d", send_proxy_hdr);
                break;
            }
            LOG_DEBUG("send proxy protocol succ, header size %d", send_proxy_hdr);

            byte_size_tot = io_channel_->TransMsg(client_fd_, sqlsvr_fd_);
            LOG_DEBUG("trans %d bytes msg in total", byte_size_tot);
        } while (0);

        if (byte_size_tot == 0) {
            io_router_->MarkFailure();
        }

        ClearAll();
    }
    return 0;
}

//IORoutine end