X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fhealth.h;h=28d7dc64959387703dcb10e001b945cb1f6e5995;hp=34d2052e5249f8ce145005cfb3dafe5275b67bf6;hb=a78af745624dfc8bfe90748a1730fecbb4677a17;hpb=c89add41f83057d9848bcef8f976ea8d2111aabd diff --git a/src/bin/lttng-sessiond/health.h b/src/bin/lttng-sessiond/health.h index 34d2052e5..28d7dc649 100644 --- a/src/bin/lttng-sessiond/health.h +++ b/src/bin/lttng-sessiond/health.h @@ -74,11 +74,30 @@ struct health_state { extern DECLARE_URCU_TLS(struct health_state, health_state); /* - * Update current counter by 1 to indicate that the thread entered or - * left a blocking state caused by a poll(). + * Update current counter by 1 to indicate that the thread entered or left a + * blocking state caused by a poll(). If the counter's value is not an even + * number (meaning a code execution flow), an assert() is raised. */ -static inline void health_poll_update(void) +static inline void health_poll_entry(void) { + /* Code MUST be in code execution state which is an even number. */ + assert(!(uatomic_read(&URCU_TLS(health_state).current) + & HEALTH_POLL_VALUE)); + + uatomic_add(&URCU_TLS(health_state).current, HEALTH_POLL_VALUE); +} + +/* + * Update current counter by 1 indicating the exit of a poll or blocking call. + * If the counter's value is not an odd number (a poll execution), an assert() + * is raised. + */ +static inline void health_poll_exit(void) +{ + /* Code MUST be in poll execution state which is an odd number. */ + assert(uatomic_read(&URCU_TLS(health_state).current) + & HEALTH_POLL_VALUE); + uatomic_add(&URCU_TLS(health_state).current, HEALTH_POLL_VALUE); }