CProtocolSR.hpp

Go to the documentation of this file.

#ifndef CPROTOCOLSR_HPP
#define CPROTOCOLSR_HPP

#include "IProtocol.hpp"

#include "messages/ProtocolMessage.pb.h"

#include <deque>

#include <boost/asio/deadline_timer.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>

namespace freedm {
    namespace broker {

class CProtocolSR
    : public IProtocol
{
    public:
        explicit CProtocolSR(std::string uuid, boost::asio::ip::udp::endpoint endpoint);
        void Send(const ModuleMessage& msg);
        void ReceiveACK(const ProtocolMessage& msg);
        bool Receive(const ProtocolMessage& msg);
        void OnReceive();
        void SendACK(const ProtocolMessage& msg);
        void SendSYN();
        void Stop() { m_timeout.cancel(); SetStopped(true);  };
        void Write(ProtocolMessageWindow & msg);
        void WriteWindow();
    private:
        void Resend(const boost::system::error_code& err);
        boost::asio::deadline_timer m_timeout;
        unsigned int m_inseq;
        unsigned int m_outseq;
        bool m_insync;
        unsigned int m_inresyncs;
        boost::posix_time::ptime m_insynctime;
        bool m_outsync;
        google::protobuf::uint64 m_outsynchash;
        bool m_sendkills;
        unsigned int m_sendkill;
        std::deque<ProtocolMessage> m_window;
        std::deque<ProtocolMessage> m_ack_window;
        static const unsigned int SEQUENCE_MODULO = 1024;
        static const unsigned int REFIRE_TIME = 10;
        static const unsigned int MAX_DROPPED_MSGS = 3;
        unsigned int m_dropped;
        bool m_timer_active;
};

    }
}
#endif