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

rename route table

This commit is contained in:
Feng Lee 2016-12-01 15:18:05 +08:00
parent 1421a43da4
commit fc14f4a3b6
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/emqttd_router.erl
View File

@ -284,11 +284,11 @@ code_change(_OldVsn, State, _Extra) ->
clean_routes_(Node) -> clean_routes_(Node) ->
Pattern = #mqtt_route{_ = '_', node = Node}, Pattern = #mqtt_route{_ = '_', node = Node},
Clean = fun() -> Clean = fun() ->
[mnesia:delete_object(route, R, write) || [mnesia:delete_object(mqtt_route, R, write) ||
R <- mnesia:match_object(route, Pattern, write)] R <- mnesia:match_object(mqtt_route, Pattern, write)]
end, end,
mnesia:transaction(Clean). mnesia:transaction(Clean).
update_stats_() -> update_stats_() ->
emqttd_stats:setstats('routes/count', 'routes/max', mnesia:table_info(route, size)). emqttd_stats:setstats('routes/count', 'routes/max', mnesia:table_info(mqtt_route, size)).