Commit 9c758317 authored by Willem Thiart's avatar Willem Thiart
Browse files

func_node_has_sufficient_logs_f now returns int

parent 36c93559
......@@ -188,7 +188,7 @@ typedef int (
* @param[in] user_data User data that is passed from Raft server
* @param[in] node The node
* @return 0 does not want to be notified again; otherwise -1 */
typedef void (
typedef int (
*func_node_has_sufficient_logs_f
) (
raft_server_t* raft,
......
......@@ -276,8 +276,9 @@ int raft_recv_appendentries_response(raft_server_t* me_,
0 == raft_node_has_sufficient_logs(node)
)
{
raft_node_set_has_sufficient_logs(node);
me->cb.node_has_sufficient_logs(me_, me->udata, node);
int e = me->cb.node_has_sufficient_logs(me_, me->udata, node);
if (0 == e)
raft_node_set_has_sufficient_logs(node);
}
/* Update commit idx */
......
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