diff --git a/apps/emqx/src/emqx_connection.erl b/apps/emqx/src/emqx_connection.erl index 8c0482587..562366eb3 100644 --- a/apps/emqx/src/emqx_connection.erl +++ b/apps/emqx/src/emqx_connection.erl @@ -173,7 +173,9 @@ system_code_change/4 ]} ). +-dialyzer({no_missing_calls, [handle_msg/2]}). +-ifndef(BUILD_WITHOUT_QUIC). -spec start_link (esockd:transport(), esockd:socket(), emqx_channel:opts()) -> {ok, pid()}; @@ -183,6 +185,9 @@ emqx_quic_connection:cb_state() ) -> {ok, pid()}. +-else. +-spec start_link(esockd:transport(), esockd:socket(), emqx_channel:opts()) -> {ok, pid()}. +-endif. start_link(Transport, Socket, Options) -> Args = [self(), Transport, Socket, Options], diff --git a/apps/emqx/src/emqx_listeners.erl b/apps/emqx/src/emqx_listeners.erl index e325263c5..ba50b3630 100644 --- a/apps/emqx/src/emqx_listeners.erl +++ b/apps/emqx/src/emqx_listeners.erl @@ -64,6 +64,17 @@ -export_type([listener_id/0]). +-dialyzer( + {no_unknown, [ + is_running/3, + current_conns/3, + do_stop_listener/3, + do_start_listener/4, + do_update_listener/4, + quic_listener_conf_rollback/3 + ]} +). + -type listener_id() :: atom() | binary(). -type listener_type() :: tcp | ssl | ws | wss | quic | dtls. @@ -1018,7 +1029,6 @@ ensure_max_conns(<<"infinity">>) -> <<"infinity">>; ensure_max_conns(MaxConn) when is_binary(MaxConn) -> binary_to_integer(MaxConn); ensure_max_conns(MaxConn) -> MaxConn. --spec quic_listen_on(X :: any()) -> quicer:listen_on(). quic_listen_on(Bind) -> case Bind of {Addr, Port} when tuple_size(Addr) == 4 -> diff --git a/apps/emqx_bridge_sqlserver/src/emqx_bridge_sqlserver.app.src b/apps/emqx_bridge_sqlserver/src/emqx_bridge_sqlserver.app.src index 3bc62734c..009a8d16b 100644 --- a/apps/emqx_bridge_sqlserver/src/emqx_bridge_sqlserver.app.src +++ b/apps/emqx_bridge_sqlserver/src/emqx_bridge_sqlserver.app.src @@ -1,6 +1,6 @@ {application, emqx_bridge_sqlserver, [ {description, "EMQX Enterprise SQL Server Bridge"}, - {vsn, "0.2.2"}, + {vsn, "0.2.3"}, {registered, []}, {applications, [kernel, stdlib, emqx_resource, odbc]}, {env, [ diff --git a/apps/emqx_bridge_sqlserver/src/emqx_bridge_sqlserver_connector.erl b/apps/emqx_bridge_sqlserver/src/emqx_bridge_sqlserver_connector.erl index 603ef18d0..521a215a5 100644 --- a/apps/emqx_bridge_sqlserver/src/emqx_bridge_sqlserver_connector.erl +++ b/apps/emqx_bridge_sqlserver/src/emqx_bridge_sqlserver_connector.erl @@ -78,7 +78,7 @@ %% https://www.erlang.org/doc/man/odbc.html %% as returned by connect/2 --type connection_reference() :: odbc:connection_reference(). +-type connection_reference() :: term(). -type time_out() :: milliseconds() | infinity. -type sql() :: string() | binary(). -type milliseconds() :: pos_integer(). diff --git a/rebar.config b/rebar.config index d2f223f40..57d3e2722 100644 --- a/rebar.config +++ b/rebar.config @@ -127,7 +127,10 @@ % generated code for protobuf emqx_exhook_pb, % generated code for protobuf - emqx_exproto_pb + emqx_exproto_pb, + % maybe BUILD_WITHOUT_QUIC + emqx_quic_connection, + quicer_listener ]}. {eunit_opts, [verbose, {print_depth, 100}]}.