diff options
| -rw-r--r-- | src/gallium/auxiliary/os/os_thread.h | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/src/gallium/auxiliary/os/os_thread.h b/src/gallium/auxiliary/os/os_thread.h index 07a4268fc0..c09e8a7a76 100644 --- a/src/gallium/auxiliary/os/os_thread.h +++ b/src/gallium/auxiliary/os/os_thread.h @@ -302,6 +302,7 @@ static INLINE void pipe_barrier_wait(pipe_barrier *barrier) typedef struct { unsigned count; unsigned waiters; + uint64_t sequence; pipe_mutex mutex; pipe_condvar condvar; } pipe_barrier; @@ -310,6 +311,7 @@ static INLINE void pipe_barrier_init(pipe_barrier *barrier, unsigned count) { barrier->count = count; barrier->waiters = 0; + barrier->sequence = 0; pipe_mutex_init(barrier->mutex); pipe_condvar_init(barrier->condvar); } @@ -329,9 +331,14 @@ static INLINE void pipe_barrier_wait(pipe_barrier *barrier) barrier->waiters++; if (barrier->waiters < barrier->count) { - pipe_condvar_wait(barrier->condvar, barrier->mutex); + uint64_t sequence = barrier->sequence; + + do { + pipe_condvar_wait(barrier->condvar, barrier->mutex); + } while (sequence == barrier->sequence); } else { barrier->waiters = 0; + barrier->sequence++; pipe_condvar_broadcast(barrier->condvar); } |