diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-01-03 16:49:46 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-01-03 16:49:46 +0000 |
| commit | 5746d836027a31886d4059728f0b8d7d8229a1eb (patch) | |
| tree | 81fb2b026d6e76ee9f85f7eea94c6777e8fe74c1 | |
| parent | d02d5e93b5fcb8b7bb4d4a5a8860c77308f491a9 (diff) | |
| download | rabbitmq-server-git-5746d836027a31886d4059728f0b8d7d8229a1eb.tar.gz | |
Explain why
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index f9502219a6..c90a141fd8 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -219,6 +219,7 @@ slave_sync_loop(Args = {Ref, MRef, Syncer, BQ, UpdateRamDuration, Parent}, slave_sync_loop(Args, TRef, BQS1); {'EXIT', Parent, Reason} -> {stop, Reason, {TRef, BQS}}; + %% If the master throws an exception {'$gen_cast', {gm, {delete_and_terminate, Reason}}} -> BQS1 = BQ:delete_and_terminate(Reason, BQS), {stop, Reason, {TRef, BQS1}} |