Browse Source

Clarify test process use.

Roberto Ostinelli 5 years ago
parent
commit
471ddc6e7d
1 changed files with 33 additions and 33 deletions
  1. 33 33
      test/syn_registry_SUITE.erl

+ 33 - 33
test/syn_registry_SUITE.erl

@@ -399,40 +399,40 @@ three_nodes_partial_netsplit_consistency(Config) ->
     timer:sleep(100),
     timer:sleep(100),
     %% start processes
     %% start processes
     Pid0 = syn_test_suite_helper:start_process(),
     Pid0 = syn_test_suite_helper:start_process(),
-    Pid0b = syn_test_suite_helper:start_process(),
+    Pid0Changed = syn_test_suite_helper:start_process(),
     Pid1 = syn_test_suite_helper:start_process(SlaveNode1),
     Pid1 = syn_test_suite_helper:start_process(SlaveNode1),
     Pid2 = syn_test_suite_helper:start_process(SlaveNode2),
     Pid2 = syn_test_suite_helper:start_process(SlaveNode2),
     timer:sleep(100),
     timer:sleep(100),
     %% retrieve
     %% retrieve
     undefined = syn:whereis(<<"proc0">>),
     undefined = syn:whereis(<<"proc0">>),
-    undefined = syn:whereis(<<"proc0b">>),
+    undefined = syn:whereis(<<"proc0b-changed">>),
     undefined = syn:whereis(<<"proc1">>),
     undefined = syn:whereis(<<"proc1">>),
     undefined = syn:whereis(<<"proc2">>),
     undefined = syn:whereis(<<"proc2">>),
     undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
     undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
-    undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b">>]),
+    undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b-changed">>]),
     undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]),
     undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]),
     undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc0">>]),
     undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc0">>]),
-    undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc0b">>]),
+    undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc0b-changed">>]),
     undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc1">>]),
     undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc1">>]),
     undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc2">>]),
     undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc2">>]),
     %% register (mix nodes)
     %% register (mix nodes)
     ok = rpc:call(SlaveNode2, syn, register, [<<"proc0">>, Pid0]),
     ok = rpc:call(SlaveNode2, syn, register, [<<"proc0">>, Pid0]),
     ok = syn:register(<<"proc1">>, Pid1),
     ok = syn:register(<<"proc1">>, Pid1),
     ok = rpc:call(SlaveNode1, syn, register, [<<"proc2">>, Pid2]),
     ok = rpc:call(SlaveNode1, syn, register, [<<"proc2">>, Pid2]),
-    ok = rpc:call(SlaveNode1, syn, register, [<<"proc0b">>, Pid0b]),
+    ok = rpc:call(SlaveNode1, syn, register, [<<"proc0b-changed">>, Pid0Changed]),
     timer:sleep(200),
     timer:sleep(200),
     %% retrieve
     %% retrieve
     Pid0 = syn:whereis(<<"proc0">>),
     Pid0 = syn:whereis(<<"proc0">>),
-    Pid0b = syn:whereis(<<"proc0b">>),
+    Pid0Changed = syn:whereis(<<"proc0b-changed">>),
     Pid1 = syn:whereis(<<"proc1">>),
     Pid1 = syn:whereis(<<"proc1">>),
     Pid2 = syn:whereis(<<"proc2">>),
     Pid2 = syn:whereis(<<"proc2">>),
     Pid0 = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
     Pid0 = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
-    Pid0b = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b">>]),
+    Pid0Changed = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b-changed">>]),
     Pid1 = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     Pid1 = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     Pid2 = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]),
     Pid2 = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]),
     Pid0 = rpc:call(SlaveNode2, syn, whereis, [<<"proc0">>]),
     Pid0 = rpc:call(SlaveNode2, syn, whereis, [<<"proc0">>]),
-    Pid0b = rpc:call(SlaveNode2, syn, whereis, [<<"proc0b">>]),
+    Pid0Changed = rpc:call(SlaveNode2, syn, whereis, [<<"proc0b-changed">>]),
     Pid1 = rpc:call(SlaveNode2, syn, whereis, [<<"proc1">>]),
     Pid1 = rpc:call(SlaveNode2, syn, whereis, [<<"proc1">>]),
     Pid2 = rpc:call(SlaveNode2, syn, whereis, [<<"proc2">>]),
     Pid2 = rpc:call(SlaveNode2, syn, whereis, [<<"proc2">>]),
     %% disconnect slave 2 from main (slave 1 can still see slave 2)
     %% disconnect slave 2 from main (slave 1 can still see slave 2)
