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 | 707b5c95544955650a6c45ae76bf55f16e1b3b3a (patch) | |
| tree | 5735e3f74fcbe103ba102df0c2ef8f83743945f8 | |
| parent | 9c8cd5e0e85f0819d761eaee9168c6ee49860ade (diff) | |
| download | rabbitmq-server-git-707b5c95544955650a6c45ae76bf55f16e1b3b3a.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 ad66d059e8..fb9f7e348c 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 2e9035c893..28acc02263 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 }) -> |