diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-12 11:59:09 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-12 11:59:09 +0000 |
| commit | be1b799e745f4404459953084451e72d35beb2c2 (patch) | |
| tree | 21af5a7e1682ab545f068c3ffaa04f7942a9f3af /src | |
| parent | 79acba27de543f92ef9bf05034671372ac15b3f4 (diff) | |
| download | rabbitmq-server-git-be1b799e745f4404459953084451e72d35beb2c2.tar.gz | |
swap union and intersection
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index c678236f71..07297f632c 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1423,8 +1423,8 @@ msgs_written_to_disk(QPid, GuidSet, written) -> msgs_confirmed(gb_sets:intersection(GuidSet, MIOD), State #vqstate { msgs_on_disk = - gb_sets:intersection( - gb_sets:union(MOD, GuidSet), UC) }) + gb_sets:union( + MOD, gb_sets:intersection(UC, GuidSet)) }) end). msg_indices_written_to_disk(QPid, GuidSet) -> @@ -1435,8 +1435,8 @@ msg_indices_written_to_disk(QPid, GuidSet) -> msgs_confirmed(gb_sets:intersection(GuidSet, MOD), State #vqstate { msg_indices_on_disk = - gb_sets:intersection( - gb_sets:union(MIOD, GuidSet), UC) }) + gb_sets:union( + MIOD, gb_sets:intersection(UC, GuidSet)) }) end). %%---------------------------------------------------------------------------- |