CConnectionManager.hpp

Go to the documentation of this file.

#ifndef CONNECTIONMANAGER_HPP
#define CONNECTIONMANAGER_HPP

#include "SRemoteHost.hpp"

#include <map>
#include <set>
#include <string>

#include <boost/bimap.hpp>
#include <boost/noncopyable.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/thread/mutex.hpp>
#include <boost/asio.hpp>

namespace freedm {
namespace broker {

class CConnection;

class CConnectionManager
    : private boost::noncopyable
{
public:
    typedef boost::shared_ptr<CConnection> ConnectionPtr;

    typedef std::map<std::string, SRemoteHost> hostnamemap;

    typedef boost::bimap<std::string, ConnectionPtr> connectionmap;

    static CConnectionManager& Instance();

    void PutHost(std::string u, std::string host, std::string port);

    void PutHost(std::string u, SRemoteHost host);

    void PutConnection(std::string uuid, ConnectionPtr c);

    void Stop(ConnectionPtr c);

    void StopAll();

    void ChangePhase(bool newround);

    ConnectionPtr GetConnectionByUUID( std::string uuid );

    ConnectionPtr CreateConnection(std::string uuid, boost::asio::ip::udp::endpoint endpoint);
    
    bool HasConnection(std::string uuid);

    hostnamemap::iterator GetHostsBegin() { return m_hosts.begin(); };

    hostnamemap::iterator GetHostsEnd() { return m_hosts.end(); };

    hostnamemap::iterator GetHost(std::string uuid) { return m_hosts.find(uuid); };

    connectionmap::iterator GetConnectionsBegin() { return m_connections.begin(); };

    connectionmap::iterator GetConnectionsEnd() { return m_connections.end(); };

    // Transient Network Simulation
    void LoadNetworkConfig();

private:
    CConnectionManager();
    hostnamemap m_hosts;
    connectionmap m_connections;
    boost::mutex m_Mutex;
};

} // namespace broker
} // namespace freedm

#endif // CONNECTIONMANAGER_HPP