@@ -440,21 +440,21 @@ three_nodes_partial_netsplit_consistency(Config) ->
     timer:sleep(500),
     timer:sleep(500),
     %% retrieve
     %% retrieve
     Pid0 = syn:whereis(<<"proc0">>),
     Pid0 = syn:whereis(<<"proc0">>),
-    Pid0b = syn:whereis(<<"proc0b">>),
+    Pid0Changed = syn:whereis(<<"proc0b-changed">>),
     Pid1 = syn:whereis(<<"proc1">>),
     Pid1 = syn:whereis(<<"proc1">>),
     undefined = syn:whereis(<<"proc2">>), %% main has lost slave 2 so 'proc2' is removed
     undefined = syn:whereis(<<"proc2">>), %% main has lost slave 2 so 'proc2' is removed
     Pid0 = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
     Pid0 = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
-    Pid0b = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b">>]),
+    Pid0Changed = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b-changed">>]),
     Pid1 = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     Pid1 = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     Pid2 = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]), %% slave 1 still has slave 2 so 'proc2' is still there
     Pid2 = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]), %% slave 1 still has slave 2 so 'proc2' is still there
     %% disconnect slave 1
     %% disconnect slave 1
     syn_test_suite_helper:disconnect_node(SlaveNode1),
     syn_test_suite_helper:disconnect_node(SlaveNode1),
     timer:sleep(500),
     timer:sleep(500),
     %% unregister 0b
     %% unregister 0b
-    ok = syn:unregister(<<"proc0b">>),
+    ok = syn:unregister(<<"proc0b-changed">>),
     %% retrieve
     %% retrieve
     Pid0 = syn:whereis(<<"proc0">>),
     Pid0 = syn:whereis(<<"proc0">>),
-    undefined = syn:whereis(<<"proc0b">>),
+    undefined = syn:whereis(<<"proc0b-changed">>),
     undefined = syn:whereis(<<"proc1">>),
     undefined = syn:whereis(<<"proc1">>),
     undefined = syn:whereis(<<"proc2">>),
     undefined = syn:whereis(<<"proc2">>),
     %% reconnect all
     %% reconnect all
@@ -463,15 +463,15 @@ three_nodes_partial_netsplit_consistency(Config) ->
     timer:sleep(5000),
     timer:sleep(5000),
     %% retrieve
     %% retrieve
     Pid0 = syn:whereis(<<"proc0">>),
     Pid0 = syn:whereis(<<"proc0">>),
-    undefined = syn:whereis(<<"proc0b">>),
+    undefined = syn:whereis(<<"proc0b-changed">>),
     Pid1 = syn:whereis(<<"proc1">>),
     Pid1 = syn:whereis(<<"proc1">>),
     Pid2 = syn:whereis(<<"proc2">>),
     Pid2 = syn:whereis(<<"proc2">>),
     Pid0 = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
     Pid0 = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
-    undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b">>]),
+    undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b-changed">>]),
     Pid1 = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     Pid1 = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     Pid2 = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]),
     Pid2 = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]),
     Pid0 = rpc:call(SlaveNode2, syn, whereis, [<<"proc0">>]),
     Pid0 = rpc:call(SlaveNode2, syn, whereis, [<<"proc0">>]),
-    undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc0b">>]),
+    undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc0b-changed">>]),
     Pid1 = rpc:call(SlaveNode2, syn, whereis, [<<"proc1">>]),
     Pid1 = rpc:call(SlaveNode2, syn, whereis, [<<"proc1">>]),
     Pid2 = rpc:call(SlaveNode2, syn, whereis, [<<"proc2">>]),
     Pid2 = rpc:call(SlaveNode2, syn, whereis, [<<"proc2">>]),
     %% kill processes
     %% kill processes
@@ -490,40 +490,40 @@ three_nodes_full_netsplit_consistency(Config) ->
     timer:sleep(100),
     timer:sleep(100),
     %% start processes
     %% start processes
     Pid0 = syn_test_suite_helper:start_process(),
     Pid0 = syn_test_suite_helper:start_process(),
-    Pid0b = syn_test_suite_helper:start_process(),
+    Pid0Changed = syn_test_suite_helper:start_process(),
     Pid1 = syn_test_suite_helper:start_process(SlaveNode1),
     Pid1 = syn_test_suite_helper:start_process(SlaveNode1),
     Pid2 = syn_test_suite_helper:start_process(SlaveNode2),
     Pid2 = syn_test_suite_helper:start_process(SlaveNode2),
     timer:sleep(100),
     timer:sleep(100),
     %% retrieve
     %% retrieve
     undefined = syn:whereis(<<"proc0">>),
     undefined = syn:whereis(<<"proc0">>),
