Function queue_qlen

lib_fiber/c/src/common/queue.c:275–296

}

int queue_qlen(QUEUE* que)
{
	int   status, n;

	status = pthread_mutex_lock(&que->lock);
	if (status) {
		msg_error("%s(%d): pthread_mutex_lock error(%s)",
			__FUNCTION__, __LINE__, strerror(status));
		return -1;
	}

	n = que->qlen;

	status = pthread_mutex_unlock(&que->lock);
	if (status) {
		msg_error("%s(%d): pthread_mutex_unlock error(%s)",
			__FUNCTION__, __LINE__, strerror(status));
		return -1;
	}

	return n;
}

void queue_set_quit(QUEUE *que)
{