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

fix(gw): fix typos

This commit is contained in:
JianBo He 2021-07-20 14:55:31 +08:00
parent 40d714049e
commit 45912d8a81
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx_gateway/src/stomp/emqx_stomp_connection.erl
View File

@ -96,7 +96,6 @@
-type(state() :: #state{}). -type(state() :: #state{}).
-define(ACTIVE_N, 100).
-define(INFO_KEYS, [socktype, peername, sockname, sockstate, active_n]). -define(INFO_KEYS, [socktype, peername, sockname, sockstate, active_n]).
-define(CONN_STATS, [recv_pkt, recv_msg, send_pkt, send_msg]). -define(CONN_STATS, [recv_pkt, recv_msg, send_pkt, send_msg]).
-define(SOCK_STATS, [recv_oct, recv_cnt, send_oct, send_cnt, send_pend]). -define(SOCK_STATS, [recv_oct, recv_cnt, send_oct, send_cnt, send_pend]).
@ -419,7 +418,7 @@ handle_msg({incoming, Packet}, State = #state{idle_timer = undefined}) ->
handle_msg({incoming, Packet}, handle_msg({incoming, Packet},
State = #state{idle_timer = IdleTimer}) -> State = #state{idle_timer = IdleTimer}) ->
ok = emqx_misc:cancel_timer(IdleTimer), ok = emqx_misc:cancel_timer(IdleTimer),
%% XXX: Serialize with inpunt packets %% XXX: Serialize with input packets
%%Serialize = emqx_stomp_frame:serialize_opts(), %%Serialize = emqx_stomp_frame:serialize_opts(),
NState = State#state{idle_timer = undefined}, NState = State#state{idle_timer = undefined},
handle_incoming(Packet, NState); handle_incoming(Packet, NState);
@ -857,6 +856,7 @@ inc_incoming_stats(Packet = ?PACKET(Type)) ->
false -> false ->
ok ok
end, end,
%% FIXME:
emqx_metrics:inc_recv(Packet). emqx_metrics:inc_recv(Packet).
inc_outgoing_stats(Packet = ?PACKET(Type)) -> inc_outgoing_stats(Packet = ?PACKET(Type)) ->