/data/refman/pasoursint/CMSSW_6_1_1/src/EventFilter/ResourceBroker/interface/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_ */