IpcMsgQueue.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef IPC_MSG_QUEUE_H_
#define IPC_MSG_QUEUE_H_

#include <fesa-core/Core/AbstractMsgQueue.h>

#include <string>
#include <mqueue.h>

namespace fesa
{

class IpcMsgQueue: public AbstractMsgQueue
{
  public:
    IpcMsgQueue(const std::string& name, uint32_t queuelength, bool blocking);

    ~IpcMsgQueue();

    void postMsg(AbstractMessage* msg);

    AbstractMessage* consumeMsg();

    void purge();

    uint32_t getCurrentMsgCount();

  private:

    mqd_t msgQueue_;


    void checkSystemMaxValues(uint32_t queuelength);


    IpcMsgQueue(const IpcMsgQueue&);

    IpcMsgQueue& operator=(const IpcMsgQueue&);
};

} // fesa

#endif // IPC_MSG_QUEUE_H_