test: Fix flakiness when waiting for tables

Author: ieQu1

src/mria_app.erl

@@ -20,6 +20,8 @@
 
 -export([start/2, stop/1]).
 
+-export([ready/0]).
+
 %% Classy hooks
 -export([ on_run_level/2
         , on_node_init/0
@@ -37,6 +39,8 @@
 -include_lib("snabbkaffe/include/trace.hrl").
 -include("mria.hrl").
 
+-define(optvar_ready, mria_app_ready).
+
 %%================================================================================
 %% Application callbacks
 %%================================================================================
@@ -58,6 +62,14 @@ stop(_) ->
     mria_config:erase_all_config(),
     ok.
 
+%%================================================================================
+%% Misc API
+%%================================================================================
+
+-spec ready() -> boolean().
+ready() ->
+    optvar:is_set(?optvar_ready).
+
 %%================================================================================
 %% Classy hooks
 %%================================================================================
@@ -70,8 +82,10 @@ on_node_init() ->
 
 on_run_level(stopped, single) ->
     {ok, _Apps} = application:ensure_all_started(mria),
+    optvar:set(?optvar_ready, true),
     ok;
 on_run_level(single, stopped) ->
+    optvar:unset(?optvar_ready),
     mria:stop();
 on_run_level(_, _) ->
     ok.

test/mria_join_fixture.erl

@@ -13,7 +13,8 @@ init_per_node(Site, _Node, JoinTo, Acc) ->
             case is_peer(JoinTo, Site) of
                 false ->
                     ?assertEqual(ok, familiar:call(Site, classy, join_node, [JoinTo, join])),
-                    ?retry(100, 10, ?assertEqual(true, is_peer(JoinTo, Site)));
+                    ?retry(100, 1000, ?assert(is_peer(JoinTo, Site))),
+                    ?retry(100, 1000, ?assert(familiar:call(Site, mria_app, ready, [])));
                 true ->
                     ok
             end,