Function queue_wait

lib_fiber/c/src/common/queue.c:113–149

}

static int queue_wait(QUEUE *que, const struct timespec *ptimeo)
{
	int   status;

	while (que->first == NULL && que->quit == 0) {
		if (ptimeo != NULL) {
			status = pthread_cond_timedwait(&que->cond,
					&que->lock, ptimeo);
		} else {
			status = pthread_cond_wait(&que->cond, &que->lock);
		}

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

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

			que->error = QUEUE_ERR_COND_WAIT;
			msg_error("%s: cond wait error(%s)",
				__FUNCTION__, last_serror());
			return -1;
		}
	}

	return 0;
}

void *queue_pop_timedwait(QUEUE *que, int tmo_sec, int tmo_usec)
{