diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-04-11 17:44:43 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-04-11 17:44:43 +0100 |
| commit | 8b04d6a5beb3eb3167f710627bf72231fa4f073b (patch) | |
| tree | 869b8c39df19bfb8cdd2f04ec895218209b6305a /src | |
| parent | 34f91555a6477b0845d400446793582afcaf0de5 (diff) | |
| download | rabbitmq-server-git-8b04d6a5beb3eb3167f710627bf72231fa4f073b.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_msg_store.erl | 4 | ||||
| -rw-r--r-- | src/rabbit_variable_queue.erl | 12 |
2 files changed, 7 insertions, 9 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 8ffd5b13f0..d69dad1f8b 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -1240,8 +1240,8 @@ client_confirm(CRef, MsgIds, ActionTaken, State) -> case dict:find(CRef, CTM) of {ok, Gs} -> MsgOnDiskFun(gb_sets:intersection(Gs, MsgIds), ActionTaken), - MsgIds1 = - rabbit_misc:gb_sets_difference(Gs, MsgIds), + MsgIds1 = rabbit_misc:gb_sets_difference( + Gs, MsgIds), case gb_sets:is_empty(MsgIds1) of true -> dict:erase(CRef, CTM); false -> dict:store(CRef, MsgIds1, CTM) diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 6e8a1cca2d..64d3b05ce1 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1291,13 +1291,11 @@ record_confirms(MsgIdSet, State = #vqstate { msgs_on_disk = MOD, msg_indices_on_disk = MIOD, unconfirmed = UC, confirmed = C }) -> - State #vqstate { msgs_on_disk = - rabbit_misc:gb_sets_difference(MOD, MsgIdSet), - msg_indices_on_disk = - rabbit_misc:gb_sets_difference(MIOD, MsgIdSet), - unconfirmed = - rabbit_misc:gb_sets_difference(UC, MsgIdSet), - confirmed = gb_sets:union(C, MsgIdSet) }. + State #vqstate { + msgs_on_disk = rabbit_misc:gb_sets_difference(MOD, MsgIdSet), + msg_indices_on_disk = rabbit_misc:gb_sets_difference(MIOD, MsgIdSet), + unconfirmed = rabbit_misc:gb_sets_difference(UC, MsgIdSet), + confirmed = gb_sets:union(C, MsgIdSet) }. must_sync_index(#vqstate { msg_indices_on_disk = MIOD, unconfirmed = UC }) -> |