raft_msg.h

Go to the documentation of this file.

 
#ifndef ICAROUS_CFS_RAFT_MSG_H
#define ICAROUS_CFS_RAFT_MSG_H
 
#include "cfe.h"
#include "merger_msg.h"
 
#define MAX_NODES 5
 
typedef struct __attribute__((__packed__)){
   int8_t aircraftID;           
   int8_t intersectionID;       
   double earlyArrivalTime;     
   double currentArrivalTime;   
   double lateArrivalTime;      
   int32_t numSchedulesComputed;
   uint8_t zoneStatus;          
}report_t;
 
 
 
typedef struct __attribute__((__packed__)){
   CCSDS_PriHdr_t hdr;                      
   int32_t intersectionID;                  
   uint8_t nodeRole;                        
   uint32_t totalNodes;                     
   report_t log[MAX_NODES];
}cDataLog_t;
 
typedef struct{
   uint8_t TlmHeader[CFE_SB_TLM_HDR_SIZE];  
   int32_t intersectionID;                  
   uint32_t leaderID;                       
   uint32_t totalNodes;                     
   uint32_t logIndex;                       
   uint32_t term;                           
   report_t log[MAX_NODES];
}raftHbeat_t;
 
typedef struct{
  uint8_t TlmHeader[CFE_SB_TLM_HDR_SIZE]; 
  int32_t intersectionID;                 
  uint32_t followerID;                    
  report_t nodeData;                      
  uint32_t logIndex;                      
}raftHbeatAck_t;
 
 
typedef struct{
  uint8_t TlmHeader[CFE_SB_TLM_HDR_SIZE]; 
  int32_t intersectionID;                 
  uint32_t candidateID;                   
  uint32_t term;                          
}raftVoteRequest_t;
 
typedef struct{
  uint8_t TlmHeader[CFE_SB_TLM_HDR_SIZE]; 
  int32_t intersectionID;                 
  uint32_t candidateID;                   
  uint32_t nodeID;                        
  uint32_t term;                          
}raftVoteResponse_t;
 
 
#endif //ICAROUS_CFS_RAFT_MSG_H