Function queue_push

lib_fiber/c/src/common/queue.c:231–273

}

int queue_push(QUEUE *que, void *data)
{
	QUEUE_ITEM *qi;
	int   status;

	if (que == NULL) {
		msg_fatal("%s: aqueue null", __FUNCTION__);
	}

	qi = calloc(1, sizeof(QUEUE_ITEM));
	qi->data = data;

	status = pthread_mutex_lock(&que->lock);
	if (status != 0) {
		msg_error("%s: lock error(%s)", __FUNCTION__, last_serror());
		free(qi);
		que->error = QUEUE_ERR_LOCK;
		return -1;
	}

	if (que->first == NULL) {
		que->first = qi;
	} else {
		que->last->next = qi;
	}

	que->last = qi;
	que->qlen++;

	status = pthread_mutex_unlock(&que->lock);
	if (status != 0) {
		msg_error("%s: unlock error(%s)", __FUNCTION__, last_serror());
		return -1;
	}

	status = pthread_cond_signal(&que->cond);
	if (status != 0) {
		msg_error("%s: cond signal error(%s)", __FUNCTION__, last_serror());
		return -1;
	}

	return 0;
}

int queue_qlen(QUEUE* que)
{