CConnection.hpp

Go to the documentation of this file.

#ifndef CCONNECTION_HPP
#define CCONNECTION_HPP

#include "CProtocolSR.hpp"
#include "CDispatcher.hpp"
#include "SRemoteHost.hpp"

#include <memory>

#include <boost/noncopyable.hpp>

namespace google {
  namespace protobuf {

class Message;

  }
}

namespace freedm {
    namespace broker {

class IProtocol;

struct EConnectionError
    : virtual std::runtime_error
{
    explicit EConnectionError(const std::string& what)
        : std::runtime_error(what) { }
};

class CConnection
    : private boost::noncopyable
{

public:
    typedef boost::shared_ptr<CConnection> ConnectionPtr;

    CConnection(std::string uuid, boost::asio::ip::udp::endpoint endpoint);

    ~CConnection();

    void Stop();

    bool GetStopped();

    void Send(const ModuleMessage& msg);

    void ReceiveACK(const ProtocolMessage& msg);

    bool Receive(const ProtocolMessage& msg);

    void OnReceive();
    
    void ChangePhase(bool newround);

    std::string GetUUID() const;

    void SetReliability(int r);
    
    int GetReliability() const;
private:

    boost::shared_ptr<IProtocol> m_protocol;
};

typedef boost::shared_ptr<CConnection> ConnectionPtr;

    } // namespace broker
} // namespace freedm

#endif // CCONNECTION_HPP