greg/machi
1
0
Fork 0
Code Issues 11 Pull requests 1 Projects Releases Packages Wiki Activity Actions

Handle timeout/paritition failures in C110

Browse source
This commit is contained in:
Scott Lystig Fritchie 2015-09-14 13:54:47 +09:00
parent fdf78bdbbc
commit 23554ffccc
1 changed files with 12 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/machi_chain_manager1.erl
View file

@ -1764,6 +1764,18 @@ react_to_env_C110(P_latest, #ch_mgr{name=MyName} = S) ->
%% %%
%% React to newer public write by restarting the iteration. %% React to newer public write by restarting the iteration.
react_to_env_A20(0, S); react_to_env_A20(0, S);
{error, TO_or_part}=Else when TO_or_part == timeout;
TO_or_part == partition ->
%% TODO: Hrm, I know that there's currently a bug in the
%% machi_flu1_client that causes use of 'undefined' instead of a
%% valid TCP socket port() that causes {error,partition} problems
%% when talking to remote projection stores. However, I've now
%% twice witnessed (and also recognized ^_^) that this same error
%% can happen when talking to our local projection store. Verrry
%% interesting. Let's assume that this is a very rare
%% happenstance, and when it does happen, we just punt and go to
%% A50.
react_to_env_A50(P_latest, [{c110_error,Else}], S);
Else -> Else ->
Summ = machi_projection:make_summary(P_latest2), Summ = machi_projection:make_summary(P_latest2),
io:format(user, "C110 error by ~w: ~w, ~w\n~p\n", io:format(user, "C110 error by ~w: ~w, ~w\n~p\n",