-    undefined = syn:whereis(<<"proc0b">>),
+    undefined = syn:whereis(<<"proc0b-changed">>),
     undefined = syn:whereis(<<"proc1">>),
     undefined = syn:whereis(<<"proc1">>),
     undefined = syn:whereis(<<"proc2">>),
     undefined = syn:whereis(<<"proc2">>),
     undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
     undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
-    undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b">>]),
+    undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b-changed">>]),
     undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]),
     undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]),
     undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc0">>]),
     undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc0">>]),
-    undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc0b">>]),
+    undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc0b-changed">>]),
     undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc1">>]),
     undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc1">>]),
     undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc2">>]),
     undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc2">>]),
     %% register (mix nodes)
     %% register (mix nodes)
     ok = rpc:call(SlaveNode2, syn, register, [<<"proc0">>, Pid0]),
     ok = rpc:call(SlaveNode2, syn, register, [<<"proc0">>, Pid0]),
-    ok = rpc:call(SlaveNode2, syn, register, [<<"proc0b">>, Pid0b]),
+    ok = rpc:call(SlaveNode2, syn, register, [<<"proc0b-changed">>, Pid0Changed]),
     ok = syn:register(<<"proc1">>, Pid1),
     ok = syn:register(<<"proc1">>, Pid1),
     ok = rpc:call(SlaveNode1, syn, register, [<<"proc2">>, Pid2]),
     ok = rpc:call(SlaveNode1, syn, register, [<<"proc2">>, Pid2]),
     timer:sleep(200),
     timer:sleep(200),
     %% retrieve
     %% retrieve
     Pid0 = syn:whereis(<<"proc0">>),
     Pid0 = syn:whereis(<<"proc0">>),
-    Pid0b = syn:whereis(<<"proc0b">>),
+    Pid0Changed = syn:whereis(<<"proc0b-changed">>),
     Pid1 = syn:whereis(<<"proc1">>),
     Pid1 = syn:whereis(<<"proc1">>),
     Pid2 = syn:whereis(<<"proc2">>),
     Pid2 = syn:whereis(<<"proc2">>),
     Pid0 = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
     Pid0 = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
-    Pid0b = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b">>]),
+    Pid0Changed = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b-changed">>]),
     Pid1 = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     Pid1 = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     Pid2 = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]),
     Pid2 = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]),
     Pid0 = rpc:call(SlaveNode2, syn, whereis, [<<"proc0">>]),
     Pid0 = rpc:call(SlaveNode2, syn, whereis, [<<"proc0">>]),
-    Pid0b = rpc:call(SlaveNode2, syn, whereis, [<<"proc0b">>]),
+    Pid0Changed = rpc:call(SlaveNode2, syn, whereis, [<<"proc0b-changed">>]),
     Pid1 = rpc:call(SlaveNode2, syn, whereis, [<<"proc1">>]),
     Pid1 = rpc:call(SlaveNode2, syn, whereis, [<<"proc1">>]),
     Pid2 = rpc:call(SlaveNode2, syn, whereis, [<<"proc2">>]),
     Pid2 = rpc:call(SlaveNode2, syn, whereis, [<<"proc2">>]),
     %% disconnect slave 2 from main (slave 1 can still see slave 2)
     %% disconnect slave 2 from main (slave 1 can still see slave 2)
@@ -531,11 +531,11 @@ three_nodes_full_netsplit_consistency(Config) ->
     timer:sleep(500),
     timer:sleep(500),
     %% retrieve
     %% retrieve
     Pid0 = syn:whereis(<<"proc0">>),
     Pid0 = syn:whereis(<<"proc0">>),
-    Pid0b = syn:whereis(<<"proc0b">>),
+    Pid0Changed = syn:whereis(<<"proc0b-changed">>),
     Pid1 = syn:whereis(<<"proc1">>),
     Pid1 = syn:whereis(<<"proc1">>),
     undefined = syn:whereis(<<"proc2">>), %% main has lost slave 2 so 'proc2' is removed
     undefined = syn:whereis(<<"proc2">>), %% main has lost slave 2 so 'proc2' is removed
     Pid0 = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
     Pid0 = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
-    Pid0b = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b">>]),
+    Pid0Changed = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b-changed">>]),
     Pid1 = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     Pid1 = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     Pid2 = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]), %% slave 1 still has slave 2 so 'proc2' is still there
     Pid2 = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]), %% slave 1 still has slave 2 so 'proc2' is still there
     %% disconnect slave 2 from slave 1
     %% disconnect slave 2 from slave 1
