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

Add raft_add_non_voting_node

parent 17d1d77e
...@@ -347,6 +347,10 @@ raft_node_t* raft_add_node(raft_server_t* me, void* user_data, int id, int is_se ...@@ -347,6 +347,10 @@ raft_node_t* raft_add_node(raft_server_t* me, void* user_data, int id, int is_se
#define raft_add_peer raft_add_node #define raft_add_peer raft_add_node
/** Add a node which does not participate in voting.
* Parameters are identical to raft_add_node */
raft_node_t* raft_add_non_voting_node(raft_server_t* me_, void* udata, int id, int is_self);
/** Set election timeout. /** Set election timeout.
* The amount of time that needs to elapse before we assume the leader is down * The amount of time that needs to elapse before we assume the leader is down
* @param[in] msec Election timeout in milliseconds */ * @param[in] msec Election timeout in milliseconds */
......
...@@ -685,6 +685,13 @@ raft_node_t* raft_add_node(raft_server_t* me_, void* udata, int id, int is_self) ...@@ -685,6 +685,13 @@ 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];
} }
raft_node_t* raft_add_non_voting_node(raft_server_t* me_, void* udata, int id, int is_self)
{
raft_node_t* node = raft_add_node(me_, udata, id, is_self);
raft_node_set_voting(node, 0);
return node;
}
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