CommandQueue.h

Go to the documentation of this file.

//
// CommandQueue.h
// -------
//
//  Created on: Dec 13, 2011
//                                          Andrei Spataru : aspataru@cern.ch

#ifndef COMMANDQUEUE_H_
#define COMMANDQUEUE_H_

#include "boost/statechart/event_base.hpp"
#include <boost/shared_ptr.hpp>

#include <queue>
#include <semaphore.h>

namespace evf {

namespace rb_statemachine {

typedef boost::shared_ptr<boost::statechart::event_base> EventPtr;

class CommandQueue {

public:
    CommandQueue();
    ~CommandQueue();

    void enqEvent(EventPtr event);

    EventPtr deqEvent();

private:
    void lock();
    void unlock();

private:
    std::queue<EventPtr> eventQueue_;
    sem_t lock_;
    // counting semaphore used to reflect the state of the event queue
    sem_t commandsSem_;
};

}
}

#endif /* COMMANDQUEUE_H_ */