IPCQueue.hpp

Go to the documentation of this file.

#ifndef _IPCQueue_hpp_
#define _IPCQueue_hpp_
 
#include <Os/Queue.hpp>
 
namespace Os {
    class IPCQueue : public Os::Queue {
        public:
            IPCQueue();
            ~IPCQueue();
            QueueStatus create(const Fw::StringBase &name, NATIVE_INT_TYPE depth, NATIVE_INT_TYPE msgSize); 
 
            // Base class has overloads - NOTE(mereweth) - this didn't work
            //using Queue::send;
            //using Queue::receive;
 
            // Send serialized buffers
            QueueStatus send(const Fw::SerializeBufferBase &buffer, NATIVE_INT_TYPE priority, QueueBlocking block); 
            QueueStatus receive(Fw::SerializeBufferBase &buffer, NATIVE_INT_TYPE &priority, QueueBlocking block); 
 
            // Send raw buffers
            QueueStatus send(const U8* buffer, NATIVE_INT_TYPE size, NATIVE_INT_TYPE priority, QueueBlocking block); 
            QueueStatus receive(U8* buffer, NATIVE_INT_TYPE capacity, NATIVE_INT_TYPE &actualSize, NATIVE_INT_TYPE &priority, QueueBlocking block); 
 
            NATIVE_INT_TYPE getNumMsgs() const; 
            NATIVE_INT_TYPE getMaxMsgs() const; 
            NATIVE_INT_TYPE getQueueSize() const; 
            NATIVE_INT_TYPE getMsgSize() const; 
    };
    class IPCQueue : public Os::Queue {…};
}
 
#endif