msg.h

Go to the documentation of this file.

 
#ifndef GHS_MSG_H
#define GHS_MSG_H
 
#include "ghs/agent.h"
#include "ghs/level.h"
#include "ghs/edge.h"
 
namespace le{
  namespace ghs{
 
    namespace msg{
      enum Type
      {
        UNASSIGNED=0,
        NOOP,
        SRCH,
        SRCH_RET,
        IN_PART,
        ACK_PART,
        NACK_PART,
        JOIN_US,
      };
 
      struct NoopPayload{ 
      }; 
 
      struct SrchPayload{
        agent_t your_leader;
        level_t   your_level;
      };
 
      struct SrchRetPayload{
        agent_t to;
        agent_t from;
        metric_t metric;
      };
 
      struct InPartPayload{
        agent_t leader;
        level_t   level; 
      };
 
      struct AckPartPayload{ 
      };
 
      struct NackPartPayload{ 
      };
 
      struct JoinUsPayload{ 
        agent_t join_peer;
        agent_t join_root;
        agent_t proposed_leader;
        level_t proposed_level;
      };
 
      union Data{
        NoopPayload noop;
        SrchPayload srch;
        SrchRetPayload srch_ret;
        InPartPayload in_part;
        AckPartPayload ack_part;
        NackPartPayload nack_part;
        JoinUsPayload join_us;
      };
    }
 
 
    class Msg
    {
 
      public:
 
        Msg();
 
        Msg(agent_t to, agent_t from, msg::NoopPayload p);
        Msg(agent_t to, agent_t from, msg::SrchPayload p);
        Msg(agent_t to, agent_t from, msg::SrchRetPayload p);
        Msg(agent_t to, agent_t from, msg::InPartPayload p);
        Msg(agent_t to, agent_t from, msg::AckPartPayload p);
        Msg(agent_t to, agent_t from, msg::NackPartPayload p);
        Msg(agent_t to, agent_t from, msg::JoinUsPayload p);
 
        Msg(agent_t to, agent_t from, const Msg &other);
 
        Msg(agent_t to, agent_t from, msg::Type t, msg::Data d);
 
        ~Msg();
        
        agent_t to() const {return to_;}
        agent_t from() const {return from_;}
        msg::Type type() const {return type_;}
        msg::Data data() const {return data_;}
 
      private:
        agent_t to_; 
 
        agent_t from_;
 
        msg::Data data_;
 
        msg::Type type_;
 
    };
 
    const unsigned int MAX_MSG_SZ= sizeof(Msg);
 
  }
}
 
#endif