Commit 1106761d authored by Willem Thiart's avatar Willem Thiart
Browse files

Replaced node idx with node pointer

parent c2f8de12
......@@ -56,10 +56,6 @@ typedef struct {
/* my node ID */
raft_node_t* node;
/* Is 1 if we are in catch up mode
* This is when we are about to join a Raft node */
int catchup_mode;
} raft_server_private_t;
void raft_election_start(raft_server_t* me);
......
......@@ -258,6 +258,7 @@ int raft_recv_appendentries(
{
raft_server_private_t* me = (raft_server_private_t*)me_;
assert(node);
assert(node != me->node);
me->timeout_elapsed = 0;
......@@ -660,12 +661,6 @@ raft_node_t* raft_add_node(raft_server_t* me_, void* udata, int id, int is_self)
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_)
{
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