Function _add_parallel_load

db/dohsql.c:1126–1153

pthread_mutex_t parallel_load_mtx = PTHREAD_MUTEX_INITIALIZER;

static int _add_parallel_load(struct sqlclntstate *clnt)
{
    static int alert_parallel_disabled = 0;
    struct thdpool *pool = get_sql_pool(clnt);
    int maxt = thdpool_get_maxthds(pool);
    int thr_slack = (gbl_dohsql_pool_thr_slack > 0) ? gbl_dohsql_pool_thr_slack : 1;

    Pthread_mutex_lock(&parallel_load_mtx);
    if ((maxt - thr_slack) <= parallel_load) {
        if (!alert_parallel_disabled) {
            logmsg(LOGMSG_INFO,
                   "Sql engine full, switching to non-parallel mode\n");
            alert_parallel_disabled = 1;
        }
        Pthread_mutex_unlock(&parallel_load_mtx);
        return SHARD_ERR_LOAD;
    } else {
        if (alert_parallel_disabled) {
            logmsg(LOGMSG_INFO,
                   "Sql engine load cleared, re-activating parallel mode\n");
            alert_parallel_disabled = 0;
        }
    }
    parallel_load++;
    Pthread_mutex_unlock(&parallel_load_mtx);

    return SHARD_NOERR;
}

static void _rem_parallel_load(void)
{