CQ shared: Unlock files after truncation instead of compaction

Author: lhoguin

deps/rabbit/src/rabbit_msg_store.erl

@@ -814,7 +814,6 @@ prioritise_call(Msg, _From, _Len, _State) ->
 
 prioritise_cast(Msg, _Len, _State) ->
     case Msg of
-        {compacted_file, _File}       -> 8;
         {client_dying, _Pid}          -> 7;
         _                             -> 0
     end.
@@ -914,16 +913,7 @@ handle_cast({remove, CRef, MsgIds}, State) ->
                       ignore  -> State2
                   end
           end, State, MsgIds),
-    noreply(State1);
-
-handle_cast({compacted_file, File},
-            State = #msstate { file_summary_ets = FileSummaryEts }) ->
-    %% This can return false if the file gets deleted immediately
-    %% after compaction ends, but before we can process this message.
-    %% So this will become a no-op and we can ignore the return value.
-    _ = ets:update_element(FileSummaryEts, File,
-                           {#file_summary.locked, false}),
-    noreply(State).
+    noreply(State1).
 
 handle_info(sync, State) ->
     noreply(internal_sync(State));
@@ -2048,8 +2038,6 @@ compact_file(File, FileSize,
     Reclaimed = FileSize - TruncateSize,
     ?LOG_DEBUG("Compacted segment file number ~tp; ~tp bytes can now be reclaimed",
                      [File, Reclaimed]),
-    %% Tell the message store to update its state.
-    gen_server2:cast(Server, {compacted_file, File}),
     %% Tell the GC process to truncate the file.
     %%
     %% We will truncate later when there are no readers. We want current
@@ -2158,6 +2146,8 @@ truncate_file(File, Size, ThresholdTimestamp, #gc_state{ file_summary_ets = File
                     ok = file:close(Fd),
                     true = ets:update_element(FileSummaryEts, File,
                                               {#file_summary.file_size, Size}),
+                    true = ets:update_element(FileSummaryEts, File,
+                                              {#file_summary.locked, false}),
                     ?LOG_DEBUG("Truncated file number ~tp; new size ~tp bytes", [File, Size]),
                     ok
             end