Function jobqueue_init

src/util/thpool/thpool.c:461–477

Initialize queue */

/* Initialize queue */
static int jobqueue_init(jobqueue *jobqueue_p) {
	jobqueue_p->len         =  0;
	jobqueue_p->front       =  NULL;
	jobqueue_p->rear        =  NULL;

	jobqueue_p->has_jobs = (struct bsem *)rm_calloc(1, sizeof(struct bsem));
	if(jobqueue_p->has_jobs == NULL) {
		return -1;
	}

	pthread_mutex_init(&(jobqueue_p->rwmutex), NULL);
	bsem_init(jobqueue_p->has_jobs, 0);

	jobqueue_p->cap = UINT64_MAX; // unlimited queue size

	return 0;
}

/* Clear the queue */
static void jobqueue_clear(jobqueue *jobqueue_p) {