ringbuf/ringbuf.c

/* SPDX-License-Identifier: MIT */

#include <stdlib.h>
#include <string.h>
#include <stdio.h>

#include "ringbuf.h"

void
rb_init(struct RingBuf *rb, rb_size_t capacity, ALLOC_T malloc_fn,
        rb_size_t struct_size)
{
  rb->struct_size = struct_size;
  rb->capacity = capacity;
  rb->write_idx = 0;
  rb->read_idx = 0;
  rb->buffer = malloc_fn(capacity * struct_size); /* Calloc? */
  rb->buffer_end = rb->buffer + (capacity * struct_size);

  // Read from buffer at max position to force a segfault if theres an issue
  printf("Reading from buffer at position %d\n",
         rb->capacity * rb->struct_size);
  void *top = rb->buffer + (rb->capacity * rb->struct_size);
  printf("Buffer top successfully read at virtual address: %p\n", &top);

  printf("Initialized ring buffer. Capacit: %d, struct_size: %d, total: %d\n",
         rb->capacity, rb->struct_size, rb->capacity * rb->struct_size);
}

void
rb_destroy(struct RingBuf *rb, void(free)())
{
  free(rb->buffer);
}

enum WriteResult
rb_push_back(struct RingBuf *rb, const void *item, MEMCPY_T memcpy_fn)
{
  // if(rb->count == rb->capacity){
  //     // handle error
  // }

  memcpy_fn(rb->write_head, item, rb->size);

  rb->write_head = (char *)rb->write_head + rb->size;

  if(rb->write_head == rb->buffer_end)
    rb->write_head = rb->buffer;

  rb->count++;
}

// void rb_pop_front(struct RingBuf *rb, void *item)
// {
//     if(cb->count == 0){
//         // handle error
//     }
//     memcpy(item, cb->tail, cb->sz);
//     cb->tail = (char*)cb->tail + cb->sz;
//     if(cb->tail == cb->buffer_end)
//         cb->tail = cb->buffer;
//     cb->count--;
// }

void
rb_read(struct RingBuf *rb, void *dest, int amount)
{
  printf("\nReading %d elements\n", amount);
  for(int i = 0; i < amount; i++) {
  }
}

void
print_seq(void *begin, int amount)
{
  printf("\nPrinting sequence\n");
  for(int i = 0; i < amount; i++) {
    int *val = (int *)(begin + 4 * i);
    printf("V: %d, A: %u\n", *val, val);
  }
}