Skip to content
This repository was archived by the owner on Dec 17, 2024. It is now read-only.

Commit 015b15e

Browse files
author
Jon Elverkilde
committed
Merge pull request #12 from andonov/max_worker_api
exported get_max_workers/1
2 parents 65834e8 + f682c59 commit 015b15e

File tree

1 file changed

+10
-1
lines changed

1 file changed

+10
-1
lines changed

src/gascheduler.erl

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,8 @@
1313
stats/1,
1414
unfinished/1,
1515
set_retry_timeout/2,
16-
set_max_workers/2
16+
set_max_workers/2,
17+
get_max_workers/1
1718
]).
1819

1920
%% For workers
@@ -119,6 +120,11 @@ set_retry_timeout(Name, RetryTimeout) ->
119120
set_max_workers(Name, Workers) ->
120121
gen_server:call(Name, {set_max_workers, Workers}).
121122

123+
-spec get_max_workers(atom()) -> non_neg_integer().
124+
get_max_workers(Name) ->
125+
gen_server:call(Name, get_max_workers).
126+
127+
122128

123129
%%% For workers
124130

@@ -190,6 +196,9 @@ handle_call({set_retry_timeout, Timeout}, _From, State) ->
190196
handle_call({set_max_workers, Workers}, _From, State) ->
191197
{reply, ok, State#state{max_workers = Workers}};
192198

199+
handle_call(get_max_workers, _From, State) ->
200+
{reply, ok, State#state.max_workers};
201+
193202
handle_call(_Request, _From, State) ->
194203
{reply, ok, State}.
195204

0 commit comments

Comments
 (0)