61 lines
2.0 KiB
Erlang
61 lines
2.0 KiB
Erlang
%%--------------------------------------------------------------------
|
|
%% Copyright (c) 2012-2016 Feng Lee <feng@emqtt.io>.
|
|
%%
|
|
%% Licensed under the Apache License, Version 2.0 (the "License");
|
|
%% you may not use this file except in compliance with the License.
|
|
%% You may obtain a copy of the License at
|
|
%%
|
|
%% http://www.apache.org/licenses/LICENSE-2.0
|
|
%%
|
|
%% Unless required by applicable law or agreed to in writing, software
|
|
%% distributed under the License is distributed on an "AS IS" BASIS,
|
|
%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
%% See the License for the specific language governing permissions and
|
|
%% limitations under the License.
|
|
%%--------------------------------------------------------------------
|
|
|
|
%% Internal Header File
|
|
|
|
-define(GPROC_POOL(JoinOrLeave, Pool, I),
|
|
(begin
|
|
case JoinOrLeave of
|
|
join -> gproc_pool:connect_worker(Pool, {Pool, Id});
|
|
leave -> gproc_pool:disconnect_worker(Pool, {Pool, I})
|
|
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)))).
|
|
|
|
-define(record_to_proplist(Def, Rec, Fields),
|
|
[{K, V} || {K, V} <- ?record_to_proplist(Def, Rec),
|
|
lists:member(K, Fields)]).
|
|
|
|
-define(UNEXPECTED_REQ(Req, State),
|
|
(begin
|
|
lager:error("Unexpected Request: ~p", [Req]),
|
|
{reply, {error, unexpected_request}, State}
|
|
end)).
|
|
|
|
-define(UNEXPECTED_MSG(Msg, State),
|
|
(begin
|
|
lager:error("Unexpected Message: ~p", [Msg]),
|
|
{noreply, State}
|
|
end)).
|
|
|
|
-define(UNEXPECTED_INFO(Info, State),
|
|
(begin
|
|
lager:error("Unexpected Info: ~p", [Info]),
|
|
{noreply, State}
|
|
end)).
|
|
|
|
-define(IF(Cond, TrueFun, FalseFun),
|
|
(case (Cond) of
|
|
true -> (TrueFun);
|
|
false-> (FalseFun)
|
|
end)).
|
|
|