fix

rabbitmq · Nov 25, 2024 · 347c72f · 347c72f
1 parent 6111f29
commit 347c72f
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/src/ra_log_reader.erl b/src/ra_log_reader.erl
@@ -183,18 +183,18 @@ read_plan(#?STATE{segment_refs = SegRefs}, Indexes) ->
                      TransformFun :: fun(),
                      #{ra_index() => Command :: term()}) ->
     {#{ra_index() => Command :: term()}, ra_flru:state()}.
-exec_read_plan(Dir, Plan, undefined, Fun, Acc0) ->
+exec_read_plan(Dir, Plan, undefined, TransformFun, Acc0) ->
     Open = ra_flru:new(1, fun({_, Seg}) -> ra_log_segment:close(Seg) end),
-    exec_read_plan(Dir, Plan, Open, Fun, Acc0);
-exec_read_plan(Dir, Plan, Open0, Fun, Acc0)
+    exec_read_plan(Dir, Plan, Open, TransformFun, Acc0);
+exec_read_plan(Dir, Plan, Open0, TransformFun, Acc0)
   when is_list(Plan) ->
+    Fun = fun (I, T, B, Acc) ->
+                  E = TransformFun(I, T, binary_to_term(B)),
+                  Acc#{I => E}
+          end,
     lists:foldl(
       fun ({Idxs, BaseName}, {Acc1, Open1}) ->
               {Seg, Open} = get_segment_ext(Dir, Open1, BaseName),
-              Fun = fun (I, T, B, Acc) ->
-                            E = Fun(I, T, binary_to_term(B)),
-                            Acc#{I => E}
-                    end,
               {_, Acc} = ra_log_segment:read_sparse(Seg, Idxs, Fun, Acc1),
               {Acc, Open}
       end, {Acc0, Open0}, Plan).