root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Avoid race condition between created/stats by reading directly from core metrics

This commit is contained in:
Diana Corbacho 2017-02-20 14:17:21 +00:00
parent 940b9e6b47
commit fece810e0f
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
deps/rabbitmq_management_agent/src/rabbit_mgmt_metrics_collector.erl vendored
View File

@ -173,7 +173,7 @@ aggregate_entry(TS, {Id, RecvOct, SendOct, Reductions}, NextStats,
policies = {BPolicies, _, GPolicies}} = State) ->
Stats = ?vhost_stats_coarse_conn_stats(RecvOct, SendOct),
Diff = get_difference(Id, Stats, State),
[insert_entry(vhost_stats_coarse_conn_stats, vhost({connection_created_stats, Id}),
[insert_entry(vhost_stats_coarse_conn_stats, vhost({connection_created, Id}),
TS, Diff, Size, Interval, true) || {Size, Interval} <- GPolicies],
[begin
insert_entry(connection_stats_coarse_conn_stats, Id, TS,
@ -421,7 +421,7 @@ vhost(#resource{virtual_host = VHost}) ->
vhost({queue_stats, #resource{virtual_host = VHost}}) ->
VHost;
vhost({TName, Pid}) ->
pget(vhost, lookup_element(TName, Pid, 3)).
pget(vhost, lookup_element(TName, Pid, 2)).
exchange_exists(Name) ->
case rabbit_exchange:lookup(Name) of