diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-11-28 14:23:33 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-11-28 14:23:33 +0000 |
| commit | 45d09eb000f05523a384f2f5875ee57c9d44b19c (patch) | |
| tree | b39718f2aaa3f6a1326545dafa838cbdaf017d55 | |
| parent | 8f9c5c2a0428a9dac54e3b0ff0a514cf740316b4 (diff) | |
| download | rabbitmq-server-45d09eb000f05523a384f2f5875ee57c9d44b19c.tar.gz | |
Unshorten name.
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index 6626ee2e..33c7bccc 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -147,7 +147,7 @@ slave(Ref, TRef, Syncer, BQ, BQS, UpdateRamDuration) -> {_MsgCount, BQS1} = BQ:purge(BQS), slave_sync_loop({Ref, MRef, Syncer, BQ, UpdateRamDuration}, TRef, BQS1). -slave_sync_loop(Args = {Ref, MRef, Syncer, BQ, UpdateRamDur}, TRef, BQS) -> +slave_sync_loop(Args = {Ref, MRef, Syncer, BQ, UpdateRamDuration}, TRef, BQS) -> receive {'DOWN', MRef, process, Syncer, _Reason} -> %% If the master dies half way we are not in the usual @@ -173,7 +173,7 @@ slave_sync_loop(Args = {Ref, MRef, Syncer, BQ, UpdateRamDur}, TRef, BQS) -> BQS1 = BQ:set_ram_duration_target(Duration, BQS), slave_sync_loop(Args, TRef, BQS1); update_ram_duration -> - {TRef2, BQS1} = UpdateRamDur(BQ, BQS), + {TRef2, BQS1} = UpdateRamDuration(BQ, BQS), slave_sync_loop(Args, TRef2, BQS1); {sync_msg, Ref, Msg, Props} -> credit_flow:ack(Syncer, ?CREDIT_DISC_BOUND), |