diff options
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 |