yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: code style

This commit is contained in:
DDDHuang 2022-01-17 15:42:34 +08:00
parent 5397d80680
commit 6278951d57
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/emqx_connection.erl
View File

@ -123,7 +123,6 @@
, 'recv_msg.qos2' , 'recv_msg.qos2'
, 'recv_msg.dropped' , 'recv_msg.dropped'
, 'recv_msg.dropped.expired' , 'recv_msg.dropped.expired'
, send_pkt , send_pkt
, send_msg , send_msg
, 'send_msg.qos0' , 'send_msg.qos0'

5
src/emqx_session.erl
View File

@ -571,8 +571,9 @@ await(PacketId, Msg, Session = #session{inflight = Inflight}) ->
%% Retry Delivery %% Retry Delivery
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
-spec(retry(emqx_types:clientinfo(), session()) -> -spec(retry(emqx_types:clientinfo(), session())
{ok, session()} | {ok, replies(), timeout(), session()}). -> {ok, session()}
| {ok, replies(), timeout(), session()}).
retry(ClientInfo, Session = #session{inflight = Inflight, retry_interval = RetryInterval}) -> retry(ClientInfo, Session = #session{inflight = Inflight, retry_interval = RetryInterval}) ->
case emqx_inflight:is_empty(Inflight) of case emqx_inflight:is_empty(Inflight) of
true -> {ok, Session}; true -> {ok, Session};