|
@@ -1247,7 +1247,7 @@ recv_msgs(Count, Msgs) ->
|
|
|
start_peer(Name, Port) ->
|
|
start_peer(Name, Port) ->
|
|
|
{ok, Node} = emqx_cth_peer:start_link(
|
|
{ok, Node} = emqx_cth_peer:start_link(
|
|
|
Name,
|
|
Name,
|
|
|
- ebin_path()
|
|
|
|
|
|
|
+ emqx_common_test_helpers:ebin_path()
|
|
|
),
|
|
),
|
|
|
pong = net_adm:ping(Node),
|
|
pong = net_adm:ping(Node),
|
|
|
setup_node(Node, Port),
|
|
setup_node(Node, Port),
|
|
@@ -1261,9 +1261,6 @@ host() ->
|
|
|
[_, Host] = string:tokens(atom_to_list(node()), "@"),
|
|
[_, Host] = string:tokens(atom_to_list(node()), "@"),
|
|
|
Host.
|
|
Host.
|
|
|
|
|
|
|
|
-ebin_path() ->
|
|
|
|
|
- ["-pa" | code:get_path()].
|
|
|
|
|
-
|
|
|
|
|
setup_node(Node, Port) ->
|
|
setup_node(Node, Port) ->
|
|
|
EnvHandler =
|
|
EnvHandler =
|
|
|
fun(_) ->
|
|
fun(_) ->
|