#include "threads_impl.h"

// C11 does not define any way for applications to know the maximum
// number of tss_t slots. pthreads, however, does, via the
// PTHREAD_KEYS_MAX constant. So we allow that bit of pthreads to
// bleed over here (and into sysconf, which also reports the value)
// rather than go through some circuituous pattern to define an
// internal constant that's just the same as the pthread one.

typedef void (*key_t)(void*);
static _Atomic(key_t) keys[PTHREAD_KEYS_MAX];

static void nodtor(void* dummy) {}

int tss_create(tss_t* k, void (*dtor)(void*)) {
    unsigned i = (uintptr_t)&k / 16 % PTHREAD_KEYS_MAX;
    unsigned j = i;

    if (!dtor)
        dtor = nodtor;
    do {
        key_t expected = NULL;
        if (atomic_compare_exchange_strong(&keys[j], &expected, dtor)) {
            *k = j;
            return 0;
        }
    } while ((j = (j + 1) % PTHREAD_KEYS_MAX) != i);
    return EAGAIN;
}

void tss_delete(tss_t k) {
    atomic_store(&keys[k], NULL);
}

void __thread_tsd_run_dtors(void) {
    thrd_t self = __thrd_current();
    int i, j, not_finished = self->tsd_used;
    for (j = 0; not_finished && j < TSS_DTOR_ITERATIONS; j++) {
        not_finished = 0;
        for (i = 0; i < PTHREAD_KEYS_MAX; i++) {
            if (self->tsd[i] && atomic_load(&keys[i])) {
                void* tmp = self->tsd[i];
                self->tsd[i] = 0;
                atomic_load(&keys[i])(tmp);
                not_finished = 1;
            }
        }
    }
}