Skip to content

Commit 19ca741

Browse files
committed
Fix dialyzer warning
1 parent fbd3251 commit 19ca741

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

src/osiris_log.erl

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2889,6 +2889,8 @@ recover_tracking(Fd, Trk0, Pos0) ->
28892889
Trk0
28902890
end.
28912891

2892+
-spec read_header0(state()) -> {ok, map(), undefined | binary(), state()} |
2893+
{end_of_stream, state()}.
28922894
read_header0(State) ->
28932895
%% reads the next header if permitted
28942896
case can_read_next(State) of
@@ -3136,7 +3138,8 @@ maybe_return_header(#?MODULE{cfg = #cfg{counter = CntRef},
31363138
last_data_size(#?MODULE{mode = R = #read{}} = S, Lds) ->
31373139
S#?MODULE{mode = R#read{last_data_size = Lds}}.
31383140

3139-
update_read(#?MODULE{mode = R0} = S, ChId, NumRecords, Pos) ->
3141+
-spec update_read(state(), offset(), offset(), non_neg_integer()) -> state().
3142+
update_read(#?MODULE{mode = R0 = #read{}} = S, ChId, NumRecords, Pos) ->
31403143
R = R0#read{next_offset = ChId + NumRecords,
31413144
position = Pos},
31423145
S#?MODULE{mode = R}.

test/osiris_log_SUITE.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2042,6 +2042,7 @@ run_read_ahead_tests(Tests, RType, FSize, Wr0, Rd0) ->
20422042
#{w => W, r => R1, rtype => RType, fsize => FSize}
20432043
end, #{w => Wr0, r => Rd0, rtype => RType, fsize => FSize}, Tests).
20442044

2045+
-spec update_read(map(), osiris_log:state()) -> osiris_log:state().
20452046
update_read(#{chunk_id := ChId,
20462047
num_records := NumRecords,
20472048
next_position := NextPos}, R) ->

0 commit comments

Comments
 (0)