diff --git a/src/emqx_connection.erl b/src/emqx_connection.erl index 2c2cc472d..bd9a9fbe4 100644 --- a/src/emqx_connection.erl +++ b/src/emqx_connection.erl @@ -123,7 +123,6 @@ , 'recv_msg.qos2' , 'recv_msg.dropped' , 'recv_msg.dropped.expired' - , send_pkt , send_msg , 'send_msg.qos0' diff --git a/src/emqx_session.erl b/src/emqx_session.erl index 9648083d9..3ba286f54 100644 --- a/src/emqx_session.erl +++ b/src/emqx_session.erl @@ -571,8 +571,9 @@ await(PacketId, Msg, Session = #session{inflight = Inflight}) -> %% Retry Delivery %%-------------------------------------------------------------------- --spec(retry(emqx_types:clientinfo(), session()) -> - {ok, session()} | {ok, replies(), timeout(), session()}). +-spec(retry(emqx_types:clientinfo(), session()) + -> {ok, session()} + | {ok, replies(), timeout(), session()}). retry(ClientInfo, Session = #session{inflight = Inflight, retry_interval = RetryInterval}) -> case emqx_inflight:is_empty(Inflight) of true -> {ok, Session};