CClockSynchronizer.hpp

Go to the documentation of this file.

#ifndef FREEDM_CLOCK_HPP
#define FREEDM_CLOCK_HPP

#include "IDGIModule.hpp"

#include <list>
#include <map>

#include <boost/asio.hpp>
#include <boost/asio/deadline_timer.hpp>
#include <boost/noncopyable.hpp>

namespace freedm {
    namespace broker {

class CBroker;
class CPeerNode;

class CClockSynchronizer
    : public IDGIModule
{
public:
    explicit CClockSynchronizer(boost::asio::io_service& ios);
    boost::posix_time::ptime GetSynchronizedTime() const;
    void Run();
    void Stop();
    void HandleIncomingMessage(boost::shared_ptr<const ModuleMessage> msg, CPeerNode peer);

private:
    typedef std::pair<std::string,std::string> MapIndex;
    typedef std::map< MapIndex, boost::posix_time::time_duration > OffsetMap;
    typedef std::pair<unsigned int, boost::posix_time::ptime> QueryRecord;
    typedef std::map< MapIndex, QueryRecord > QueryMap;
    typedef std::pair<boost::posix_time::ptime, boost::posix_time::ptime> TimeTuple;
    typedef std::list< TimeTuple > ResponseList;
    typedef std::map< MapIndex, ResponseList > ResponseMap;
    typedef std::map< MapIndex, double > SkewMap;
    typedef std::pair< double, boost::posix_time::ptime > DecayingWeight;
    typedef std::map< MapIndex, DecayingWeight > WeightMap;
    typedef std::map< MapIndex, unsigned int > LastResponseMap;

    void HandleExchangeResponse(const ExchangeResponseMessage& msg, CPeerNode peer);
    void HandleExchange(const ExchangeMessage& msg, CPeerNode peer);
    void Exchange(const boost::system::error_code& err );

    ModuleMessage CreateExchangeMessage(unsigned int k);
    ModuleMessage CreateExchangeResponse(unsigned int k);
    static ModuleMessage PrepareForSending(const ClockSynchronizerMessage& message);

    OffsetMap m_offsets;
    SkewMap m_skews;
    WeightMap m_weights;
    QueryMap m_queries;
    ResponseMap m_responses;
    boost::posix_time::ptime m_lastinteraction;
    unsigned int m_kcounter;
    LastResponseMap m_lastresponse;

    boost::posix_time::time_duration m_myoffset;
    double m_myskew;

    boost::asio::deadline_timer m_exchangetimer;

    double GetWeight(MapIndex i) const;

    void SetWeight(MapIndex i, double w);

    static double TDToDouble(boost::posix_time::time_duration td);

    static boost::posix_time::time_duration DoubleToTD(double td);
};


}
}
#endif