d1/df5/cwist__io_8h_source.html

#ifndef __CWIST_IO_H__

#define __CWIST_IO_H__


#include <stddef.h>

#include <stdbool.h>


typedef struct cwist_io_queue cwist_io_queue;


typedef void (*cwist_job_func)(void *arg);


cwist_io_queue *cwist_io_queue_create(size_t capacity);


bool cwist_io_queue_submit(cwist_io_queue *q, cwist_job_func func, void *arg);


void cwist_io_queue_run(cwist_io_queue *q);


void cwist_io_queue_stop(cwist_io_queue *q);


void cwist_io_queue_destroy(cwist_io_queue *q);


#endif

cwist_job_func
void(* cwist_job_func)(void *arg)
Job function signature.
Definition cwist_io.h:22

cwist_io_queue
struct cwist_io_queue cwist_io_queue
Opaque handle for the IO Queue. Backend implementation depends on OS (io_uring, kqueue,...
Definition cwist_io.h:16

cwist_io_queue_run
void cwist_io_queue_run(cwist_io_queue *q)
Run the event loop. Blocks indefinitely, processing jobs as they complete/trigger.
Definition io_queue.c:293

cwist_io_queue_stop
void cwist_io_queue_stop(cwist_io_queue *q)
Request that all runners stop processing without freeing the queue.
Definition io_queue.c:331

cwist_io_queue_destroy
void cwist_io_queue_destroy(cwist_io_queue *q)
Destroy the queue and free resources.
Definition io_queue.c:343

cwist_io_queue_create
cwist_io_queue * cwist_io_queue_create(size_t capacity)
Initialize the job queue.
Definition io_queue.c:228

cwist_io_queue_submit
bool cwist_io_queue_submit(cwist_io_queue *q, cwist_job_func func, void *arg)
Submit a job to be executed asynchronously.
Definition io_queue.c:277