diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-03 22:37:00 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-03 22:37:00 +0000 |
| commit | ca53fb64918bbf0f32765644654ec7d0001a86cf (patch) | |
| tree | b987b32f902ebdb089c6b441065e1456f4932aca /src/rabbit_mirror_queue_sync.erl | |
| parent | 08c59a9170c1858d009ccecd089b6f1b2d25cd20 (diff) | |
| download | rabbitmq-server-ca53fb64918bbf0f32765644654ec7d0001a86cf.tar.gz | |
cosmetic
Diffstat (limited to 'src/rabbit_mirror_queue_sync.erl')
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index 88f4639f..bb69a664 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -145,8 +145,7 @@ syncer(Ref, Log, MPid, SPids) -> SPids1 -> MPid ! {ready, self()}, Log("~p to sync", [[rabbit_misc:pid_to_string(SPid) || SPid <- SPids1]]), - SPids2 = syncer_loop(Ref, MPid, SPids1), - [SPid ! {sync_complete, Ref} || SPid <- SPids2] + syncer_loop(Ref, MPid, SPids1) end. syncer_loop(Ref, MPid, SPids) -> @@ -160,7 +159,7 @@ syncer_loop(Ref, MPid, SPids) -> end || SPid <- SPids1], syncer_loop(Ref, MPid, SPids1); {done, Ref} -> - SPids + [SPid ! {sync_complete, Ref} || SPid <- SPids] end. wait_for_credit(SPids) -> |