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

Fix (via sleep, egadz) race condition in machi_flu_psup_test

Browse source
This commit is contained in:
Scott Lystig Fritchie 2015-08-26 14:38:56 +09:00
parent e6f8e3516e
commit 27656eafaa
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
test/machi_flu_psup_test.erl
View file

@ -135,11 +135,12 @@ partial_stop_restart2() ->
{FluName_a, _} = hd(Ps), {FluName_a, _} = hd(Ps),
ok = machi_flu_psup:stop_flu_package(FluName_a), ok = machi_flu_psup:stop_flu_package(FluName_a),
{ok, _} = Start(hd(Ps)), {ok, _} = Start(hd(Ps)),
timer:sleep(123), % TODO fix server socket available race condition in better way
%% Remember: 'a' is not in active mode. %% Remember: 'a' is not in active mode.
{ok, Proj_m3} = machi_projection_store:read_latest_projection( {ok, Proj_m3} = machi_projection_store:read_latest_projection(
hd(PStores), private), hd(PStores), private),
true = (machi_projection:update_dbg2(Proj_m, []) == true = (machi_projection:update_dbg2(Proj_m, []) ==
machi_projection:update_dbg2(Proj_m, [])), machi_projection:update_dbg2(Proj_m3, [])),
%% Confirm that 'a' is wedged %% Confirm that 'a' is wedged
{error, wedged} = Append(hd(Ps), EpochID1), {error, wedged} = Append(hd(Ps), EpochID1),
{_, #p_srvr{address=Addr_a, port=TcpPort_a}} = hd(Ps), {_, #p_srvr{address=Addr_a, port=TcpPort_a}} = hd(Ps),