|
|
@@ -917,7 +917,7 @@ bool tq_push(struct thread_q *tq, void *data)
|
|
|
return rc;
|
|
|
}
|
|
|
|
|
|
-void *tq_pop(struct thread_q *tq, const struct timespec *abstime)
|
|
|
+void *tq_pop(struct thread_q * const tq)
|
|
|
{
|
|
|
struct tq_ent *ent;
|
|
|
void *rval = NULL;
|
|
|
@@ -927,10 +927,7 @@ void *tq_pop(struct thread_q *tq, const struct timespec *abstime)
|
|
|
if (tq->q)
|
|
|
goto pop;
|
|
|
|
|
|
- if (abstime)
|
|
|
- rc = pthread_cond_timedwait(&tq->cond, &tq->mutex, abstime);
|
|
|
- else
|
|
|
- rc = pthread_cond_wait(&tq->cond, &tq->mutex);
|
|
|
+ rc = pthread_cond_wait(&tq->cond, &tq->mutex);
|
|
|
if (rc)
|
|
|
goto out;
|
|
|
if (!tq->q)
|