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

Automate check for unanimous all_hosed

Browse source
This commit is contained in:
Scott Lystig Fritchie 2015-03-06 00:02:25 +09:00
parent f2ee7b5045
commit e0c6aeac94
1 changed files with 37 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
prototype/chain-manager/test/machi_chain_manager1_test.erl
View file

@ -382,7 +382,12 @@ convergence_demo_test(_) ->
XandYs2 = [[{X,Y}, {A,B}] || X <- All_list, Y <- All_list, X /= Y, XandYs2 = [[{X,Y}, {A,B}] || X <- All_list, Y <- All_list, X /= Y,
A <- All_list, B <- All_list, A /= B, A <- All_list, B <- All_list, A /= B,
X /= A], X /= A],
%% XandYs3 = [[{X,Y}, {A,B}, {C,D}] || X <- All_list, Y <- All_list, X /= Y,
%% A <- All_list, B <- All_list, A /= B,
%% C <- All_list, D <- All_list, C /= D,
%% X /= A, X /= C, A /= C],
AllPartitionCombinations = XandYs1 ++ XandYs2, AllPartitionCombinations = XandYs1 ++ XandYs2,
%% AllPartitionCombinations = XandYs3,
?D({?LINE, length(AllPartitionCombinations)}), ?D({?LINE, length(AllPartitionCombinations)}),
machi_partition_simulator:reset_thresholds(10, 50), machi_partition_simulator:reset_thresholds(10, 50),
@ -396,7 +401,8 @@ convergence_demo_test(_) ->
io:format(user, "\nSET partitions = ~w.\n", [Partition]), io:format(user, "\nSET partitions = ~w.\n", [Partition]),
[DoIt(50, 10, 100) || _ <- [1,2,3,4] ], [DoIt(50, 10, 100) || _ <- [1,2,3,4] ],
true = private_projections_are_stable(Namez, DoIt), true = private_projections_are_stable(Namez, DoIt),
io:format(user, "\nSweet, we converged to a stable state.\n", []), true = all_hosed_lists_are_identical(Namez, Partition),
io:format(user, "\nSweet, we converged & all_hosed are unanimous-or-islands-inconclusive.\n", []),
%% PPP = %% PPP =
%% [begin %% [begin
%% PPPallPubs = machi_flu0:proj_list_all(FLU, public), %% PPPallPubs = machi_flu0:proj_list_all(FLU, public),
@ -408,11 +414,13 @@ convergence_demo_test(_) ->
%% io:format(user, "PPP ~p\n", [lists:sort(lists:append(PPP))]), %% io:format(user, "PPP ~p\n", [lists:sort(lists:append(PPP))]),
timer:sleep(1000), timer:sleep(1000),
ok ok
end || Partition <- AllPartitionCombinations], end || Partition <- AllPartitionCombinations
%% end || Partition <- [ [{c,a}] ] ], %% end || Partition <- [ [{c,a}] ]
%% end || Partition <- [ [{c,a}], [{c,b}, {a, b}] ] ], %% end || Partition <- [ [{c,a}], [{c,b}, {a, b}] ]
%% end || Partition <- [ [{a,b},{b,a}, {a,c},{c,a}, {a,d},{d,a}, {b,c}], %% end || Partition <- [ [{a,b},{b,a}, {a,c},{c,a}, {a,d},{d,a}],
%% [{a,b},{b,a}, {a,c},{c,a}, {a,d},{d,a}, {c,d}] ] ], %% [{a,b},{b,a}, {a,c},{c,a}, {a,d},{d,a}, {b,c}],
%% [{a,b},{b,a}, {a,c},{c,a}, {a,d},{d,a}, {c,d}] ]
],
%% exit(end_experiment), %% exit(end_experiment),
io:format(user, "\nSET partitions = []\n", []), io:format(user, "\nSET partitions = []\n", []),
@ -475,5 +483,28 @@ private_projections_are_stable(Namez, PollFunc) ->
{_Name, FLU} <- Namez], {_Name, FLU} <- Namez],
true = (Private1 == Private2). true = (Private1 == Private2).
all_hosed_lists_are_identical(Namez, Partition) ->
Ps = [machi_flu0:proj_read_latest(FLU, private) || {_Name, FLU} <- Namez],
Uniques = lists:usort([machi_chain_manager1:get_all_hosed(P) ||
{ok, P} <- Ps]),
Members = [M || {M, _Pid} <- Namez],
Islands = machi_partition_simulator:partitions2num_islands(
Members, Partition),
%% io:format(user, "all_hosed_lists_are_identical:\n", []),
%% io:format(user, " Uniques = ~p Islands ~p\n Partition ~p\n",
%% [Uniques, Islands, Partition]),
case length(Uniques) of
1 ->
true;
_ when Islands == 'many' ->
%% There are at least two partitions, so yes, it's quite
%% possible that the all_hosed lists may differ.
%% TODO Fix this up to be smarter about fully-isolated
%% islands of partition.
true;
_ ->
false
end.
-endif. % not PULSE -endif. % not PULSE
-endif. % TEST -endif. % TEST