Function thdpool_create

util/thdpool.c:219–281

}

struct thdpool *thdpool_create(const char *name, size_t per_thread_data_sz)
{
    struct thdpool *pool;

    pool = calloc(1, sizeof(struct thdpool));
    if (!pool) {
        logmsg(LOGMSG_ERROR, "%s: out of memory\n", __func__);
        return NULL;
    }
    pool->name = strdup(name);
    if (!pool->name) {
        logmsg(LOGMSG_ERROR, "%s: strdup out of memory\n", __func__);
        free(pool);
        return NULL;
    }
    pool->pool = pool_init(sizeof(struct workitem), 0);
    if (!pool->pool) {
        logmsg(LOGMSG_ERROR, "%s: pool_init failed\n", __func__);
        free(pool->name);
        free(pool);
        return NULL;
    }
#ifdef MONITOR_STACK
    pool->stack_alloc =
        comdb2ma_create_with_scope(0, 0, "stack", pool->name, 1);
    if (pool->stack_alloc == NULL) {
        logmsg(LOGMSG_ERROR, "%s: comdb2ma_create failed\n", __func__);
        free(pool->name);
        free(pool);
        return NULL;
    }
#endif
    listc_init(&pool->thdlist, offsetof(struct thd, thdlist_linkv));
    listc_init(&pool->freelist, offsetof(struct thd, freelist_linkv));
    listc_init(&pool->queue, offsetof(struct workitem, linkv));

    Pthread_mutex_init(&pool->mutex, NULL);
    Pthread_attr_init(&pool->attrs);
    Pthread_attr_setstacksize(&pool->attrs, DEFAULT_THD_STACKSZ);
    Pthread_attr_setdetachstate(&pool->attrs, PTHREAD_CREATE_DETACHED);

    /* 1 meg default mem per thread for thread_malloc() */
    pool->mem_sz = 1 * 1024 * 1024;

    pool->per_thread_data_sz = per_thread_data_sz;
    pool->longwaitms = 500;
    pool->wait = 0;
    pool->exit_on_create_fail = 1;
    pool->dump_on_full = 0;
    pool->stack_sz = DEFAULT_THD_STACKSZ;

    Pthread_cond_init(&pool->wait_for_thread, NULL);

    Pthread_mutex_lock(&pool_list_lk);
    pthread_once(&init_pool_list_once, init_pool_list);
    listc_abl(&threadpools, pool);
    Pthread_mutex_unlock(&pool_list_lk);