Skip to content

Commit 50eae64

Browse files
author
Loïc Hoguin
committed
Minor comment/whitespace tweaks
1 parent ad82c0b commit 50eae64

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

deps/rabbit/src/rabbit_classic_queue_index_v2.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -375,7 +375,7 @@ recover_index_v1_loop(State0 = #mqistate{ queue_name = Name },
375375
HiSeqId]),
376376
{Messages, V1State} = rabbit_queue_index:read(LoSeqId, UpSeqId, V1State0),
377377
%% We do a garbage collect immediately after the old index read
378-
%% and ack because they may have created a lot of garbage.
378+
%% because they may have created a lot of garbage.
379379
garbage_collect(),
380380
MessagesCount = length(Messages),
381381
counters:add(CountersRef, ?RECOVER_COUNT, MessagesCount),

deps/rabbit/src/rabbit_msg_store.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -520,8 +520,8 @@ write(MsgId, Msg, CState) -> client_write(MsgId, Msg, noflow, CState).
520520

521521
%% Used when upgrading to the modern index.
522522
sync_write(MsgId, Msg,
523-
CState = #client_msstate { cur_file_cache_ets = CurFileCacheEts,
524-
client_ref = CRef }) ->
523+
CState = #client_msstate { cur_file_cache_ets = CurFileCacheEts,
524+
client_ref = CRef }) ->
525525
file_handle_cache_stats:update(msg_store_write),
526526
ok = client_update_flying(+1, MsgId, CState),
527527
ok = update_msg_cache(CurFileCacheEts, MsgId, Msg),

0 commit comments

Comments
 (0)