diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-18 12:31:41 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-18 12:31:41 +0000 |
| commit | ab3613f8133c81c97b6eb19e03d2c9736d36772d (patch) | |
| tree | 4a127f2dcf65e79cf60e5a84af75fcd2d38ce167 /src/rabbit_variable_queue.erl | |
| parent | ad5f36fdaee422405631e3d0d8ee1c3e7db3407c (diff) | |
| parent | 02c2dd6844e132b64abef90ecfdf01c9e9124d8d (diff) | |
| download | rabbitmq-server-ab3613f8133c81c97b6eb19e03d2c9736d36772d.tar.gz | |
merge from default
Diffstat (limited to 'src/rabbit_variable_queue.erl')
| -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 35e37df6..3b385020 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1441,8 +1441,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) -> @@ -1453,8 +1453,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). %%---------------------------------------------------------------------------- |