uring_sqpoll.h

Go to the documentation of this file.

 
#ifndef CWIST_SYS_IO_URING_SQPOLL_H
#define CWIST_SYS_IO_URING_SQPOLL_H
 
#include <stddef.h>
#include <stdint.h>
#include <stdbool.h>
 
#if defined(__linux__)
#include <linux/io_uring.h>
#include <stdatomic.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef struct {
    int ring_fd;
    struct io_uring_sqe *sqes;
    _Atomic uint32_t *sq_head;
    _Atomic uint32_t *sq_tail;
    uint32_t *sq_ring_mask;
    uint32_t *sq_array;
    uint32_t entries;
    size_t sq_ring_sz;
    size_t sqes_sz;
    bool active;
} cwist_sqpoll_ring_t;
 
int cwist_io_uring_init_sqpoll(cwist_sqpoll_ring_t *r, unsigned entries,
                               unsigned sq_thread_idle_ms);
 
bool cwist_io_uring_sqpoll_send(cwist_sqpoll_ring_t *r, int fd, const void *buf, size_t len,
                                uint64_t user_data);
 
void cwist_io_uring_destroy_sqpoll(cwist_sqpoll_ring_t *r);
 
#ifdef __cplusplus
}
#endif
 
#endif /* __linux__ */
 
#endif /* CWIST_SYS_IO_URING_SQPOLL_H */