event_ctx.h

Go to the documentation of this file.

#ifndef KEEL_EVENT_CTX_H
#define KEEL_EVENT_CTX_H
 
#include <keel/allocator.h>
#include <keel/error.h>
#include <keel/event.h>
#include <stdint.h>
 
/* ── KlWatcher — generic FD callback ──────────────────────────────── */
 
typedef void (*KlWatcherFn)(int fd, KlEventMask ready, void *user_data);
 
typedef struct KlWatcher {
    int fd;                  
    KlEventMask mask;        
    KlWatcherFn on_ready;    
    void *user_data;         
    struct KlWatcher *next;  
} KlWatcher;
 
/* ── KlEventCtx — composable event loop + watcher context ────────── */
 
typedef struct KlTimerEntry KlTimerEntry;
 
typedef struct KlEventCtx {
    KlEventLoop loop;             
    KlAllocator *alloc;           
    KlWatcher *watchers;          
    int dispatch_dirty;       
    KlError last_error;       
    /* Timer heap */
    KlTimerEntry *timers;     
    int timer_count;          
    int timer_cap;            
    int64_t timer_next_id;    
} KlEventCtx;
 
int  kl_event_ctx_init(KlEventCtx *ctx, KlAllocator *alloc);
 
void kl_event_ctx_free(KlEventCtx *ctx);
 
/* ── Watcher API (operates on KlEventCtx, not KlServer) ──────────── */
 
int  kl_watcher_add(KlEventCtx *ctx, int fd, KlEventMask mask,
                    KlWatcherFn on_ready, void *user_data);
 
int  kl_watcher_mod(KlEventCtx *ctx, int fd, KlEventMask mask);
 
void kl_watcher_del(KlEventCtx *ctx, int fd);
 
int  kl_watcher_rearm(KlEventCtx *ctx, int fd);
 
/* ── Dispatch helpers ─────────────────────────────────────────────── */
 
static inline int kl_event_dispatch(KlEventCtx *ctx, const KlEvent *event) {
    uintptr_t tag = (uintptr_t)event->udata;
    if (!(tag & 1))
        return 0;  /* not a watcher — caller handles */
    KlWatcher *w = (KlWatcher *)(tag & ~(uintptr_t)1);
    int wfd = w->fd;
    ctx->dispatch_dirty = 0;
    w->on_ready(wfd, event->ready, w->user_data);
    // cppcheck-suppress knownConditionTrueFalse
    if (!ctx->dispatch_dirty)
        kl_watcher_rearm(ctx, wfd);
    return 1;
}
 
int kl_event_ctx_run(KlEventCtx *ctx, int max_events, int timeout_ms);
 
#endif