diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-10-01 22:19:35 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-10-01 22:19:35 +0100 |
| commit | 5384745ad76ead540b9b893ad366a0e6f20da8f6 (patch) | |
| tree | b3a6eeacf63b67dc5de1e5afc3c556ae4d90c72e /src/rabbit_mirror_queue_master.erl | |
| parent | 4b6a2777580d67ab069c86349f32f832feff8fc5 (diff) | |
| download | rabbitmq-server-5384745ad76ead540b9b893ad366a0e6f20da8f6.tar.gz | |
cosmetic(ish)
Diffstat (limited to 'src/rabbit_mirror_queue_master.erl')
| -rw-r--r-- | src/rabbit_mirror_queue_master.erl | 17 |
1 files changed, 4 insertions, 13 deletions
diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl index 4cfb3dcb..71d316f3 100644 --- a/src/rabbit_mirror_queue_master.erl +++ b/src/rabbit_mirror_queue_master.erl @@ -131,19 +131,12 @@ delete_and_terminate(Reason, State = #state { gm = GM, node(Pid) =/= node()], MRefs = [erlang:monitor(process, S) || S <- Slaves], ok = gm:broadcast(GM, {delete_and_terminate, Reason}), - monitor_wait(MRefs), + [receive {'DOWN', MRef, process, _Pid, _Info} -> ok end || + MRef <- MRefs], ok = gm:forget_group(proplists:get_value(group_name, Info)), State #state { backing_queue_state = BQ:delete_and_terminate(Reason, BQS), set_delivered = 0 }. -monitor_wait([]) -> - ok; -monitor_wait([MRef | MRefs]) -> - receive({'DOWN', MRef, process, _Pid, _Info}) -> - ok - end, - monitor_wait(MRefs). - purge(State = #state { gm = GM, backing_queue = BQ, backing_queue_state = BQS }) -> @@ -410,10 +403,8 @@ length_fun() -> end) end. -maybe_store_acktag(undefined, _MsgId, AM) -> - AM; -maybe_store_acktag(AckTag, MsgId, AM) -> - dict:store(AckTag, MsgId, AM). +maybe_store_acktag(undefined, _MsgId, AM) -> AM; +maybe_store_acktag(AckTag, MsgId, AM) -> dict:store(AckTag, MsgId, AM). ensure_monitoring(ChPid, State = #state { coordinator = CPid, known_senders = KS }) -> |