diff --git a/src/emqx_stats.erl b/src/emqx_stats.erl index 479021bf0..41730005e 100644 --- a/src/emqx_stats.erl +++ b/src/emqx_stats.erl @@ -59,7 +59,9 @@ 'subscribers/count', 'subscribers/max', 'subscriptions/count', - 'subscriptions/max' + 'subscriptions/max', + 'subscriptions/shared/count', + 'subscriptions/shared/max' ]). -define(ROUTE_STATS, [ diff --git a/src/emqx_ws_connection.erl b/src/emqx_ws_connection.erl index a57a80fe9..3871f7b4c 100644 --- a/src/emqx_ws_connection.erl +++ b/src/emqx_ws_connection.erl @@ -131,9 +131,9 @@ stat_fun() -> fun() -> {ok, get(recv_oct)} end. websocket_handle({binary, <<>>}, State) -> - {ok, State}; + {ok, ensure_stats_timer(State)}; websocket_handle({binary, [<<>>]}, State) -> - {ok, State}; + {ok, ensure_stats_timer(State)}; websocket_handle({binary, Data}, State = #state{parser_state = ParserState, proto_state = ProtoState}) -> BinSize = iolist_size(Data),