raft.h

Go to the documentation of this file.

 
#ifndef ICAROUS_CFS_RAFT_H
#define ICAROUS_CFS_RAFT_H
 
#include "cfe.h"
#include "cfe_error.h"
#include "cfe_evs.h"
#include "cfe_sb.h"
#include "cfe_es.h"
#include "cfe_platform_cfg.h"
#include <string.h>
#include <stdbool.h>
#include <time.h>
#include "raft_msg.h"
#include "raft_msgids.h"
#include "Icarous_msgids.h"
 
#define RAFT_STARTUP_INF_EID 0
#define RAFT_COMMAND_ERR_EID 1
#define RAFT_RECEIVED_FENCE_EID 3
 
#define RAFT_PIPE_DEPTH 100
#define RAFT_HBEATPIPE_NAME "RAFT_HBEAT_PIPE"
#define RAFT_SCHPIPE_NAME "RAFT_SCH_PIPE"
#define RAFT_VOTEPIPE_NAME "RAFT_VOTE_PIPE"
#define RAFT_DATAPIPE_NAME "RAFT_DATA_PIPE"
 
#define RAFT_MAJOR_VERSION 1
#define RAFT_MINOR_VERSION 0
 
typedef enum{
   NEUTRAL,
   FOLLOWER,
   CANDIDATE,
   LEADER
}Role_e;
 
typedef struct{
    CFE_SB_PipeId_t    Raft_HbeatPipe;      
    CFE_SB_PipeId_t    Raft_SchPipe;        
    CFE_SB_PipeId_t    Raft_VotePipe;       
    CFE_SB_PipeId_t    Raft_ClientPipe;     
 
    CFE_SB_MsgPtr_t    Raft_HbeatMsgPtr;    
    CFE_SB_MsgPtr_t    Raft_SchMsgPtr;      
    CFE_SB_MsgPtr_t    Raft_VoteMsgPtr;     
    CFE_SB_MsgPtr_t    Raft_ClientMsgPtr;   
 
    Role_e  nodeRole;                       
    uint32_t nodeID;                        
    uint32_t leaderID;                      
    int32_t nodeTerm;                       
    int32_t votedTerm;                      
    uint32_t votedForNodeId;                
    int32_t nodeIntersection;               
    uint32_t totalVotesReceived;            
    uint32_t totalNodes;                    
    int32_t memberNodeID[MAX_NODES];        
    uint32_t followerTimerId;               
    uint32_t candidateTimerId;              
    uint32_t leaderTimerId;                 
    uint32_t hbeatTimeoutCounter;           
    uint32_t electionTimeoutCounter;        
    uint32_t leaderTimeoutCounter;          
 
    report_t mergingData[MAX_NODES];   
    uint32_t logDataIndex;                  
    report_t ownshipMergingData;       
    bool electionInitiated;                 
    bool neutralPipeInitialized;            
    bool followerPipeInitialized;           
    bool candidatePipeInitialized;          
    bool leaderPipeInitialized;             
    bool neutralFollower;                   
 
    FILE* logFile;                          
}raftAppData_t;
 
void RAFT_AppMain(void);
 
void RAFT_AppInit(void);
 
void RAFT_AppInitializeData(void);
 
void RAFT_AppCleanUp(void);
 
void RAFT_ProcessPacket(void);
 
void heartbeatTimeoutCallback(uint32_t timerId);
 
void electionTimeoutCallback(uint32_t timerId);
 
void leaderTimeoutCallback(uint32_t timerId);
 
void raft_loop(void);
 
void raft_neutral(void);
 
void raft_follower(void);
 
void raft_candidate(void);
 
void raft_leader(void);
 
void raftProcessClientData(void);
 
void raftSendDataToClient(void);
 
void RAFT_SetNeutralPipeConfiguration(void);
 
void RAFT_SetFollowerPipeConfiguration(void);
 
void RAFT_SetCandidatePipeConfiguration(void);
 
void RAFT_SetLeaderPipeConfiguration(void);
 
 
EXTERN raftAppData_t raftAppData;
 
 
#endif //ICAROUS_CFS_RAFT_H