diff --git a/apps/emqx_gateway_gbt32960/include/emqx_gbt32960.hrl b/apps/emqx_gateway_gbt32960/include/emqx_gbt32960.hrl index ce1a3f135..ba7e7dc4a 100644 --- a/apps/emqx_gateway_gbt32960/include/emqx_gbt32960.hrl +++ b/apps/emqx_gateway_gbt32960/include/emqx_gbt32960.hrl @@ -4,6 +4,8 @@ -record(frame, {cmd, ack, vin, encrypt, length, data, check, rawdata}). +-type frame() :: #frame{}. + -define(CMD(CmdType), #frame{ cmd = CmdType, ack = ?ACK_IS_CMD diff --git a/apps/emqx_gateway_gbt32960/src/emqx_gbt32960_channel.erl b/apps/emqx_gateway_gbt32960/src/emqx_gbt32960_channel.erl index b5ac046ce..98b84a55e 100644 --- a/apps/emqx_gateway_gbt32960/src/emqx_gbt32960_channel.erl +++ b/apps/emqx_gateway_gbt32960/src/emqx_gbt32960_channel.erl @@ -67,7 +67,6 @@ | {close, Reason :: atom()}. -type replies() :: reply() | [reply()]. --type frame() :: emqx_gbt32960_frame:frame(). -define(TIMER_TABLE, #{ alive_timer => keepalive, @@ -203,7 +202,7 @@ setting_peercert_infos(Peercert, ClientInfo) -> %%-------------------------------------------------------------------- %% Handle incoming packet %%-------------------------------------------------------------------- --spec handle_in(emqx_gbt32960_frame:frame() | {frame_error, any()}, channel()) -> +-spec handle_in(frame() | {frame_error, any()}, channel()) -> {ok, channel()} | {ok, replies(), channel()} | {shutdown, Reason :: term(), channel()}