yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

pick_worker

This commit is contained in:
Feng 2015-07-28 11:05:50 +08:00
parent c276b6c6d1
commit ca075f8f21
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/emqttd_pooler.erl
View File

@ -51,14 +51,14 @@ start_link(I) ->
%% @end %% @end
%%------------------------------------------------------------------------------ %%------------------------------------------------------------------------------
submit(Fun) -> submit(Fun) ->
gen_server:call(gproc_pool:pick(pooler), {submit, Fun}, infinity). gen_server:call(gproc_pool:pick_worker(pooler), {submit, Fun}, infinity).
%%------------------------------------------------------------------------------ %%------------------------------------------------------------------------------
%% @doc Submit work to pooler asynchronously %% @doc Submit work to pooler asynchronously
%% @end %% @end
%%------------------------------------------------------------------------------ %%------------------------------------------------------------------------------
async_submit(Fun) -> async_submit(Fun) ->
gen_server:cast(gproc_pool:pick(pooler), {async_submit, Fun}). gen_server:cast(gproc_pool:pick_worker(pooler), {async_submit, Fun}).
%%%============================================================================= %%%=============================================================================
%%% gen_server callbacks %%% gen_server callbacks