Remove an atomic op from wait_sync_update

Signed-off-by: Joseph Schuchart <schuchart@icl.utk.edu>
open-mpi · Nov 22, 2022 · ca79fa1 · ca79fa1
1 parent 31006fd
commit ca79fa1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/opal/mca/threads/wait_sync.h b/opal/mca/threads/wait_sync.h
@@ -145,9 +145,10 @@ OPAL_DECLSPEC void opal_threads_base_wait_sync_global_wakeup_mt(int status);
 static inline void wait_sync_update(ompi_wait_sync_t *sync, int updates, int status)
 {
     if (OPAL_LIKELY(OPAL_SUCCESS == status)) {
-        if (0 != (OPAL_THREAD_ADD_FETCH32(&sync->count, -updates))) {
+        if (1 != sync->count && 0 != (OPAL_THREAD_ADD_FETCH32(&sync->count, -updates))) {
             return;
         }
+        sync->count = 0;
     } else {
         /* this is an error path so just use the atomic */
         sync->status = status;