commit 408096f5537793a057bdcf2a1db01aee9c3f74dd
author Nick Vatamaniuc <vatamane@apache.org> Tue Aug 01 22:20:11 2017 -0400
committer Nick Vatamaniuc <nickva@users.noreply.github.com> Wed Aug 02 01:37:38 2017 -0400
tree 11910350b6e1e0987cc73aa53530deef4c14df6d
parent f728209102a84d669f81431dea0bd0d60655a12f

Fix timeouts in couch epi tests

Sleeps there not enough when run in a contrained test environment

Adjust timeouts to let tests pass even when setting CPU usage limit down to
1% in my VirtualBox VM.

Also switch to using macro defines to make it look slightly cleaner.

Fixes #731

src/couch_epi/test/couch_epi_tests.erl

diff --git a/src/couch_epi/test/couch_epi_tests.erl b/src/couch_epi/test/couch_epi_tests.erl
index bde85a8..99a06f3 100644
--- a/src/couch_epi/test/couch_epi_tests.erl
+++ b/src/couch_epi/test/couch_epi_tests.erl
@@ -22,6 +22,7 @@
 -record(ctx, {file, handle, pid, kv, key, modules = []}).
 
 -define(TIMEOUT, 5000).
+-define(RELOAD_WAIT, 1000).
 
 -define(temp_atom,
     fun() ->
@@ -392,7 +393,7 @@
 ensure_not_notified_when_no_change(_Case, #ctx{key = Key} = Ctx) ->
     ?_test(begin
         subscribe(Ctx, test_app, Key),
-        timer:sleep(200),
+        timer:sleep(?RELOAD_WAIT),
         ?assertMatch(error, get(Ctx, is_called))
     end).
 
@@ -495,7 +496,7 @@
         subscribe(Ctx, test_app, Key),
         update_definitions(Case, Ctx),
         couch_epi_module_keeper:reload(Pid),
-        timer:sleep(50),
+        timer:sleep(?RELOAD_WAIT),
         ?assertNotEqual(error, get(Ctx, is_called))
     end).
 
@@ -505,7 +506,7 @@
         Version = Handle:version(),
         subscribe(Ctx, test_app, Key),
         update_definitions(Case, Ctx),
-        timer:sleep(250),
+        timer:sleep(?RELOAD_WAIT),
         ?assertNotEqual(Version, Handle:version()),
         ?assertNotEqual(error, get(Ctx, is_called))
     end);
@@ -516,7 +517,7 @@
         subscribe(Ctx, test_app, Key),
         update(Case, Ctx),
         ?assertNotEqual(Version, Handle:version()),
-        timer:sleep(100), %% Allow some time for notify to be called
+        timer:sleep(?RELOAD_WAIT), %% Allow some time for notify to be called
         ?assertNotEqual(error, get(Ctx, is_called))
     end).
 
@@ -534,7 +535,7 @@
     ?_test(begin
         Version = Handle:version(),
         subscribe(Ctx, test_app, Key),
-        timer:sleep(450),
+        timer:sleep(?RELOAD_WAIT),
         ?assertEqual(Version, Handle:version()),
         ?assertEqual(error, get(Ctx, is_called))
     end).
@@ -576,7 +577,7 @@
 maybe_wait(Opts) ->
     case lists:member(concurrent, Opts) of
         true ->
-            timer:sleep(100);
+            timer:sleep(?RELOAD_WAIT);
         false ->
             ok
     end.
@@ -584,7 +585,7 @@
 wait_update(Ctx) ->
     case get(Ctx, is_called) of
         error ->
-            timer:sleep(100),
+            timer:sleep(?RELOAD_WAIT),
             wait_update(Ctx);
         _ -> ok
     end.