diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-10-05 18:23:04 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-10-05 18:23:04 +0100 |
| commit | 367f9f0387a13da101c91355c41b79652b88d290 (patch) | |
| tree | d6665dd2edfad642ceaeb0ce42093f8bfda37dcf | |
| parent | 34f93f5425c1376e9e3e11f68ebbfd04cd1dcf62 (diff) | |
| download | rabbitmq-server-git-367f9f0387a13da101c91355c41b79652b88d290.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_msg_store.erl | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 8acd05e78b..6c968ae451 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -620,9 +620,9 @@ handle_call(client_terminate, _From, State) -> reply(ok, State). handle_cast({write, Guid}, - State = #msstate { sum_valid_data = SumValid, - file_summary_ets = FileSummaryEts, - cur_file_cache_ets = CurFileCacheEts }) -> + State = #msstate { sum_valid_data = SumValid, + file_summary_ets = FileSummaryEts, + cur_file_cache_ets = CurFileCacheEts }) -> true = 0 =< ets:update_counter(CurFileCacheEts, Guid, {3, -1}), [{Guid, Msg, _CacheRefCount}] = ets:lookup(CurFileCacheEts, Guid), case index_lookup(Guid, State) of @@ -945,9 +945,8 @@ remove_message(Guid, State = #msstate { sum_valid_data = SumValid, [{#file_summary.valid_total_size, ValidTotalSize - TotalSize}]), delete_file_if_empty( - File, - State #msstate { - sum_valid_data = SumValid - TotalSize }) + File, State #msstate { + sum_valid_data = SumValid - TotalSize }) end; _ -> ok = decrement_cache(DedupCacheEts, Guid), ok = Dec(), |