KirinDave / fuzed

A new revision of Fuzed, the Erlang-based frontend for web apps. Check out the mailing list at http://groups.google.com/group/fuzed

fuzed / elibs / fuzed_frontend_supervisor.erl
100644 55 lines (44 sloc) 1.314 kb
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
-module(fuzed_frontend_supervisor).
-behaviour(supervisor).
-export([start/0, start_shell/0, start_link/1, init/1]).
-include("../include/fuzed.hrl").
 
% Supervisor Functions
 
start() ->
  spawn(fun() ->
    supervisor:start_link({local, ?MODULE}, ?MODULE, _Arg = [])
  end).
  
start_shell() ->
  {ok, Pid} = supervisor:start_link({local, ?MODULE}, ?MODULE, _Arg = []),
  unlink(Pid).
  
start_link(Args) ->
  supervisor:start_link({local, ?MODULE}, ?MODULE, Args).
  
 
init([]) ->
  Master = application:get_env(master),
  {ok, DocRoot} = application:get_env(docroot),
  {ok, Port} = application:get_env(port),
  case Master of
    {ok, MasterNode} ->
      ping_master(MasterNode);
    undefined ->
      MasterNode = node()
  end,
  frontend_yaws:setup(Port, DocRoot),
  {ok, {{one_for_one, 10, 600},
        [{master_beater,
          {master_beater, start_link, [MasterNode, ?GLOBAL_TIMEOUT, ?SLEEP_CYCLE]},
          permanent,
          10000,
          worker,
          [master_beater]}
        ]}}.
  
 
% Helper functions
 
ping_master(Node) ->
  case net_adm:ping(Node) of
    pong ->
      timer:sleep(?SLEEP_CYCLE),
      ok;
    pang ->
      error_logger:info_msg("Master node ~p not available. Retrying in 5 seconds.~n", [Node]),
      timer:sleep(?SLEEP_CYCLE),
      ping_master(Node)
  end.