hub.hpp

Go to the documentation of this file.

#pragma once
#include "message.hpp"

#include <list>
#include <memory>
#include <queue>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <atomic>

namespace channeling {
  class Channel;
}

namespace Hub {

  typedef std::unique_ptr<channeling::Channel> chanPtr;

  class Hub {
  private:
    const std::string _name;                        
    std::list<chanPtr> _inputChannels;              
    std::list<chanPtr> _outputChannels;             
    std::queue<messaging::message_ptr> _messages;   
    std::mutex _mutex;                              
    std::condition_variable _cond;                  
    std::unique_ptr<std::thread> _msgLoop;          
    std::atomic_bool _loopRunning;                  
    void addInput(channeling::Channel * const);

    void addOutput(channeling::Channel * const);

    /*
     * Queue operations
     */

    const messaging::message_ptr popMessage();
    void pushMessage(const messaging::message_ptr&& item);

    void msgLoop();

    std::shared_ptr<std::atomic<bool> > _alive;
  public:
    Hub(std::string const& name);
    ~Hub() { _alive.reset(); };

    const std::string& name() const {return _name; };
    std::shared_ptr<std::atomic<bool> > alive() const {return _alive; };

    void addChannel(channeling::Channel * const);

    void newMessage(const messaging::message_ptr&& msg);

    void activate();

    void deactivate();

    bool active() {return _loopRunning; };

    void tick();
  };
}