File syn_pt_sem.h¶

#ifndef SYN_PT_SEM_H
#define SYN_PT_SEM_H

#include "../port/syn_port_system.h"
#include "syn_pt.h"

#ifdef __cplusplus
extern "C" {
#endif

/* ── Semaphore structure ────────────────────────────────────────────────── */

typedef struct {
    volatile int16_t count; 
} SYN_PT_Sem;

/* ── Initialization ─────────────────────────────────────────────────────── */

#define PT_SEM_INIT(sem, initial) ((sem)->count = (int16_t)(initial))

/* ── Blocking wait (protothread context) ────────────────────────────────── */

#define PT_SEM_WAIT(pt, sem)                 \
    do {                                     \
        PT_WAIT_UNTIL(pt, (sem)->count > 0); \
        syn_port_enter_critical();           \
        (sem)->count--;                      \
        syn_port_exit_critical();            \
    } while (0)

#define PT_SEM_BLOCK(pt, task, sem)                     \
    do {                                                \
        PT_BLOCK_CONDITION(pt, task, (sem)->count > 0); \
        syn_port_enter_critical();                      \
        (sem)->count--;                                 \
        syn_port_exit_critical();                       \
    } while (0)

/* ── Signal (any context) ───────────────────────────────────────────────── */

static inline void pt_sem_signal(SYN_PT_Sem *sem)
{
    syn_port_enter_critical();
    sem->count++;
    syn_port_exit_critical();
}

#define PT_SEM_SIGNAL(sem) pt_sem_signal(sem)

/* ── Non-blocking try ───────────────────────────────────────────────────── */

static inline int pt_sem_trywait(SYN_PT_Sem *sem)
{
    int acquired = 0;

    syn_port_enter_critical();
    if (sem->count > 0) {
        sem->count--;
        acquired = 1;
    }
    syn_port_exit_critical();

    return acquired;
}

#define PT_SEM_TRYWAIT(sem) pt_sem_trywait(sem)

/* ── Query ──────────────────────────────────────────────────────────────── */

#define PT_SEM_COUNT(sem) ((sem)->count)

#ifdef __cplusplus
}
#endif

#endif /* SYN_PT_SEM_H */