X-Git-Url: https://git.squeep.com/?a=blobdiff_plain;f=test%2Fsupport%2Fcluster.ex;h=6826439880e9ba6c21afd3203c2a3a5ed1dfe49a;hb=dcac8adb3de7fb5545f6c6f18c9e1d5d82606594;hp=deb37f361cb058bacc3139589dea56bf813907e1;hpb=7722e5a67a46304f3ae0e37f674a44ca9268be5e;p=akkoma diff --git a/test/support/cluster.ex b/test/support/cluster.ex index deb37f361..682643988 100644 --- a/test/support/cluster.ex +++ b/test/support/cluster.ex @@ -96,8 +96,8 @@ defmodule Pleroma.Cluster do silence_logger_warnings(fn -> node_configs - |> Enum.map(&Task.async(fn -> start_slave(&1) end)) - |> Enum.map(&Task.await(&1, 60_000)) + |> Enum.map(&Task.async(fn -> start_peer(&1) end)) + |> Enum.map(&Task.await(&1, 90_000)) end) end @@ -121,9 +121,12 @@ defmodule Pleroma.Cluster do result end - defp start_slave({node_host, override_configs}) do + defp start_peer({node_host, override_configs}) do log(node_host, "booting federated VM") - {:ok, node} = :slave.start(~c"127.0.0.1", node_name(node_host), vm_args()) + + {:ok, _pid, node} = + :peer.start(%{host: ~c"127.0.0.1", name: node_name(node_host), args: vm_args()}) + add_code_paths(node) load_apps_and_transfer_configuration(node, override_configs) ensure_apps_started(node)