From 0df59934c7704300964a05917d95e984ae79ea7a Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Mon, 13 Mar 2017 12:14:57 +0800 Subject: [PATCH] Fix the GPROC_POOL macro --- include/emqttd_internal.hrl | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/include/emqttd_internal.hrl b/include/emqttd_internal.hrl index 72d745646..ede858916 100644 --- a/include/emqttd_internal.hrl +++ b/include/emqttd_internal.hrl @@ -16,19 +16,18 @@ %% Internal Header File --define(GPROC_POOL(JoinOrLeave, Pool, I), +-define(GPROC_POOL(JoinOrLeave, Pool, Id), (begin case JoinOrLeave of - join -> gproc_pool:connect_worker(Pool, {Pool, I}); - leave -> gproc_pool:disconnect_worker(Pool, {Pool, I}) + join -> gproc_pool:connect_worker(Pool, {Pool, Id}); + leave -> gproc_pool:disconnect_worker(Pool, {Pool, Id}) end end)). -define(PROC_NAME(M, I), (list_to_atom(lists:concat([M, "_", I])))). -define(record_to_proplist(Def, Rec), - lists:zip(record_info(fields, Def), - tl(tuple_to_list(Rec)))). + lists:zip(record_info(fields, Def), tl(tuple_to_list(Rec)))). -define(record_to_proplist(Def, Rec, Fields), [{K, V} || {K, V} <- ?record_to_proplist(Def, Rec),