This commit is contained in:
parent
134d958be8
commit
05c09d10f3
@ -225,7 +225,7 @@ defmodule Paxos do
|
|||||||
prepare(st, inst)
|
prepare(st, inst)
|
||||||
end)
|
end)
|
||||||
|
|
||||||
# Handles a proposal from the parent process
|
# Handles a proposal message from the parent process
|
||||||
{:propose, inst, value, pid_to_inform, action} ->
|
{:propose, inst, value, pid_to_inform, action} ->
|
||||||
log("#{state.name} - Propose #{inspect(inst)} with action #{inspect(action)}")
|
log("#{state.name} - Propose #{inspect(inst)} with action #{inspect(action)}")
|
||||||
|
|
||||||
@ -320,7 +320,7 @@ defmodule Paxos do
|
|||||||
state
|
state
|
||||||
end
|
end
|
||||||
|
|
||||||
# Handles a nack
|
# Handles a nack message
|
||||||
{:nack, inst, ballot} ->
|
{:nack, inst, ballot} ->
|
||||||
log("#{state.name} - nack #{inspect(inst)} #{inspect(ballot)}")
|
log("#{state.name} - nack #{inspect(inst)} #{inspect(ballot)}")
|
||||||
|
|
||||||
@ -348,7 +348,7 @@ defmodule Paxos do
|
|||||||
state
|
state
|
||||||
end
|
end
|
||||||
|
|
||||||
# Handles an abort
|
# Handles an abort message
|
||||||
{:rb_deliver, _proc, {:abort, inst, _}} ->
|
{:rb_deliver, _proc, {:abort, inst, _}} ->
|
||||||
cond do
|
cond do
|
||||||
has_finished(state, inst) ->
|
has_finished(state, inst) ->
|
||||||
@ -421,7 +421,7 @@ defmodule Paxos do
|
|||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
# Handles a accept
|
# Handles an accept message
|
||||||
# Sends out accept when a decide when a quoeom is met
|
# Sends out accept when a decide when a quoeom is met
|
||||||
{:accepted, inst, ballot} ->
|
{:accepted, inst, ballot} ->
|
||||||
log("#{state.name} - accepted #{inspect(inst)} #{inspect(ballot)}")
|
log("#{state.name} - accepted #{inspect(inst)} #{inspect(ballot)}")
|
||||||
|
Reference in New Issue
Block a user