diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-09-04 15:57:38 +0100 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-09-04 15:57:38 +0100 |
| commit | 5c8326a4892c43f1e7e7db12284288c5479509f9 (patch) | |
| tree | 5735e3f74fcbe103ba102df0c2ef8f83743945f8 | |
| parent | 13a5c4c3e17deeac959e5d35b91e2b08a98f6a6b (diff) | |
| download | rabbitmq-server-5c8326a4892c43f1e7e7db12284288c5479509f9.tar.gz | |
cosmetics
| -rw-r--r-- | src/rabbit_mirror_queue_master.erl | 3 | ||||
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 2 |
2 files changed, 1 insertions, 4 deletions
diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl index ad66d059..fb9f7e34 100644 --- a/src/rabbit_mirror_queue_master.erl +++ b/src/rabbit_mirror_queue_master.erl @@ -406,8 +406,7 @@ length_fun() -> fun (?MODULE, State = #state { gm = GM, backing_queue = BQ, backing_queue_state = BQS }) -> - ok = gm:broadcast( - GM, {depth, BQ:depth(BQS)}), + ok = gm:broadcast(GM, {depth, BQ:depth(BQS)}), State end) end. diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 2e9035c8..28acc022 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -875,13 +875,11 @@ process_instruction({sender_death, ChPid}, msg_id_status = MS1, known_senders = pmon:demonitor(ChPid, KS) } end}; - process_instruction({depth, Depth}, State = #state { backing_queue = BQ, backing_queue_state = BQS }) -> {ok, set_synchronised( 0, true, State #state { depth_delta = Depth - BQ:depth(BQS) })}; - process_instruction({delete_and_terminate, Reason}, State = #state { backing_queue = BQ, backing_queue_state = BQS }) -> |