LocklessQueue.hpp

Go to the documentation of this file.

#ifndef _LOCKLESS_QUEUE_H_
#define _LOCKLESS_QUEUE_H_
 
#include <FpConfig.hpp>
#include <Os/Queue.hpp>
#ifndef BUILD_DARWIN // Allow compiling
#include <mqueue.h>
#endif
 
namespace Os {
 
  class LocklessQueue {
 
    typedef struct QueueNode_s {
      U8                 * data;
      NATIVE_INT_TYPE      size;
      struct QueueNode_s * next;
    } QueueNode;
    
  public:
    
    LocklessQueue (NATIVE_INT_TYPE maxmsg, NATIVE_INT_TYPE msgsize);
    ~LocklessQueue();
 
#ifndef BUILD_DARWIN // Allow compiling
    void GetAttr (mq_attr & attr);
#endif
 
    Os::Queue::QueueStatus Send (const U8 * buffer, NATIVE_INT_TYPE size);
    Os::Queue::QueueStatus Receive (U8 * buffer, NATIVE_INT_TYPE capacity, NATIVE_INT_TYPE & size);
 
  private:
    bool PopFree (QueueNode ** free_node);
    void PushFree (QueueNode * my_node);
 
    QueueNode *  m_first;   
    QueueNode *  m_last;    
 
    QueueNode *  m_free_head;
 
    QueueNode *  m_index;
    U8        *  m_data;
#ifndef BUILD_DARWIN
    mq_attr      m_attr;
#endif
  };
 
}
 
#endif