version 1.1.2.3, 2025/09/26 10:00:46
|
version 1.1.2.4, 2025/09/26 10:13:57
|
Line 163 rbuf_enqueue(ringbuf_t *rbuf, void *data, size_t len)
|
Line 163 rbuf_enqueue(ringbuf_t *rbuf, void *data, size_t len)
|
|
|
if (!rbuf || !rbuf->rb_buffer) |
if (!rbuf || !rbuf->rb_buffer) |
return -1; |
return -1; |
|
if (!rbuf->rb_bufnum) |
|
return 1; |
|
|
h = atomic_load_explicit(&rbuf->rb_head, memory_order_relaxed); |
h = atomic_load_explicit(&rbuf->rb_head, memory_order_relaxed); |
t = atomic_load_explicit(&rbuf->rb_tail, memory_order_acquire); |
t = atomic_load_explicit(&rbuf->rb_tail, memory_order_acquire); |
Line 193 rbuf_dequeue(ringbuf_t *rbuf, struct iovec *out)
|
Line 195 rbuf_dequeue(ringbuf_t *rbuf, struct iovec *out)
|
|
|
if (!rbuf || !rbuf->rb_buffer) |
if (!rbuf || !rbuf->rb_buffer) |
return -1; |
return -1; |
|
if (!rbuf->rb_bufnum) |
|
return 1; |
|
|
h = atomic_load_explicit(&rbuf->rb_head, memory_order_acquire); |
h = atomic_load_explicit(&rbuf->rb_head, memory_order_acquire); |
t = atomic_load_explicit(&rbuf->rb_tail, memory_order_relaxed); |
t = atomic_load_explicit(&rbuf->rb_tail, memory_order_relaxed); |