#include #include #include #include "ringbuffer.c" #include "ringbuffer-test-utils.c" void test_read_commit(void) { uint8_t *out_buf; uint8_t in_buf[] = { 'a', 'b', 'c', }; struct ringbuffer_consumer *rbc; struct ringbuffer *rb; size_t len; rb = ringbuffer_init(10); rbc = ringbuffer_consumer_register(rb, ringbuffer_poll_nop, NULL); ringbuffer_queue(rb, in_buf, sizeof(in_buf)); len = ringbuffer_dequeue_peek(rbc, 0, &out_buf); ringbuffer_dequeue_commit(rbc, len); len = ringbuffer_dequeue_peek(rbc, 0, &out_buf); assert(len == 0); ringbuffer_fini(rb); } int main(void) { test_read_commit(); return EXIT_SUCCESS; }