queue.h

Go to the documentation of this file.

#ifndef QUEUE_H_INCLUDED
#define QUEUE_H_INCLUDED 1

#include "common.h"

#define BUFSIZE 1024

class Queue
{
    int wpointer, rpointer;
    uint32_t buffer[BUFSIZE];
    inline int size(void) {
        return (wpointer + BUFSIZE - rpointer) & (BUFSIZE - 1);
    }
    inline int empty(void) {
        return size() == 0;
    }
    inline int full(void) {
        return size() == BUFSIZE - 1;
    }
public:
    Queue() {
        wpointer = rpointer = 0;
    }
    uint8_t read(uint32_t *x) {
        if (empty()) return 1;
        *x = buffer[rpointer];
        rpointer = (rpointer + 1) & (BUFSIZE - 1);
        return 0;
    }
    uint8_t write(uint32_t x) {
        if (full()) return 1;
        buffer[wpointer] = x;
        wpointer = (wpointer + 1) & (BUFSIZE - 1);
        return 0;
    }
};

#endif