syncop: Remove task from syncbarrier's waitq before 'wake'
Removing task from syncbarrier's waitq after wake could result in a subsequent syncbarrier_wake, wake'ing up the already running task. This fix makes the removal from waitq and wake 'atomic' The root cause and the fix are similar in spirit to what was observed in synclock's waitq implementation. Change-Id: I7dd9e6ad5945742bcda20eb5a06a9376bb18528e BUG: 948686 Signed-off-by: Krishnan Parthasarathi <kparthas@redhat.com> Reviewed-on: http://review.gluster.org/5047 Tested-by: Gluster Build System <jenkins@build.gluster.com> Reviewed-by: Anand Avati <avati@redhat.com>
This commit is contained in:
parent
27b457fad2
commit
277fabf577
@ -688,13 +688,10 @@ __syncbarrier_wait (struct syncbarrier *barrier, int waitfor)
|
||||
if (task) {
|
||||
/* called within a synctask */
|
||||
list_add_tail (&task->waitq, &barrier->waitq);
|
||||
{
|
||||
pthread_mutex_unlock (&barrier->guard);
|
||||
synctask_yawn (task);
|
||||
synctask_yield (task);
|
||||
pthread_mutex_lock (&barrier->guard);
|
||||
}
|
||||
list_del_init (&task->waitq);
|
||||
pthread_mutex_unlock (&barrier->guard);
|
||||
synctask_yawn (task);
|
||||
synctask_yield (task);
|
||||
pthread_mutex_lock (&barrier->guard);
|
||||
} else {
|
||||
/* called by a non-synctask */
|
||||
pthread_cond_wait (&barrier->cond, &barrier->guard);
|
||||
@ -737,6 +734,7 @@ __syncbarrier_wake (struct syncbarrier *barrier)
|
||||
pthread_cond_signal (&barrier->cond);
|
||||
if (!list_empty (&barrier->waitq)) {
|
||||
task = list_entry (barrier->waitq.next, struct synctask, waitq);
|
||||
list_del_init (&task->waitq);
|
||||
synctask_wake (task);
|
||||
}
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user