VoltVarCtrl.hpp

Go to the documentation of this file.

#ifndef VoltVarCtrl_HPP_
#define VoltVarCtrl_HPP_

#include "CBroker.hpp"
#include "CDevice.hpp"
#include "CPeerNode.hpp"
#include "PeerSets.hpp"
#include "IDGIModule.hpp"
#include "messages/ModuleMessage.pb.h"

// To include vvc headers
#include "load_system_data.h"
#include "fun_return.h"


#include <map>
#include <set>
#include <string>
#include <boost/shared_ptr.hpp>
#include <boost/date_time/posix_time/posix_time_types.hpp>

namespace freedm {

namespace broker {

namespace vvc {

class VVCAgent
    : public IDGIModule
{
public:
    VVCAgent();
    ~VVCAgent();
    int Run();
private:
    void vvc_Manage( const boost::system::error_code& err);
 
    void HandleIncomingMessage(boost::shared_ptr<const ModuleMessage> msg, CPeerNode peer);
    void HandlePeerList(const gm::PeerListMessage & m, CPeerNode peer);
    PeerSet m_peers;
    std::string m_leader;
    
    ModuleMessage VoltageDelta(unsigned int cf, float pm, std::string loc);
    ModuleMessage LineReadings(std::vector<float> vals);
    ModuleMessage Gradient(arma::mat grad); 
    ModuleMessage PrepareForSending(const VoltVarMessage& message, std::string recipient);
    void HandleVoltageDelta(const VoltageDeltaMessage & m, CPeerNode peer);
    void HandleLineReadings(const LineReadingsMessage & m, CPeerNode peer);
    void HandleGradient(const GradientMessage & m, CPeerNode peer);




    void VVCManage(const boost::system::error_code& err);
    void FirstRound(const boost::system::error_code& err);
    
    void ScheduleNextRound();
    void ReadDevices();
    //int vvc_main1();
    void vvc_main();
    
    const boost::posix_time::time_duration ROUND_TIME;
    const boost::posix_time::time_duration REQUEST_TIMEOUT;

    CBroker::TimerHandle m_RoundTimer;
    CBroker::TimerHandle m_WaitTimer;
    
    float m_Gateway;
    float m_NetGeneration;
    float m_PredictedGateway;
    float m_MigrationStep;
    float m_PowerDifferential;

    bool m_Synchronized;

    std::string m_Leader;
    
    
    
} ; //Class

}  // namespace vvc

} // namespace broker

} // namespace freedm
    
    

#endif