Skip to content

Commit

Permalink
main: use new re_atomic helpers
Browse files Browse the repository at this point in the history
  • Loading branch information
sreimers committed Jul 21, 2022
1 parent d8a1095 commit 1f065df
Showing 1 changed file with 8 additions and 9 deletions.
17 changes: 8 additions & 9 deletions src/main/main.c
Original file line number Diff line number Diff line change
Expand Up @@ -1063,7 +1063,7 @@ int re_main(re_signal_h *signalh)
}
#endif

if (re_atomic_load(&re->polling, re_memory_order_relaxed)) {
if (re_atomic_weak(&re->polling)) {
DEBUG_WARNING("main loop already polling\n");
return EALREADY;
}
Expand All @@ -1075,7 +1075,7 @@ int re_main(re_signal_h *signalh)
DEBUG_INFO("Using async I/O polling method: `%s'\n",
poll_method_name(re->method));

re_atomic_store(&re->polling, true, re_memory_order_relaxed);
re_atomic_weak_set(&re->polling, true);

re_lock(re);
for (;;) {
Expand All @@ -1087,7 +1087,7 @@ int re_main(re_signal_h *signalh)
re->sig = 0;
}

if (!re_atomic_load(&re->polling, re_memory_order_relaxed)) {
if (!re_atomic_weak(&re->polling)) {
err = 0;
break;
}
Expand Down Expand Up @@ -1118,7 +1118,7 @@ int re_main(re_signal_h *signalh)
re_unlock(re);

out:
re_atomic_store(&re->polling, false, re_memory_order_relaxed);
re_atomic_weak_set(&re->polling, false);

return err;
}
Expand All @@ -1136,7 +1136,7 @@ void re_cancel(void)
return;
}

re_atomic_store(&re->polling, false, re_memory_order_relaxed);
re_atomic_weak_set(&re->polling, false);
}


Expand Down Expand Up @@ -1332,8 +1332,7 @@ void re_thread_enter(void)

/* set only for non-re threads */
if (!thrd_equal(re->tid, thrd_current())) {
re_atomic_store(&re->thread_enter, true,
re_memory_order_relaxed);
re_atomic_weak_set(&re->thread_enter, true);
}
}

Expand All @@ -1350,7 +1349,7 @@ void re_thread_leave(void)
return;
}

re_atomic_store(&re->thread_enter, false, re_memory_order_relaxed);
re_atomic_weak_set(&re->thread_enter, false);
re_unlock(re);
}

Expand Down Expand Up @@ -1421,7 +1420,7 @@ int re_thread_check(void)
if (!re)
return EINVAL;

if (re_atomic_load(&re->thread_enter, re_memory_order_relaxed))
if (re_atomic_weak(&re->thread_enter))
return 0;

if (thrd_equal(re->tid, thrd_current()))
Expand Down

0 comments on commit 1f065df

Please sign in to comment.