root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

wip

This commit is contained in:
Karl Nilsson 2024-11-25 14:43:03 +00:00
parent 1b973d2789
commit a751df9d5c
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
deps/rabbit/src/rabbit_fifo.erl vendored
View File

@ -3021,10 +3021,9 @@ incr_msg(Msg0, DelFailed, Anns) ->
end. end.
exec_read(Flru0, ReadPlan, Msgs) -> exec_read(Flru0, ReadPlan, Msgs) ->
{Entries, Flru} = ra:execute_read_plan(ReadPlan, Flru0), {Entries, Flru} = ra_log_read_plan:execute(ReadPlan, Flru0),
%% pretend entries is a map %% return a list in original order
{lists:map(fun ({MsgId, ?MSG(Idx, Header)}) -> {lists:map(fun ({MsgId, ?MSG(Idx, Header)}) ->
{_, _, Cmd, _} = maps:get(Idx, Entries), Cmd = maps:get(Idx, Entries),
%% hacky
{MsgId, {Header, get_msg(Cmd)}} {MsgId, {Header, get_msg(Cmd)}}
end, Msgs), Flru}. end, Msgs), Flru}.