diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-06-21 11:28:32 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-06-21 11:28:32 +0100 |
| commit | a4b9c824910f9e2793b5938b8e365eb5c70da7ae (patch) | |
| tree | f8290259549c6670a638ce79de1bd3cf27bec8dc | |
| parent | 9b61963c76fc05aa4209960e7a24c9bc334cd9ce (diff) | |
| download | rabbitmq-server-git-a4b9c824910f9e2793b5938b8e365eb5c70da7ae.tar.gz | |
Add a TODO for if we are ever unbusy enough to look at removing this code.
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index 5607bfa9a4..cb91b65094 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -217,6 +217,8 @@ report_deaths(MirrorPid, IsMaster, QueueName, DeadPids) -> store_updated_slaves(Q = #amqqueue{slave_pids = SPids, sync_slave_pids = SSPids}) -> + %% TODO now that we clear sync_slave_pids in rabbit_durable_queue, + %% do we still need this? SSPids1 = [SSPid || SSPid <- SSPids, lists:member(SSPid, SPids)], Q1 = Q#amqqueue{sync_slave_pids = SSPids1}, ok = rabbit_amqqueue:store_queue(Q1), |