diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-02 00:48:51 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-02 00:48:51 +0200 |
| commit | ccae00a253236f817587e9145e8fc1e85cbf9fd1 (patch) | |
| tree | a95f3742d8788e9311e38bba469dd9c4dee3149d /src | |
| parent | e8fe201e57a045ecc9082ebbd492eab5fa99984e (diff) | |
| download | rabbitmq-server-git-ccae00a253236f817587e9145e8fc1e85cbf9fd1.tar.gz | |
adds explanation
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index 3fbe03fa02..7cfd0ab4b6 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -346,7 +346,11 @@ slave_sync_loop(Args = {Ref, MRef, Syncer, BQ, UpdateRamDuration, Parent}, slave_sync_loop(Args, {MA1, TRef, BQS1}); {sync_msgs, Ref, Batch} -> credit_flow:ack(Syncer), - %% we don't need to reverse BatchP1 and BatchPD1 since the + %% We need to partition the batch in messages that need to + %% be batch_publish/2 and the ones that need to be + %% batch_publish_delivered/2. + %% + %% We don't need to reverse BatchP1 and BatchPD1 since the %% foldl takes care of that. {BatchP1, BatchPD1} = lists:foldl( |