Commit fd1f0286 authored by Willem Thiart's avatar Willem Thiart
Browse files

Refactor, move raft_state_e to raft.h

parent 74f27d87
...@@ -11,6 +11,13 @@ ...@@ -11,6 +11,13 @@
#ifndef RAFT_H_ #ifndef RAFT_H_
#define RAFT_H_ #define RAFT_H_
typedef enum {
RAFT_STATE_NONE,
RAFT_STATE_FOLLOWER,
RAFT_STATE_CANDIDATE,
RAFT_STATE_LEADER
} raft_state_e;
typedef struct typedef struct
{ {
void *buf; void *buf;
...@@ -542,4 +549,8 @@ int raft_append_entry(raft_server_t* me, raft_entry_t* ety); ...@@ -542,4 +549,8 @@ int raft_append_entry(raft_server_t* me, raft_entry_t* ety);
int raft_msg_entry_response_committed(raft_server_t* me_, int raft_msg_entry_response_committed(raft_server_t* me_,
const msg_entry_response_t* r); const msg_entry_response_t* r);
/** Tell if we are a leader, candidate or follower.
* @return get state of type raft_state_e. */
int raft_get_state(raft_server_t* me_);
#endif /* RAFT_H_ */ #endif /* RAFT_H_ */
...@@ -12,13 +12,6 @@ ...@@ -12,13 +12,6 @@
* @version 0.1 * @version 0.1
*/ */
enum {
RAFT_STATE_NONE,
RAFT_STATE_FOLLOWER,
RAFT_STATE_CANDIDATE,
RAFT_STATE_LEADER
};
typedef struct { typedef struct {
/* Persistent state: */ /* Persistent state: */
...@@ -105,6 +98,7 @@ int raft_get_commit_idx(raft_server_t* me_); ...@@ -105,6 +98,7 @@ int raft_get_commit_idx(raft_server_t* me_);
void raft_set_last_applied_idx(raft_server_t* me, int idx); void raft_set_last_applied_idx(raft_server_t* me, int idx);
void raft_set_state(raft_server_t* me_, int state); void raft_set_state(raft_server_t* me_, int state);
int raft_get_state(raft_server_t* me_); int raft_get_state(raft_server_t* me_);
raft_node_t* raft_node_new(void* udata); raft_node_t* raft_node_new(void* udata);
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment