diff options
| author | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2020-10-30 11:28:39 +0100 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2020-10-30 11:28:39 +0100 |
| commit | b98f15679c4c13eda051a9e229dbd159e097e7e8 (patch) | |
| tree | b1f11c5feb7fe7273648cf7e3b9b1855fc01f6bd | |
| parent | 5b7f6e21c7d8ed4d0cbd638a93dcda9386225353 (diff) | |
| download | rabbitmq-server-git-lrb-diagnose-file-handle-cache-issue.tar.gz | |
rabbit_variable_queue: Add logging to follow a new leadlrb-diagnose-file-handle-cache-issue
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index e3837c726e..e26c5bb49f 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -2374,11 +2374,15 @@ ifold(Fun, Acc, Its, State) -> {#msg_status{seq_id = SeqId2}, _, _}) -> SeqId1 =< SeqId2 end, Its), + rabbit_log:debug("IFOLD: reading message using msstate ~p", [State#vqstate.msg_store_clients]), {Msg, State1} = read_msg(MsgStatus, State), + rabbit_log:debug("IFOLD: message returned with new msstate ~p", [State1#vqstate.msg_store_clients]), case Fun(Msg, MsgStatus#msg_status.msg_props, Unacked, Acc) of {stop, Acc1} -> + rabbit_log:debug("IFOLD: stopping recursion, discarding latest msstate", []), {Acc1, State}; {cont, Acc1} -> + rabbit_log:debug("IFOLD: recurse, keeping latest msstate", []), {Its1, IndexState1} = inext(It, {Rest, State1#vqstate.index_state}), ifold(Fun, Acc1, Its1, State1#vqstate{index_state = IndexState1}) end. |