@@ -543,22 +543,22 @@ three_nodes_full_netsplit_consistency(Config) ->
     timer:sleep(500),
     timer:sleep(500),
     %% retrieve
     %% retrieve
     Pid0 = syn:whereis(<<"proc0">>),
     Pid0 = syn:whereis(<<"proc0">>),
-    Pid0b = syn:whereis(<<"proc0b">>),
+    Pid0Changed = syn:whereis(<<"proc0b-changed">>),
     Pid1 = syn:whereis(<<"proc1">>),
     Pid1 = syn:whereis(<<"proc1">>),
     undefined = syn:whereis(<<"proc2">>), %% main has lost slave 2 so 'proc2' is removed
     undefined = syn:whereis(<<"proc2">>), %% main has lost slave 2 so 'proc2' is removed
     undefined = syn:whereis(<<"proc2">>, with_meta),
     undefined = syn:whereis(<<"proc2">>, with_meta),
     Pid0 = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
     Pid0 = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
-    Pid0b = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b">>]),
+    Pid0Changed = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b-changed">>]),
     Pid1 = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     Pid1 = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]),
     undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]),
     %% disconnect slave 1
     %% disconnect slave 1
     syn_test_suite_helper:disconnect_node(SlaveNode1),
     syn_test_suite_helper:disconnect_node(SlaveNode1),
     timer:sleep(500),
     timer:sleep(500),
     %% unregister
     %% unregister
-    ok = syn:unregister(<<"proc0b">>),
+    ok = syn:unregister(<<"proc0b-changed">>),
     %% retrieve
     %% retrieve
     Pid0 = syn:whereis(<<"proc0">>),
     Pid0 = syn:whereis(<<"proc0">>),
-    undefined = syn:whereis(<<"proc0b">>),
+    undefined = syn:whereis(<<"proc0b-changed">>),
     undefined = syn:whereis(<<"proc1">>),
     undefined = syn:whereis(<<"proc1">>),
     undefined = syn:whereis(<<"proc2">>),
     undefined = syn:whereis(<<"proc2">>),
     %% reconnect all
     %% reconnect all
@@ -568,20 +568,20 @@ three_nodes_full_netsplit_consistency(Config) ->
     timer:sleep(1500),
     timer:sleep(1500),
     %% retrieve
     %% retrieve
     Pid0 = syn:whereis(<<"proc0">>),
     Pid0 = syn:whereis(<<"proc0">>),
-    undefined = syn:whereis(<<"proc0b">>),
+    undefined = syn:whereis(<<"proc0b-changed">>),
     Pid1 = syn:whereis(<<"proc1">>),
     Pid1 = syn:whereis(<<"proc1">>),
     Pid2 = syn:whereis(<<"proc2">>),
     Pid2 = syn:whereis(<<"proc2">>),
     Pid0 = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
     Pid0 = rpc:call(SlaveNode1, syn, whereis, [<<"proc0">>]),
-    undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b">>]),
+    undefined = rpc:call(SlaveNode1, syn, whereis, [<<"proc0b-changed">>]),
     Pid1 = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     Pid1 = rpc:call(SlaveNode1, syn, whereis, [<<"proc1">>]),
     Pid2 = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]),
     Pid2 = rpc:call(SlaveNode1, syn, whereis, [<<"proc2">>]),
     Pid0 = rpc:call(SlaveNode2, syn, whereis, [<<"proc0">>]),
     Pid0 = rpc:call(SlaveNode2, syn, whereis, [<<"proc0">>]),
-    undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc0b">>]),
+    undefined = rpc:call(SlaveNode2, syn, whereis, [<<"proc0b-changed">>]),
     Pid1 = rpc:call(SlaveNode2, syn, whereis, [<<"proc1">>]),
     Pid1 = rpc:call(SlaveNode2, syn, whereis, [<<"proc1">>]),
     Pid2 = rpc:call(SlaveNode2, syn, whereis, [<<"proc2">>]),
     Pid2 = rpc:call(SlaveNode2, syn, whereis, [<<"proc2">>]),
     %% kill processes
     %% kill processes
     syn_test_suite_helper:kill_process(Pid0),
     syn_test_suite_helper:kill_process(Pid0),
-    syn_test_suite_helper:kill_process(Pid0b),
+    syn_test_suite_helper:kill_process(Pid0Changed),
     syn_test_suite_helper:kill_process(Pid1),
     syn_test_suite_helper:kill_process(Pid1),
     syn_test_suite_helper:kill_process(Pid2).
     syn_test_suite_helper:kill_process(Pid2).