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

fix(gw-exproto): fix start udp/dtls listener

This commit is contained in:
JianBo He 2021-07-22 22:20:22 +08:00
parent 7f1d245a8f
commit 15bba6afe3
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
apps/emqx_gateway/src/exproto/emqx_exproto_impl.erl
View File

@ -168,8 +168,18 @@ start_listener(InstaId, Ctx, Type, ListenOn, SocketOpts, Cfg) ->
frame_mod => emqx_exproto_frame, frame_mod => emqx_exproto_frame,
chann_mod => emqx_exproto_channel chann_mod => emqx_exproto_channel
}, },
esockd:open(Name, ListenOn, merge_default_by_type(Type, SocketOpts), MFA = {emqx_gateway_conn, start_link, [NCfg]},
{emqx_gateway_conn, start_link, [NCfg]}). NSockOpts = merge_default_by_type(Type, SocketOpts),
do_start_listener(Type, Name, ListenOn, NSockOpts, MFA).
do_start_listener(Type, Name, ListenOn, Opts, MFA)
when Type == tcp;
Type == ssl ->
esockd:open(Name, ListenOn, Opts, MFA);
do_start_listener(udp, Name, ListenOn, Opts, MFA) ->
esockd:open_udp(Name, ListenOn, Opts, MFA);
do_start_listener(dtls, Name, ListenOn, Opts, MFA) ->
esockd:open_dtls(Name, ListenOn, Opts, MFA).
name(InstaId, Type) -> name(InstaId, Type) ->
list_to_atom(lists:concat([InstaId, ":", Type])). list_to_atom(lists:concat([InstaId, ":", Type])).