u_threading.h

Go to the documentation of this file.

// Copyright 2020, Collabora, Ltd.
// SPDX-License-Identifier: BSL-1.0
/*!
 * @file
 * @brief  Slightly higher level thread safe helpers.
 * @author Jakob Bornecrantz <jakob@collabora.com>
 *
 * @ingroup aux_util
 */

#pragma once

#include "os/os_threading.h"


struct u_threading_stack
{
        struct os_mutex mutex;

        void **arr;

        size_t length;
        size_t num;
};


static inline void
u_threading_stack_init(struct u_threading_stack *uts)
{
        os_mutex_init(&uts->mutex);
}

static inline void
u_threading_stack_push(struct u_threading_stack *uts, void *ptr)
{
        if (ptr == NULL) {
                return;
        }

        os_mutex_lock(&uts->mutex);

        if (uts->num + 1 > uts->length) {
                uts->length += 8;
                uts->arr = realloc(uts->arr, uts->length * sizeof(void *));
        }

        uts->arr[uts->num++] = ptr;

        os_mutex_unlock(&uts->mutex);
}

static inline void *
u_threading_stack_pop(struct u_threading_stack *uts)
{
        void *ret = NULL;

        os_mutex_lock(&uts->mutex);

        if (uts->num > 0) {
                ret = uts->arr[--uts->num];
                uts->arr[uts->num] = NULL;
        }

        os_mutex_unlock(&uts->mutex);

        return ret;
}

static inline void *
u_threading_stack_fini(struct u_threading_stack *uts)
{
        void *ret = NULL;

        os_mutex_destroy(&uts->mutex);

        if (uts->arr != NULL) {
                free(uts->arr);
                uts->arr = NULL;
        }

        return ret;
}