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

Add raft_get_current_leader_node

parent 75955b2c
......@@ -518,6 +518,11 @@ int raft_get_voted_for(raft_server_t* me);
* -1 if the leader is unknown */
int raft_get_current_leader(raft_server_t* me);
/** Get what this node thinks the node of the leader is.
* @return node of what this node thinks is the valid leader;
* NULL if the leader is unknown */
raft_node_t* raft_get_current_leader_node(raft_server_t* me);
/**
* @return callback user data */
void* raft_get_udata(raft_server_t* me);
......
......@@ -89,7 +89,6 @@ void raft_become_leader(raft_server_t* me_)
__log(me_, "becoming leader");
raft_set_state(me_, RAFT_STATE_LEADER);
for (i = 0; i < me->num_nodes; i++)
{
if (me->node != me->nodes[i])
......
......@@ -158,6 +158,12 @@ int raft_get_current_leader(raft_server_t* me_)
return -1;
}
raft_node_t* raft_get_current_leader_node(raft_server_t* me_)
{
raft_server_private_t* me = (void*)me_;
return me->current_leader;
}
void* raft_get_udata(raft_server_t* me_)
{
return ((raft_server_private_t*)me_)->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