diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2015-12-13 00:28:15 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2015-12-13 00:28:15 +0300 |
| commit | 417c14b545c77d4c1d2055d8e21e7ab6c1738843 (patch) | |
| tree | 5fbaf6bf049d37e45a5bb1a442b7e94a5bcd8a22 /src | |
| parent | c7e03fd9c17be97d9f5db31e240a4e5457fae717 (diff) | |
| download | rabbitmq-server-git-417c14b545c77d4c1d2055d8e21e7ab6c1738843.tar.gz | |
Handle a case when newly created (priority) queue may emit some of its stats as default
Fixes #488.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_priority_queue.erl | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/rabbit_priority_queue.erl b/src/rabbit_priority_queue.erl index 7439b5bc32..d11e63a15d 100644 --- a/src/rabbit_priority_queue.erl +++ b/src/rabbit_priority_queue.erl @@ -647,6 +647,9 @@ combine_status(P, New, Old) -> cse(infinity, _) -> infinity; cse(_, infinity) -> infinity; +%% can happen when queue process has just started and has +%% no data to provide when asked to emit statsV +cse(default, default) -> infinity; cse(A, B) when is_number(A) -> A + B; cse({delta, _, _, _}, _) -> {delta, todo, todo, todo}; cse(A, B) -> exit({A, B}). |