yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore(replayer): add comment describing what "until" means

This commit is contained in:
Andrew Mayorov 2023-11-28 11:47:54 +03:00
parent 86685bdce2
commit 34c9c022d0
No known key found for this signature in database
GPG Key ID: 2837C62ACFBFED5D
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx/src/emqx_persistent_message_ds_replayer.erl
View File

@ -185,6 +185,8 @@ poll(ReplyFun, SessionId, Inflight0, WindowSize) when WindowSize > 0, WindowSize
fetch(ReplyFun, SessionId, Inflight0, Streams, FreeSpace, []) fetch(ReplyFun, SessionId, Inflight0, Streams, FreeSpace, [])
end. end.
%% Which seqno this track is committed until.
%% "Until" means this is first seqno that is _not yet committed_ for this track.
-spec committed_until(track() | marker(), inflight()) -> seqno(). -spec committed_until(track() | marker(), inflight()) -> seqno().
committed_until(Track, #inflight{commits = Commits}) -> committed_until(Track, #inflight{commits = Commits}) ->
maps:get(Track, Commits). maps:get(Track, Commits).