version 1.2, 2025/09/26 10:16:59
|
version 1.4, 2025/09/30 11:38:28
|
Line 46 SUCH DAMAGE.
|
Line 46 SUCH DAMAGE.
|
#ifndef __ARING_H |
#ifndef __ARING_H |
#define __ARING_H |
#define __ARING_H |
|
|
|
#define E_ATOMIC_ALIGN alignas(sizeof(int) * 8) |
|
|
typedef struct { |
typedef struct { |
atomic_int rb_head; | E_ATOMIC_ALIGN int rb_head; |
atomic_int rb_tail; | E E_ATOMIC_ALIGN int rb_tail; |
int rb_bufnum; | int rb_bufnum; |
struct iovec *rb_buffer; | struct iovec *rb_buffer; |
} ringbuf_t; |
} ringbuf_t; |
|
|
|
|
Line 108 int rbuf_enqueue(ringbuf_t *rbuf, void *data, size_t l
|
Line 109 int rbuf_enqueue(ringbuf_t *rbuf, void *data, size_t l
|
* @out = Data, if =NULL, just dequeue data |
* @out = Data, if =NULL, just dequeue data |
* return: -1 error, 1 buffer is empty or 0 ok |
* return: -1 error, 1 buffer is empty or 0 ok |
*/ |
*/ |
int rbuf_dequeue(ringbuf_t *rbuf, struct iovec *out); | int rbuf_dequeue(ringbuf_t *rbuf, struct iovec **out); |
|
|
|
|
#endif |
#endif |