tabs/kernel/util/ringbuffer.c

#ifndef RINGBUFFER_C
#define RINGBUFFER_C

#include "ringbuffer.h"
#include "../memory.c"

struct ringbuffer* rbfr_create(const int capacity, void (*destroy_element)(void*)) {
	struct ringbuffer* const this = alloc(sizeof (struct ringbuffer));

	this->buffer = alloc(capacity * sizeof (void*));
	this->buffer_n = capacity;
	this->size = 0;
	this->head = 0;

	this->destroy_element = destroy_element;

	return this;
}

void rbfr_destroy(struct ringbuffer* this) {
	rbfr_clear(this);
	free(this->buffer);
	free(this);
}

int rbfr_size(const struct ringbuffer* this) {
	return this->size;
}

int rbfr_capacity(const struct ringbuffer* this) {
	return this->buffer_n;
}

void rbfr_enqueue(struct ringbuffer* this, void* element) {
	if (this->buffer_n == 0) {
		return;
	}

	int index = this->head + this->size;
	if (index >= this->buffer_n) {
		index -= this->buffer_n;
	}
	this->buffer[index] = element;
	if (this->size < this->buffer_n) {
		this->size++;
	} else {
		this->head++;
	}
	return;
}

bool rbfr_peek(const struct ringbuffer* this, void** element) {
	if (this->size == 0) {
		return false;
	}
	*element = this->buffer[this->head];
	return true;
}

bool rbfr_dequeue(struct ringbuffer* this, void** element) {
	if (!rbfr_peek(this, element)) {
		return false;
	}
	this->size--;
	this->head++;
	if (this->head >= this->buffer_n) {
		this->head = 0;
	}
	return true;
}

void rbfr_clear(struct ringbuffer* this) {
	void* element;
	while (rbfr_dequeue(this, &element)) {
		this->destroy_element(element);
	}
}

#endif // RINGBUFFER_C