Function queue_pop_timedwait

lib_fiber/c/src/common/queue.c:151–224

}

void *queue_pop_timedwait(QUEUE *que, int tmo_sec, int tmo_usec)
{
	QUEUE_ITEM *qi;
	struct  timeval   tv;
	struct	timespec  timeo, *ptimeo;
	int   status;
	void *data;

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

	que->error = QUEUE_OK;

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

	qi = NULL;

	while (1) {
		if (tmo_sec < 0 || tmo_usec < 0) {
			ptimeo = NULL;
		} else {
			gettimeofday(&tv, NULL);
			timeo.tv_sec   = tv.tv_sec + tmo_sec;
			timeo.tv_nsec  = tv.tv_usec * 1000 + tmo_usec * 1000;
			timeo.tv_sec  += timeo.tv_nsec / 1000000000;
			timeo.tv_nsec %= 1000000000;
			ptimeo         = &timeo;
		}

		if (queue_wait(que, ptimeo) < 0) {
			return NULL;
		}

		qi = que->first;
		if (qi != NULL) {
			que->first = qi->next;
			que->qlen--;
			if (que->last == qi) {
				que->last = NULL;
			}
			break;
		}
		if (que->quit != 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_UNLOCK;
			}

			return NULL;
		}