diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-09-03 11:35:37 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-09-03 11:35:37 +0100 |
| commit | 054f774ab39eba201c67b542285647c3e36cb2d3 (patch) | |
| tree | bfde904047fb4e3c4a1e822dbb59786abe4ac9eb /src | |
| parent | 1d73afd61d9dc07a1a4c764b34b14e80936c3e00 (diff) | |
| download | rabbitmq-server-git-054f774ab39eba201c67b542285647c3e36cb2d3.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_msg_store.erl | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 9be895ed35..10e46fc7fd 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -663,10 +663,11 @@ handle_cast({write, Pid, Guid}, NextOffset, State #msstate { sum_valid_data = SumValid + TotalSize, sum_file_size = SumFileSize + TotalSize, - pid_to_guids = case dict:find(Pid, PTF) of - {ok, _} -> dict:append(Pid, Guid, PTG); - error -> PTG - end})); + pid_to_guids = + case dict:find(Pid, PTF) of + {ok, _} -> rabbit_misc:dict_cons(Pid, Guid, PTG); + error -> PTG + end})); #msg_location { ref_count = RefCount } -> %% We already know about it, just update counter. Only %% update field otherwise bad interaction with concurrent GC |