DataFifo.h

#pragma once
#include <mqueue.h>
#include <string>
class DataFifo
{
public:
        DataFifo();
        ~DataFifo();
        int setup(const std::string& name, size_t msgSize, size_t maxMsg, bool blocking, bool recreate = true);

        int send(const char* buf, size_t size);

        int receive(char* buf, double timeoutMs = 0);

        int cleanup();
        static bool test();

private:
        mqd_t queue;
        size_t msgSize;
        std::string qName;
};