|
@@ -79,7 +79,13 @@ start_link() ->
|
|
|
start_link({[node()|nodes()], []}).
|
|
|
|
|
|
start_link(all) ->
|
|
|
- start_link({[node()|nodes()], [{bcast_type, all}]});
|
|
|
+ Workers = case application:get_env(gproc_dist_workers) of
|
|
|
+ undefined -> [];
|
|
|
+ {ok, false} -> [];
|
|
|
+ {ok, WorkersList} when is_list(WorkersList) -> WorkersList;
|
|
|
+ {ok, _} -> []
|
|
|
+ end,
|
|
|
+ start_link({[node()|nodes()], [{bcast_type, all}, {workers, Workers}]});
|
|
|
start_link(Nodes) when is_list(Nodes) ->
|
|
|
start_link({Nodes, []});
|
|
|
start_link({Nodes, Opts}) ->
|