msg_queue_manager.h

Go to the documentation of this file.

#ifndef MSG_QUEUE_MANAGER_H_
#define MSG_QUEUE_MANAGER_H_
   
#include <iostream>
#include <boost/thread.hpp>
#include "micros_swarm/circular_queue.h"

namespace micros_swarm{

    class MsgQueueManager;

    class OutMsgQueue
    {
    public:
        OutMsgQueue(const std::string& name, int size, MsgQueueManager *manager_ptr);
        ~OutMsgQueue();
        bool full();
        bool empty();
        int size();
        const std::vector<uint8_t>& front();
        void pop();
        void push(const std::vector<uint8_t>& msg);
    private:
        std::string name_;
        int size_;
        MsgQueueManager *queue_manager_ptr_;
        boost::shared_mutex mutex_;
        boost::shared_ptr<cqueue<std::vector<uint8_t> > > queue_;
    };

    class MsgQueueManager
    {
        public:
            MsgQueueManager();
            ~MsgQueueManager();
            void createOutMsgQueue(std::string name, int size);
            OutMsgQueue* getOutMsgQueue(std::string name);
            void spinAllOutMsgQueueOnce(std::vector<std::vector<uint8_t> >& msg_vec);
            bool allOutMsgQueueEmpty();
            
            boost::shared_mutex msg_queue_mutex;
            boost::condition_variable_any msg_queue_condition;
        private:
            std::map<std::string, OutMsgQueue*> queue_map_;
    };
};

#endif