Function list_all_sql_pools_func

db/sqlpool.c:264–294

}

static int list_all_sql_pools_func(void *obj, void *arg)
{
    pool_entry_t *entry = (pool_entry_t *)obj;
    if (entry == NULL) return 0;
    struct thdpool *pool = entry->pPool;
    pool_foreach_data_t *data = (pool_foreach_data_t *)arg;
    SBUF2 *sb = (data != NULL) ? data->sb : NULL;
    if (sb != NULL) {
        /* NOTE: Being called from comdb2_save_ruleset(), use SBUF. */
        /* NOTE: Also, skip emitting the "default" SQL engine pool. */
        if ((entry->zName != NULL) &&
            (pool != get_default_sql_pool(0))) {
            sbuf2printf(sb, "pool %s", entry->zName);
            if (entry->nThreads != 0) {
                sbuf2printf(sb, " threads %lld", entry->nThreads);
            }
            sbuf2printf(sb, "\n");
            data->sum++;
        }
    } else {
        /* NOTE: Being called from process_command(), use logmsg. */
        logmsg(LOGMSG_USER,
               "%s: (name {%s}, threads %lld) ==> (name {%s}, threads %d)\n",
               __func__, (entry->zName != NULL) ? entry->zName : "<null>",
               entry->nThreads,
               (pool != NULL) ? thdpool_get_name(pool) : "<null>",
               (pool != NULL) ? thdpool_get_maxthds(pool) : -1);
        data->sum++;
    }
    return 0;
}

int list_all_sql_pools(SBUF2 *sb)
{