Function cdb2_connect_sqlhost

cdb2api/cdb2api.c:2702–2754

}

static int cdb2_connect_sqlhost(cdb2_hndl_tp *hndl)
{
    if (hndl->flags & CDB2_TYPE_IS_FD) {
        return newsql_connect_via_fd(hndl);
    }

    if (hndl->sb) {
        newsql_disconnect(hndl, hndl->sb, __LINE__);
    }

    int requery_done = 0;

retry_connect:
    debugprint("node_seq=%d flags=0x%x, num_hosts=%d, num_hosts_sameroom=%d\n",
               hndl->node_seq, hndl->flags, hndl->num_hosts,
               hndl->num_hosts_sameroom);

    if ((hndl->node_seq == 0) &&
        ((hndl->flags & CDB2_RANDOM) || ((hndl->flags & CDB2_RANDOMROOM) &&
                                         (hndl->num_hosts_sameroom == 0)))) {
        hndl->node_seq = getRandomExclude(hndl->num_hosts, hndl->master);
    } else if ((hndl->flags & CDB2_RANDOMROOM) && (hndl->node_seq == 0) &&
               (hndl->num_hosts_sameroom > 0)) {
        hndl->node_seq =
            getRandomExclude(hndl->num_hosts_sameroom, hndl->master);
        /* First try on same room. */
        if (0 == cdb2_try_connect_range(hndl, hndl->node_seq,
                                        hndl->num_hosts_sameroom))
            return 0;
    }

    if (0 == cdb2_try_connect_range(hndl, hndl->node_seq, hndl->num_hosts))
        return 0;

    if (hndl->sb == NULL) {
        /* Can't connect to any of the non-master nodes, try connecting to
         * master.*/
        /* After this retry on other nodes. */
        bzero(hndl->hosts_connected, sizeof(hndl->hosts_connected));
        if (newsql_connect(hndl, hndl->master) == 0)
            return 0;
    }

    /* Can't connect to any of the nodes, re-check information about db. */
    if (!(hndl->flags & CDB2_DIRECT_CPU) && requery_done == 0 &&
        cdb2_get_dbhosts(hndl) == 0) {
        requery_done = 1;
        goto retry_connect;
    }

    hndl->connected_host = -1;
    return -1;
}

static inline void ack(cdb2_hndl_tp *hndl)
{