Sha256: c3b67a83693f4e88722e6491dee7e74c563460626d9dca173d2063c517232f7d
Contents?: true
Size: 1.27 KB
Versions: 8
Compression:
Stored size: 1.27 KB
Contents
-module(pm_cluster).
-ifdef(EUNIT).
-include_lib("eunit/include/eunit.hrl").
-endif.
-export ([slaves/1, slaves/0]).
-export ([get_live_nodes/0,refresh_live_nodes/0]).
-export ([send_call/2, master/0]).
send_call(Type, Args) ->
Nodes = get_live_nodes(),
rpc:multicall(Nodes, pm_node, Type, [Args]).
master() ->
{erlang:node()}.
slaves([]) ->
ok;
slaves([Host|Hosts]) ->
Args = erl_system_args(),
NodeName = "pp_cluster",
{ok, Node} = slave:start_link(Host, NodeName, Args),
io:format("Erlang node started = [~p]~n", [Node]),
slaves(Hosts).
slaves() ->
get_live_nodes().
erl_system_args()->
Shared = case init:get_argument(shared) of
error -> " ";
{ok,[[]]} -> " -shared "
end,
lists:append(
["-rsh ssh -setcookie",
atom_to_list(erlang:get_cookie()),
Shared, " +Mea r10b "
]).
refresh_live_nodes() ->
String = ". /etc/profile && server-list-active -c name",
Nodes = string:tokens(os:cmd(String), "\n\t"),
io:format("nodes: ~p~n", [Nodes]),
lists:map(
fun(No) ->
io:format("pinging ~p~n", [list_to_atom(lists:append("pp_cluster@",No))]),
net_adm:ping(list_to_atom(lists:append("@pp_cluster", No)))
end,
Nodes),
ok.
% Get the live nodes
get_live_nodes() ->
nodes().
%% Do not forget to start erlang with a command like:
%% erl -rsh ssh -sname clustmaster
Version data entries
8 entries across 8 versions & 2 rubygems