X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fwaiter.cpp;fp=src%2Fcommon%2Fwaiter.cpp;h=b1e0adeccba00638a206c9e8171b6af44af6f201;hp=2a1dded89805a6188a5b77b9f75e8ce5a99a976c;hb=28ab034a2c3582d07d3423d2d746731f87d3969f;hpb=52e345b9ac912d033c2a2c25a170a01cf209839d diff --git a/src/common/waiter.cpp b/src/common/waiter.cpp index 2a1dded89..b1e0adecc 100644 --- a/src/common/waiter.cpp +++ b/src/common/waiter.cpp @@ -6,11 +6,12 @@ * */ -#include "waiter.hpp" -#include -#include #include "error.hpp" +#include "waiter.hpp" + #include +#include +#include /* * Number of busy-loop attempts before waiting on futex. @@ -19,11 +20,11 @@ enum waiter_state { /* WAITER_WAITING is compared directly (futex compares it). */ - WAITER_WAITING = 0, + WAITER_WAITING = 0, /* non-zero are used as masks. */ - WAITER_WOKEN_UP = (1 << 0), - WAITER_RUNNING = (1 << 1), - WAITER_TEARDOWN = (1 << 2), + WAITER_WOKEN_UP = (1 << 0), + WAITER_RUNNING = (1 << 1), + WAITER_TEARDOWN = (1 << 2), }; void lttng_waiter_init(struct lttng_waiter *waiter) @@ -67,7 +68,7 @@ void lttng_waiter_wait(struct lttng_waiter *waiter) goto skip_futex_wait; case EINTR: /* Retry if interrupted by signal. */ - break; /* Get out of switch. Check again. */ + break; /* Get out of switch. Check again. */ default: /* Unexpected error. */ PERROR("futex_noasync"); @@ -107,8 +108,7 @@ void lttng_waiter_wake_up(struct lttng_waiter *waiter) LTTNG_ASSERT(uatomic_read(&waiter->state) == WAITER_WAITING); uatomic_set(&waiter->state, WAITER_WOKEN_UP); if (!(uatomic_read(&waiter->state) & WAITER_RUNNING)) { - if (futex_noasync(&waiter->state, FUTEX_WAKE, 1, - NULL, NULL, 0) < 0) { + if (futex_noasync(&waiter->state, FUTEX_WAKE, 1, NULL, NULL, 0) < 0) { PERROR("futex_noasync"); abort(); }