cond.h

Go to the documentation of this file.

#pragma once
 
#include <stdbool.h>
#include <stdint.h>
#include "mutex.h"
#include <ascii-chat/atomic.h>
 
#ifdef _WIN32
#include "windows_compat.h"
typedef struct {
    CONDITION_VARIABLE impl; 
    const char *name;        
    atomic_t waiting_count;        
#ifndef NDEBUG
    uint64_t last_signal_time_ns;  
    uint64_t last_broadcast_time_ns; 
    uint64_t last_wait_time_ns;    
    uintptr_t last_waiting_key;     
    mutex_t *last_wait_mutex;       
    const char *last_wait_file;     
    int        last_wait_line;      
    const char *last_wait_func;     
    uint64_t wait_count;            
    uint64_t signal_count;          
    uint64_t broadcast_count;       
#endif
} cond_t;
#else
#include <pthread.h>
typedef struct {
    pthread_cond_t impl;     
    const char *name;        
    atomic_t waiting_count;        
#ifndef NDEBUG
    uint64_t last_signal_time_ns;  
    uint64_t last_broadcast_time_ns; 
    uint64_t last_wait_time_ns;    
    uintptr_t last_waiting_key;     
    mutex_t *last_wait_mutex;       
    const char *last_wait_file;     
    int        last_wait_line;      
    const char *last_wait_func;     
    uint64_t wait_count;            
    uint64_t signal_count;          
    uint64_t broadcast_count;       
#endif
} cond_t;
#endif
 
#ifdef __cplusplus
extern "C" {
#endif
 
// ============================================================================
// Condition Variable Functions
// ============================================================================
 
int cond_init(cond_t *cond, const char *name);
 
int cond_destroy(cond_t *cond);
 
int cond_wait_impl(cond_t *cond, mutex_t *mutex);
 
int cond_timedwait_impl(cond_t *cond, mutex_t *mutex, uint64_t timeout_ns);
 
int cond_signal(cond_t *cond);
 
int cond_broadcast(cond_t *cond);
 
#ifndef NDEBUG
void cond_on_wait(cond_t *cond, mutex_t *mutex, const char *file, int line, const char *func);
#else
#define cond_on_wait(cond, mutex, file, line, func) ((void)0)
#endif
 
// Forward declare debug_sync functions (only in debug builds)
#ifndef NDEBUG
int debug_sync_cond_wait(cond_t *cond, mutex_t *mutex, const char *file, int line, const char *func);
int debug_sync_cond_timedwait(cond_t *cond, mutex_t *mutex, uint64_t timeout_ns, const char *file, int line, const char *func);
bool debug_sync_is_initialized(void);
#endif
 
#ifndef NDEBUG
void cond_on_signal(cond_t *cond);
#else
#define cond_on_signal(cond) ((void)0)
#endif
 
#ifndef NDEBUG
void cond_on_broadcast(cond_t *cond);
#else
#define cond_on_broadcast(cond) ((void)0)
#endif
 
#ifndef NDEBUG
void cond_log_state(const cond_t *cond, const char *file, int line, const char *func);
#define LOG_COND_STATE(cond) cond_log_state(cond, __FILE__, __LINE__, __func__)
#else
#define LOG_COND_STATE(cond) ((void)0)
#endif
 
#ifdef NDEBUG
#define cond_wait(cond, mutex) cond_wait_impl(cond, mutex)
#else
#define cond_wait(cond, mutex)                                                                                         \
  (debug_sync_is_initialized() ? debug_sync_cond_wait(cond, mutex, __FILE__, __LINE__, __func__)                       \
                               : cond_wait_impl(cond, mutex))
#endif
 
#ifdef NDEBUG
#define cond_timedwait(cond, mutex, timeout_ns) cond_timedwait_impl(cond, mutex, timeout_ns)
#else
#define cond_timedwait(cond, mutex, timeout_ns)                                                                        \
  (debug_sync_is_initialized()                                                                                         \
     ? debug_sync_cond_timedwait(cond, mutex, timeout_ns, __FILE__, __LINE__, __func__)                               \
     : cond_timedwait_impl(cond, mutex, timeout_ns))
#endif
 
 
#ifdef __cplusplus
}
#endif