diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2015-11-23 17:36:21 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2015-11-23 17:36:21 +0300 |
| commit | 056fa2e2cd0dbcae5140a75eaf8a490b92daa448 (patch) | |
| tree | f422cd73cac49a1529ffe116b4917f43efbbfb7c /src/gatherer.erl | |
| parent | 3c1588167e5cf4ceea5c2b4c4e47fa50e6998541 (diff) | |
| parent | c42d5e571e95bf96b5933bc770ec5331dee2542f (diff) | |
| download | rabbitmq-server-git-056fa2e2cd0dbcae5140a75eaf8a490b92daa448.tar.gz | |
Merge branch 'stable'
Conflicts:
src/credit_flow.erl
src/gm.erl
src/mirrored_supervisor.erl
Diffstat (limited to 'src/gatherer.erl')
| -rw-r--r-- | src/gatherer.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/gatherer.erl b/src/gatherer.erl index 89bd46ca37..ecc2ab6189 100644 --- a/src/gatherer.erl +++ b/src/gatherer.erl @@ -120,8 +120,8 @@ handle_call(Msg, _From, State) -> handle_cast(finish, State = #gstate { forks = Forks, blocked = Blocked }) -> NewForks = Forks - 1, NewBlocked = case NewForks of - 0 -> [gen_server2:reply(From, empty) || - From <- queue:to_list(Blocked)], + 0 -> _ = [gen_server2:reply(From, empty) || + From <- queue:to_list(Blocked)], queue:new(); _ -> Blocked end, |