From 96a510fbf132d1973669f66d9c7d98f4e056c16d Mon Sep 17 00:00:00 2001 From: William Yang Date: Thu, 9 Jun 2022 17:52:27 +0200 Subject: [PATCH] feat(quic): fix some listener --- apps/emqx/src/emqx_listeners.erl | 10 +++++++--- apps/emqx/test/emqx_common_test_helpers.erl | 2 +- 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/apps/emqx/src/emqx_listeners.erl b/apps/emqx/src/emqx_listeners.erl index 9d46fe975..e5b7e4293 100644 --- a/apps/emqx/src/emqx_listeners.erl +++ b/apps/emqx/src/emqx_listeners.erl @@ -143,9 +143,13 @@ is_running(Type, ListenerId, _Conf) when Type =:= ws; Type =:= wss -> _:_ -> false end; -is_running(quic, _ListenerId, _Conf) -> - %% TODO: quic support - false. +is_running(quic, ListenerId, _Conf) -> + case quicer:listener(ListenerId) of + {ok, Pid} when is_pid(Pid) -> + true; + _ -> + false + end. current_conns(ID, ListenOn) -> {ok, #{type := Type, name := Name}} = parse_listener_id(ID), diff --git a/apps/emqx/test/emqx_common_test_helpers.erl b/apps/emqx/test/emqx_common_test_helpers.erl index dd9a56841..89687905d 100644 --- a/apps/emqx/test/emqx_common_test_helpers.erl +++ b/apps/emqx/test/emqx_common_test_helpers.erl @@ -526,7 +526,6 @@ ensure_dashboard_listeners_started(_App) -> -spec ensure_quic_listener(Name :: atom(), UdpPort :: inet:port_number()) -> ok. ensure_quic_listener(Name, UdpPort) -> application:ensure_all_started(quicer), - emqx_config:put([listeners, quic, Name, mountpoint], <<>>), Conf = #{ acceptors => 16, bind => {{0, 0, 0, 0}, UdpPort}, @@ -545,6 +544,7 @@ ensure_quic_listener(Name, UdpPort) -> mountpoint => <<>>, zone => default }, + emqx_config:put([listeners, quic, Name], Conf), case emqx_listeners:start_listener(quic, Name, Conf) of ok -> ok; {error, {already_started, _Pid}} -> ok