join_cluster.erl

   1 -module(join_cluster).
   2 -compile(export_all).
   3
   4 start(Server, Command) ->
   5   code:add_patha("./elibs"),
   6   erlang:set_cookie(node(), 'AWZVAQXUPGVPKZQLYEUP'),
   7   net_adm:ping(Server), sleep_in_HEAVENLY_PEACE(2),
   8   start_resource_manager(Command, 1).
   9
  10 start_resource_manager(Command, N) ->
  11   Spawner = fun() ->
  12     Responder = port_wrapper:wrap(Command),
  13     rails_connection_pool:add({node(), Responder}),
  14     Responder
  15   end,
  16   Slayer = fun(Responder) ->
  17     Responder ! shutdown,
  18     rails_connection_pool:remove({node(), Responder})
  19   end,
  20   resource_manager:start(Spawner,Slayer,N).
  21
  22 sleep_in_HEAVENLY_PEACE(Secs) ->
  23   receive
  24   after Secs * 1000 ->
  25     Secs * 1000
  26   end.