|
version 1.1.2.1, 2025/09/26 08:58:05
|
version 1.3.2.1, 2025/09/30 11:33:20
|
|
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 |