Add WS stats

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, [

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),