From ca075f8f21c2fe76c97541172cbb167621d71e16 Mon Sep 17 00:00:00 2001 From: Feng Date: Tue, 28 Jul 2015 11:05:50 +0800 Subject: [PATCH] pick_worker --- src/emqttd_pooler.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/emqttd_pooler.erl b/src/emqttd_pooler.erl index b284c240e..3f0245250 100644 --- a/src/emqttd_pooler.erl +++ b/src/emqttd_pooler.erl @@ -51,14 +51,14 @@ start_link(I) -> %% @end %%------------------------------------------------------------------------------ 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 %% @end %%------------------------------------------------------------------------------ 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