@@ -139,7 +139,7 @@ start_link() ->
139
139
InitLazys = [],
140
140
plumtree_util :log (debug , " init peers, eager: ~p , lazy: ~p " ,
141
141
[InitEagers , InitLazys ]),
142
- Mods = app_helper :get_env (plumtree , broadcast_mods , []),
142
+ Mods = application :get_env (plumtree , broadcast_mods , []),
143
143
Res = start_link (Members , InitEagers , InitLazys , Mods ,
144
144
[{lazy_tick_period , LazyTickPeriod },
145
145
{exchange_tick_period , ExchangeTickPeriod }]),
@@ -473,7 +473,7 @@ maybe_exchange(undefined, State) ->
473
473
maybe_exchange (Peer , State = # state {mods = [Mod | _ ], exchanges = Exchanges }) ->
474
474
% % limit the number of exchanges this node can start concurrently.
475
475
% % the exchange must (currently?) implement any "inbound" concurrency limits
476
- ExchangeLimit = app_helper :get_env (plumtree , broadcast_start_exchange_limit , 1 ),
476
+ ExchangeLimit = application :get_env (plumtree , broadcast_start_exchange_limit , 1 ),
477
477
BelowLimit = not (length (Exchanges ) >= ExchangeLimit ),
478
478
FreeMod = lists :keyfind (Mod , 1 , Exchanges ) =:= false ,
479
479
case BelowLimit and FreeMod of
@@ -660,7 +660,7 @@ schedule_exchange_tick(Period) ->
660
660
schedule_tick (exchange_tick , broadcast_exchange_timer , Period ).
661
661
662
662
schedule_tick (Message , Timer , Default ) ->
663
- TickMs = app_helper :get_env (plumtree , Timer , Default ),
663
+ TickMs = application :get_env (plumtree , Timer , Default ),
664
664
erlang :send_after (TickMs , ? MODULE , Message ).
665
665
666
666
reset_peers (AllMembers , EagerPeers , LazyPeers , State ) ->
0 commit comments