+4 -1

lib/servers/coordinator.ex

reviewed

··· 351 351 replica_map: replica_map, 352 352 replica_ids: replica_ids, 353 353 quorum_size: quorum_size, 354 354 + 355 355 + last_send_prepare_timestamp: current_time(), 354 356 # Subtracting @request_start_view_min_elapsed_ms ensures cluster bootstraps a bit faster 355 357 # if the first Prepare is missed during backup replica startup 356 358 # TODO: there are better ways to ensure this, probably ··· 978 980 979 981 # Send messages 980 982 981 981 - defp send_prepare_if_pending_and_enough_elapsed(%State{} = state) when state.commit_number == state.op_number do 983 983 + defp send_prepare_if_pending_and_enough_elapsed(%State{} = state) when state.commit_number == state.op_number or is_nil(state.current_op) do 982 984 # No ops are pending 983 985 state 984 986 end ··· 987 989 assert state.role == :primary 988 990 assert state.status == :normal 989 991 assert state.op_number > state.commit_number 992 992 + assert state.current_op != nil 990 993 991 994 elapsed_us = current_time() - state.last_send_prepare_timestamp 992 995

+1 -1

lib/servers/manager.ex

reviewed

··· 142 142 {:ok, result} -> 143 143 result 144 144 145 145 - {:error, err} when err in [:no_config, :timeout] -> 145 145 + {:error, err} -> 146 146 SimLogger.debug "Manager failed to inc_generation (error=#{inspect(err)}), exiting" 147 147 exit(:shutdown) 148 148 end