Function _indexer_AddTask

src/index/indexer.c:238–261

add task to indexer queue

// add task to indexer queue
static void _indexer_AddTask
(
	IndexerOp op,
	void *pdata
) {
	// lock
	int res = pthread_mutex_lock(&indexer->m);
	ASSERT(res == 0);

	// add task to queue
	IndexerTask	task = {.op = op, .pdata = pdata};

	res = CircularBuffer_Add(indexer->q, &task);
	ASSERT(res == 1);

	// unlock
	res = pthread_mutex_unlock(&indexer->m);
	ASSERT(res == 0);

	// signal conditional variable
	pthread_mutex_lock(&indexer->cm); 
	pthread_cond_signal(&indexer->c);
	pthread_mutex_unlock(&indexer->cm);
}

// pops a task from queue
// if queue is empty caller will be waiting on conditional variable