Function create_sql_pool

db/sqlpool.c:124–155

}

static struct thdpool *create_sql_pool(const char *zName, int nThreads)
{
    struct thdpool *pool = thdpool_create(
        (zName != NULL) ? zName : SQL_POOL_LEGACY_NAME,
        sizeof(struct sqlthdstate));

    if (pool == NULL) return NULL;

    if (!gbl_exit_on_pthread_create_fail)
        thdpool_unset_exit(pool);

    thdpool_set_stack_size(pool, SQL_POOL_STACK_SIZE);
    thdpool_set_init_fn(pool, thdpool_sqlengine_start);
    thdpool_set_delt_fn(pool, thdpool_sqlengine_end);
    thdpool_set_dque_fn(pool, thdpool_sqlengine_dque);
    thdpool_set_queued_callback(pool, clnt_queued_event);

    if (zName != NULL) {
        /* TODO: *TUNING* Defaults for non-default pools. */
        thdpool_set_maxthds(pool, nThreads);
        thdpool_set_maxqueueoverride(pool, SQL_POOL_NAMED_MAXQ_OVERRIDE);
    } else {
        thdpool_set_minthds(pool, SQL_POOL_DEFLT_MIN_THREADS);
        thdpool_set_maxthds(pool, SQL_POOL_DEFLT_MAX_THREADS);
        thdpool_set_linger(pool, SQL_POOL_LINGER_SECS);
        thdpool_set_maxqueueoverride(pool, SQL_POOL_DEFLT_MAXQ_OVERRIDE);
        thdpool_set_maxqueueagems(pool, SQL_POOL_MAXQ_AGE_MS);
        thdpool_set_dump_on_full(pool, 1);
    }

    return pool;
}

/*
** WARNING: The "try_add_sql_pool" function assumes the hash lock is already