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

Add raft_apply_all

parent c2b045ca
...@@ -596,8 +596,11 @@ int raft_get_last_log_term(raft_server_t* me_); ...@@ -596,8 +596,11 @@ int raft_get_last_log_term(raft_server_t* me_);
* are counted in majorities. */ * are counted in majorities. */
void raft_node_set_voting(raft_node_t* node, int voting); void raft_node_set_voting(raft_node_t* node, int voting);
/* Tell if a node is a voting node or not. /** Tell if a node is a voting node or not.
* @return 1 if this is a voting node. Otherwise 0. */ * @return 1 if this is a voting node. Otherwise 0. */
int raft_node_is_voting(raft_node_t* me_); int raft_node_is_voting(raft_node_t* me_);
/** Apply all entries up to the commit index */
void raft_apply_all(raft_server_t* me_);
#endif /* RAFT_H_ */ #endif /* RAFT_H_ */
...@@ -731,3 +731,9 @@ int raft_msg_entry_response_committed(raft_server_t* me_, ...@@ -731,3 +731,9 @@ int raft_msg_entry_response_committed(raft_server_t* me_,
return -1; return -1;
return r->idx <= raft_get_commit_idx(me_); return r->idx <= raft_get_commit_idx(me_);
} }
void raft_apply_all(raft_server_t* me_)
{
while (raft_get_last_applied_idx(me_) < raft_get_commit_idx(me_))
raft_apply_entry(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