diff --git a/apps/emqx/src/emqx_metrics.erl b/apps/emqx/src/emqx_metrics.erl index 5f04cf403..016edc2c7 100644 --- a/apps/emqx/src/emqx_metrics.erl +++ b/apps/emqx/src/emqx_metrics.erl @@ -16,7 +16,7 @@ -module(emqx_metrics). --behavior(gen_server). +-behaviour(gen_server). -include("emqx.hrl"). -include("logger.hrl"). diff --git a/apps/emqx/src/emqx_sys_mon.erl b/apps/emqx/src/emqx_sys_mon.erl index 3d47038c6..7d798060f 100644 --- a/apps/emqx/src/emqx_sys_mon.erl +++ b/apps/emqx/src/emqx_sys_mon.erl @@ -16,7 +16,7 @@ -module(emqx_sys_mon). --behavior(gen_server). +-behaviour(gen_server). -include("types.hrl"). -include("logger.hrl"). diff --git a/apps/emqx_authn/src/emqx_authn_api.erl b/apps/emqx_authn/src/emqx_authn_api.erl index f8e8bf5de..4f02afc55 100644 --- a/apps/emqx_authn/src/emqx_authn_api.erl +++ b/apps/emqx_authn/src/emqx_authn_api.erl @@ -16,7 +16,7 @@ -module(emqx_authn_api). --behavior(minirest_api). +-behaviour(minirest_api). -include("emqx_authn.hrl"). @@ -117,7 +117,7 @@ }, topology => #{ max_overflow => 8, - pool_size => 8 + pool_size => 8 }, enable => true})). diff --git a/apps/emqx_authz/src/emqx_authz_api_mnesia.erl b/apps/emqx_authz/src/emqx_authz_api_mnesia.erl index da9b552c0..a12bd195a 100644 --- a/apps/emqx_authz/src/emqx_authz_api_mnesia.erl +++ b/apps/emqx_authz/src/emqx_authz_api_mnesia.erl @@ -16,7 +16,7 @@ -module(emqx_authz_api_mnesia). --behavior(minirest_api). +-behaviour(minirest_api). -include("emqx_authz.hrl"). -include_lib("emqx/include/logger.hrl"). diff --git a/apps/emqx_authz/src/emqx_authz_api_settings.erl b/apps/emqx_authz/src/emqx_authz_api_settings.erl index ac48fafd9..c2a87da16 100644 --- a/apps/emqx_authz/src/emqx_authz_api_settings.erl +++ b/apps/emqx_authz/src/emqx_authz_api_settings.erl @@ -16,7 +16,7 @@ -module(emqx_authz_api_settings). --behavior(minirest_api). +-behaviour(minirest_api). -export([ api_spec/0 , settings/2 diff --git a/apps/emqx_authz/src/emqx_authz_api_sources.erl b/apps/emqx_authz/src/emqx_authz_api_sources.erl index a349a1314..0b6aaa066 100644 --- a/apps/emqx_authz/src/emqx_authz_api_sources.erl +++ b/apps/emqx_authz/src/emqx_authz_api_sources.erl @@ -16,7 +16,7 @@ -module(emqx_authz_api_sources). --behavior(minirest_api). +-behaviour(minirest_api). -include("emqx_authz.hrl"). -include_lib("emqx/include/logger.hrl"). diff --git a/apps/emqx_exhook/test/emqx_exhook_demo_svr.erl b/apps/emqx_exhook/test/emqx_exhook_demo_svr.erl index 656788b5e..d99f20d67 100644 --- a/apps/emqx_exhook/test/emqx_exhook_demo_svr.erl +++ b/apps/emqx_exhook/test/emqx_exhook_demo_svr.erl @@ -16,7 +16,7 @@ -module(emqx_exhook_demo_svr). --behavior(emqx_exhook_v_1_hook_provider_bhvr). +-behaviour(emqx_exhook_v_1_hook_provider_bhvr). %% -export([ start/0 diff --git a/apps/emqx_gateway/src/coap/emqx_coap_channel.erl b/apps/emqx_gateway/src/coap/emqx_coap_channel.erl index acce25807..4c21e227b 100644 --- a/apps/emqx_gateway/src/coap/emqx_coap_channel.erl +++ b/apps/emqx_gateway/src/coap/emqx_coap_channel.erl @@ -16,7 +16,7 @@ -module(emqx_coap_channel). --behavior(emqx_gateway_channel). +-behaviour(emqx_gateway_channel). -include_lib("emqx/include/logger.hrl"). -include_lib("emqx_gateway/src/coap/include/emqx_coap.hrl"). diff --git a/apps/emqx_gateway/src/coap/emqx_coap_frame.erl b/apps/emqx_gateway/src/coap/emqx_coap_frame.erl index 4d12997a7..e5305b417 100644 --- a/apps/emqx_gateway/src/coap/emqx_coap_frame.erl +++ b/apps/emqx_gateway/src/coap/emqx_coap_frame.erl @@ -16,7 +16,7 @@ -module(emqx_coap_frame). --behavior(emqx_gateway_frame). +-behaviour(emqx_gateway_frame). %% emqx_gateway_frame API -export([ initial_parse_state/1 diff --git a/apps/emqx_gateway/src/coap/emqx_coap_impl.erl b/apps/emqx_gateway/src/coap/emqx_coap_impl.erl index 6f576a2da..bce57e559 100644 --- a/apps/emqx_gateway/src/coap/emqx_coap_impl.erl +++ b/apps/emqx_gateway/src/coap/emqx_coap_impl.erl @@ -18,7 +18,7 @@ -include_lib("emqx_gateway/include/emqx_gateway.hrl"). --behavior(emqx_gateway_impl). +-behaviour(emqx_gateway_impl). %% APIs -export([ reg/0 diff --git a/apps/emqx_gateway/src/emqx_gateway_registry.erl b/apps/emqx_gateway/src/emqx_gateway_registry.erl index cfa6d424a..e4d410990 100644 --- a/apps/emqx_gateway/src/emqx_gateway_registry.erl +++ b/apps/emqx_gateway/src/emqx_gateway_registry.erl @@ -19,7 +19,7 @@ -include("include/emqx_gateway.hrl"). --behavior(gen_server). +-behaviour(gen_server). %% APIs -export([ reg/2 diff --git a/apps/emqx_gateway/src/exproto/emqx_exproto_frame.erl b/apps/emqx_gateway/src/exproto/emqx_exproto_frame.erl index ecd6273ca..5bf23b022 100644 --- a/apps/emqx_gateway/src/exproto/emqx_exproto_frame.erl +++ b/apps/emqx_gateway/src/exproto/emqx_exproto_frame.erl @@ -18,7 +18,7 @@ %% @doc The frame parser for ExProto -module(emqx_exproto_frame). --behavior(emqx_gateway_frame). +-behaviour(emqx_gateway_frame). -export([ initial_parse_state/1 , serialize_opts/0 diff --git a/apps/emqx_gateway/src/exproto/emqx_exproto_gsvr.erl b/apps/emqx_gateway/src/exproto/emqx_exproto_gsvr.erl index 3832f67d8..1b9afca62 100644 --- a/apps/emqx_gateway/src/exproto/emqx_exproto_gsvr.erl +++ b/apps/emqx_gateway/src/exproto/emqx_exproto_gsvr.erl @@ -17,7 +17,7 @@ %% The gRPC server for ConnectionAdapter -module(emqx_exproto_gsvr). -% -behavior(emqx_exproto_v_1_connection_adapter_bhvr). +% -behaviour(emqx_exproto_v_1_connection_adapter_bhvr). -include("src/exproto/include/emqx_exproto.hrl"). -include_lib("emqx/include/logger.hrl"). diff --git a/apps/emqx_gateway/src/exproto/emqx_exproto_impl.erl b/apps/emqx_gateway/src/exproto/emqx_exproto_impl.erl index 92169d67c..0a540f4c1 100644 --- a/apps/emqx_gateway/src/exproto/emqx_exproto_impl.erl +++ b/apps/emqx_gateway/src/exproto/emqx_exproto_impl.erl @@ -17,7 +17,7 @@ %% @doc The ExProto Gateway Implement interface -module(emqx_exproto_impl). --behavior(emqx_gateway_impl). +-behaviour(emqx_gateway_impl). %% APIs -export([ reg/0 diff --git a/apps/emqx_gateway/src/lwm2m/emqx_lwm2m_impl.erl b/apps/emqx_gateway/src/lwm2m/emqx_lwm2m_impl.erl index 7f2dbdd79..899a7109f 100644 --- a/apps/emqx_gateway/src/lwm2m/emqx_lwm2m_impl.erl +++ b/apps/emqx_gateway/src/lwm2m/emqx_lwm2m_impl.erl @@ -17,7 +17,7 @@ %% @doc The LwM2M Gateway Implement interface -module(emqx_lwm2m_impl). --behavior(emqx_gateway_impl). +-behaviour(emqx_gateway_impl). %% APIs -export([ reg/0 diff --git a/apps/emqx_gateway/src/mqttsn/emqx_sn_channel.erl b/apps/emqx_gateway/src/mqttsn/emqx_sn_channel.erl index cc3e8e053..550f89413 100644 --- a/apps/emqx_gateway/src/mqttsn/emqx_sn_channel.erl +++ b/apps/emqx_gateway/src/mqttsn/emqx_sn_channel.erl @@ -16,7 +16,7 @@ -module(emqx_sn_channel). --behavior(emqx_gateway_channel). +-behaviour(emqx_gateway_channel). -include("src/mqttsn/include/emqx_sn.hrl"). -include_lib("emqx/include/emqx.hrl"). @@ -1042,7 +1042,7 @@ handle_out(connack, ?SN_RC_ACCEPTED, Channel = #channel{ctx = Ctx, conninfo = ConnInfo}) -> _ = run_hooks(Ctx, 'client.connack', [ConnInfo, returncode_name(?SN_RC_ACCEPTED)], - #{} + #{} ), return_connack(?SN_CONNACK_MSG(?SN_RC_ACCEPTED), ensure_keepalive(Channel)); @@ -1325,7 +1325,7 @@ handle_deliver(Delivers, Channel = #channel{ ctx = Ctx, conn_state = ConnState, session = Session, - clientinfo = #{clientid := ClientId}}) + clientinfo = #{clientid := ClientId}}) when ConnState =:= disconnected; ConnState =:= asleep -> NSession = emqx_session:enqueue( diff --git a/apps/emqx_gateway/src/mqttsn/emqx_sn_frame.erl b/apps/emqx_gateway/src/mqttsn/emqx_sn_frame.erl index 5a57a4bff..59acc71ce 100644 --- a/apps/emqx_gateway/src/mqttsn/emqx_sn_frame.erl +++ b/apps/emqx_gateway/src/mqttsn/emqx_sn_frame.erl @@ -18,7 +18,7 @@ %% @doc The frame parser for MQTT-SN protocol -module(emqx_sn_frame). --behavior(emqx_gateway_frame). +-behaviour(emqx_gateway_frame). -include("src/mqttsn/include/emqx_sn.hrl"). diff --git a/apps/emqx_gateway/src/mqttsn/emqx_sn_impl.erl b/apps/emqx_gateway/src/mqttsn/emqx_sn_impl.erl index 192e7c340..4a683ebdf 100644 --- a/apps/emqx_gateway/src/mqttsn/emqx_sn_impl.erl +++ b/apps/emqx_gateway/src/mqttsn/emqx_sn_impl.erl @@ -17,7 +17,7 @@ %% @doc The MQTT-SN Gateway Implement interface -module(emqx_sn_impl). --behavior(emqx_gateway_impl). +-behaviour(emqx_gateway_impl). %% APIs -export([ reg/0 diff --git a/apps/emqx_gateway/src/stomp/emqx_stomp_channel.erl b/apps/emqx_gateway/src/stomp/emqx_stomp_channel.erl index 3f77aa8eb..98ef95806 100644 --- a/apps/emqx_gateway/src/stomp/emqx_stomp_channel.erl +++ b/apps/emqx_gateway/src/stomp/emqx_stomp_channel.erl @@ -16,7 +16,7 @@ -module(emqx_stomp_channel). --behavior(emqx_gateway_channel). +-behaviour(emqx_gateway_channel). -include("src/stomp/include/emqx_stomp.hrl"). -include_lib("emqx/include/emqx.hrl"). diff --git a/apps/emqx_gateway/src/stomp/emqx_stomp_frame.erl b/apps/emqx_gateway/src/stomp/emqx_stomp_frame.erl index 2b511b57a..1000eec58 100644 --- a/apps/emqx_gateway/src/stomp/emqx_stomp_frame.erl +++ b/apps/emqx_gateway/src/stomp/emqx_stomp_frame.erl @@ -68,7 +68,7 @@ -module(emqx_stomp_frame). --behavior(emqx_gateway_frame). +-behaviour(emqx_gateway_frame). -include("src/stomp/include/emqx_stomp.hrl"). diff --git a/apps/emqx_gateway/src/stomp/emqx_stomp_impl.erl b/apps/emqx_gateway/src/stomp/emqx_stomp_impl.erl index b33878a97..de7321c92 100644 --- a/apps/emqx_gateway/src/stomp/emqx_stomp_impl.erl +++ b/apps/emqx_gateway/src/stomp/emqx_stomp_impl.erl @@ -16,7 +16,7 @@ -module(emqx_stomp_impl). --behavior(emqx_gateway_impl). +-behaviour(emqx_gateway_impl). %% APIs -export([ reg/0 diff --git a/apps/emqx_gateway/test/emqx_exproto_echo_svr.erl b/apps/emqx_gateway/test/emqx_exproto_echo_svr.erl index 69c64d4ca..db6334565 100644 --- a/apps/emqx_gateway/test/emqx_exproto_echo_svr.erl +++ b/apps/emqx_gateway/test/emqx_exproto_echo_svr.erl @@ -16,7 +16,7 @@ -module(emqx_exproto_echo_svr). --behavior(emqx_exproto_v_1_connection_handler_bhvr). +-behaviour(emqx_exproto_v_1_connection_handler_bhvr). -export([ start/0 , stop/1 diff --git a/apps/emqx_modules/src/emqx_delayed_api.erl b/apps/emqx_modules/src/emqx_delayed_api.erl index 3cc2c7c21..95b586fef 100644 --- a/apps/emqx_modules/src/emqx_delayed_api.erl +++ b/apps/emqx_modules/src/emqx_delayed_api.erl @@ -16,7 +16,7 @@ -module(emqx_delayed_api). --behavior(minirest_api). +-behaviour(minirest_api). -include_lib("typerefl/include/types.hrl"). diff --git a/apps/emqx_modules/src/emqx_telemetry_api.erl b/apps/emqx_modules/src/emqx_telemetry_api.erl index 7dd36654a..799f192d0 100644 --- a/apps/emqx_modules/src/emqx_telemetry_api.erl +++ b/apps/emqx_modules/src/emqx_telemetry_api.erl @@ -16,7 +16,7 @@ -module(emqx_telemetry_api). --behavior(minirest_api). +-behaviour(minirest_api). -import(emqx_mgmt_util, [ schema/1 , object_schema/1 diff --git a/apps/emqx_modules/src/emqx_topic_metrics_api.erl b/apps/emqx_modules/src/emqx_topic_metrics_api.erl index fa2547e58..00740584e 100644 --- a/apps/emqx_modules/src/emqx_topic_metrics_api.erl +++ b/apps/emqx_modules/src/emqx_topic_metrics_api.erl @@ -16,7 +16,7 @@ %% TODO: refactor uri path -module(emqx_topic_metrics_api). --behavior(minirest_api). +-behaviour(minirest_api). -import(emqx_mgmt_util, [ properties/1 , schema/1