Skip to content

Commit 15a100a

Browse files
committed
CQ: Use open_eventually in queue store's get_read_fd
1 parent 92b8f40 commit 15a100a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

deps/rabbit/src/rabbit_classic_queue_store_v2.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -435,7 +435,7 @@ get_read_fd(Segment, State = #qs{ read_segment = Segment,
435435
{ok, Fd, State};
436436
get_read_fd(Segment, State = #qs{ read_fd = OldFd }) ->
437437
maybe_close_fd(OldFd),
438-
case file:open(segment_file(Segment, State), [read, raw, binary]) of
438+
case rabbit_file:open_eventually(segment_file(Segment, State), [read, raw, binary]) of
439439
{ok, Fd} ->
440440
case file:read(Fd, ?HEADER_SIZE) of
441441
{ok, <<?MAGIC:32,?VERSION:8,

0 commit comments

Comments
 (0)