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

fix(gw): fix xrefs

This commit is contained in:
JianBo He 2021-07-20 15:41:45 +08:00
parent f22384669e
commit 9355adae4b
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_gateway/src/mqttsn/emqx_sn_broadcast.erl
View File

@ -89,7 +89,7 @@ ensure_advertise(State = #state{duration = Duration}) ->
send_advertise(#state{gwid = GwId, sock = Sock, port = Port, send_advertise(#state{gwid = GwId, sock = Sock, port = Port,
addrs = Addrs, duration = Duration}) -> addrs = Addrs, duration = Duration}) ->
Data = emqx_sn_frame:serialize(?SN_ADVERTISE_MSG(GwId, Duration)), Data = emqx_sn_frame:serialize_pkt(?SN_ADVERTISE_MSG(GwId, Duration), #{}),
lists:foreach(fun(Addr) -> lists:foreach(fun(Addr) ->
?LOG(debug, "SEND SN_ADVERTISE to ~p~n", [Addr]), ?LOG(debug, "SEND SN_ADVERTISE to ~p~n", [Addr]),
gen_udp:send(Sock, Addr, Port, Data) gen_udp:send(Sock, Addr, Port, Data)

6
apps/emqx_gateway/src/mqttsn/emqx_sn_channel.erl
View File

@ -1095,8 +1095,8 @@ handle_call(discard, Channel) ->
% AllPendings = lists:append(Delivers, Pendings), % AllPendings = lists:append(Delivers, Pendings),
% shutdown_and_reply(takeovered, AllPendings, Channel); % shutdown_and_reply(takeovered, AllPendings, Channel);
handle_call(list_acl_cache, Channel) -> %handle_call(list_acl_cache, Channel) ->
{reply, emqx_acl_cache:list_acl_cache(), Channel}; % {reply, emqx_acl_cache:list_acl_cache(), Channel};
%% XXX: No Quota Now %% XXX: No Quota Now
% handle_call({quota, Policy}, Channel) -> % handle_call({quota, Policy}, Channel) ->
@ -1375,7 +1375,7 @@ run_hooks(Ctx, Name, Args, Acc) ->
emqx_hooks:run_fold(Name, Args, Acc). emqx_hooks:run_fold(Name, Args, Acc).
run_hooks_without_metrics(_Ctx, Name, Args) -> run_hooks_without_metrics(_Ctx, Name, Args) ->
emqx_hooks:run_fold(Name, Args). emqx_hooks:run(Name, Args).
run_hooks_without_metrics(_Ctx, Name, Args, Acc) -> run_hooks_without_metrics(_Ctx, Name, Args, Acc) ->
emqx_hooks:run_fold(Name, Args, Acc). emqx_hooks:run_fold(Name, Args, Acc).