rel/files/app.config

@@ -1 +1,22 @@
-[].
+[
+ {machi, [
+          %% Data directory for all FLUs.
+          {flu_data_dir, "{{platform_data_dir}}"},
+
+          %% FLUs to start at app start.
+          {initial_flus, [
+                          %% Remember, this is a list, so separate all tuples
+                          %% with a comma.
+                          %%
+                          %% {Name::atom(), Port::pos_integer(), proplist()}
+                          %%
+                          %% For example: {my_name_is_a, 12500, []}
+
+                         ]},
+
+          %% Number of metadata manager processes to run per FLU.
+          %% Default = 10
+          %% {metadata_manager_count, 2}
+         ]
+  }
+].

src/machi_flu_psup.erl

@@ -73,7 +73,7 @@
 -endif.
 
 %% External API
--export([make_package_spec/4,
+-export([make_package_spec/1, make_package_spec/4,
          start_flu_package/1, start_flu_package/4, stop_flu_package/1]).
 %% Internal API
 -export([start_link/4,
@@ -83,13 +83,18 @@
 %% Supervisor callbacks
 -export([init/1]).
 
+make_package_spec({FluName, TcpPort, Props}) when is_list(Props) ->
+    FluDataDir = get_env(flu_data_dir, undefined_is_invalid),
+    MyDataDir = filename:join(FluDataDir, atom_to_list(FluName)),
+    make_package_spec(FluName, TcpPort, MyDataDir, Props).
+
 make_package_spec(FluName, TcpPort, DataDir, Props) ->
     {FluName, {machi_flu_psup, start_link,
                [FluName, TcpPort, DataDir, Props]},
      permanent, ?SHUTDOWN, supervisor, []}.
 
 start_flu_package(#p_srvr{name=FluName, port=TcpPort, props=Props}) ->
-    DataDir = proplists:get_value(data_dir, Props),
+    DataDir = get_data_dir(Props),
     start_flu_package(FluName, TcpPort, DataDir, Props).
 
 start_flu_package(FluName, TcpPort, DataDir, Props) ->
@@ -169,3 +174,9 @@ get_env(Setting, Default) ->
         undefined -> Default;
         {ok, V} -> V
     end.
+
+get_data_dir(Props) ->
+    case proplists:get_value(data_dir, Props) of
+        Path when is_list(Path) ->
+            Path
+    end.

src/machi_flu_sup.erl

@@ -60,9 +60,7 @@ init([]) ->
                                     {read_concurrency,true}]),
 
     Ps = get_initial_flus(),
-    FLU_specs = [machi_flu_psup:make_package_spec(FluName, TcpPort,
-                                                  DataDir, Props) ||
-                    {FluName, TcpPort, DataDir, Props} <- Ps],
+    FLU_specs = [machi_flu_psup:make_package_spec(P) || P <- Ps],
 
     {ok, {SupFlags, FLU_specs}}.