thread_flags_group.h

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: 2025 ML!PA Consulting GmbH
 * SPDX-License-Identifier: LGPL-2.1-only
 */
 
#pragma once

 
#include <limits.h>
 
#include "atomic_utils.h"
#include "thread.h"
#include "thread_flags.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
/* UINT_WIDTH is only provided starting with -std=c23 or newer. Until RIOT
 * requires C23 as C version, we need provide it by hand when missing. */
#ifndef UINT_WIDTH
#  define UINT_WIDTH (sizeof(unsigned) * 8)
#endif

typedef struct {
    unsigned members[(MAXTHREADS / UINT_WIDTH) + !!(MAXTHREADS % UINT_WIDTH)];
} thread_flags_group_t;

#define THREAD_FLAGS_GROUP_INIT { .members = { 0 } }

static inline void thread_flags_group_join(thread_flags_group_t *group)
{
    kernel_pid_t pid = thread_getpid();
    /* this also optimizes away the arithmetic below if MAXTHREADS <= UINT_WIDTH */
    assume(pid < MAXTHREADS);
    atomic_set_bit_unsigned(atomic_bit_unsigned(&group->members[pid / UINT_WIDTH],
                                                pid % UINT_WIDTH));
}

static inline void thread_flags_group_leave(thread_flags_group_t *group)
{
    kernel_pid_t pid = thread_getpid();
    /* this also optimizes away the arithmetic below if MAXTHREADS <= UINT_WIDTH */
    assume(pid < MAXTHREADS);
    atomic_clear_bit_unsigned(atomic_bit_unsigned(&group->members[pid / UINT_WIDTH],
                                                  pid % UINT_WIDTH));
}

void thread_flags_group_set(thread_flags_group_t *group, thread_flags_t mask);
 
#ifdef __cplusplus
}
#endif