Commit 5a49e862 authored by Willem Thiart's avatar Willem Thiart
Browse files

Added membership changes

parent 1106761d
...@@ -56,6 +56,9 @@ typedef struct { ...@@ -56,6 +56,9 @@ typedef struct {
/* my node ID */ /* my node ID */
raft_node_t* node; raft_node_t* node;
/** 1 if there is a configuration change in progress */
int cfg_inprogress;
} raft_server_private_t; } raft_server_private_t;
void raft_election_start(raft_server_t* me); void raft_election_start(raft_server_t* me);
......
...@@ -661,6 +661,12 @@ raft_node_t* raft_add_node(raft_server_t* me_, void* udata, int id, int is_self) ...@@ -661,6 +661,12 @@ raft_node_t* raft_add_node(raft_server_t* me_, void* udata, int id, int is_self)
return me->nodes[me->num_nodes - 1]; return me->nodes[me->num_nodes - 1];
} }
int raft_has_started(raft_server_t* me_)
{
raft_server_private_t* me = (raft_server_private_t*)me_;
return me->current_term != 0 && me->timeout_elapsed != 0 && me->election_timeout != 0;
}
int raft_get_nvotes_for_me(raft_server_t* me_) int raft_get_nvotes_for_me(raft_server_t* me_)
{ {
raft_server_private_t* me = (raft_server_private_t*)me_; raft_server_private_t* me = (raft_server_private_t*)me_;
......
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