diff --git a/src/riak_repl2_fs_node_reserver.erl b/src/riak_repl2_fs_node_reserver.erl index 53adf3cd..6285510f 100644 --- a/src/riak_repl2_fs_node_reserver.erl +++ b/src/riak_repl2_fs_node_reserver.erl @@ -101,6 +101,8 @@ handle_call({reserve, Partition}, _From, State) -> end; %% @hidden +%% This message is a call to prevent unreserve/reserve races, as well as +%% detect failed processes. handle_call({unreserve, Partition}, _From, State) -> Reserved2 = cancel_reservation_timeout(Partition, State#state.reservations), {reply, ok, State#state{reservations = Reserved2}};