Skip to content

Commit 3e1045f

Browse files
committed
osiris_log_manifest: Use #chunk_info{} for chunk_written event
1 parent 1c7dbed commit 3e1045f

File tree

2 files changed

+6
-7
lines changed

2 files changed

+6
-7
lines changed

src/osiris_log.erl

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2501,9 +2501,11 @@ write_chunk(Chunk,
25012501
counters:put(CntRef, ?C_OFFSET, NextOffset - 1),
25022502
counters:add(CntRef, ?C_CHUNKS, 1),
25032503
maybe_set_first_offset(Next, Cfg),
2504-
Event = {chunk_written, Next, Timestamp, Epoch,
2505-
Cur, Size, NumRecords, Chunk},
2506-
Manifest = ManifestMod:handle_event(Event, Manifest0),
2504+
ChunkInfo = #chunk_info{id = Next, timestamp = Timestamp,
2505+
epoch = Epoch, num = NumRecords,
2506+
type = ChType, size = Size, pos = Cur},
2507+
Manifest = ManifestMod:handle_event({chunk_written, ChunkInfo},
2508+
Manifest0),
25072509
State#?MODULE{manifest = {ManifestMod, Manifest},
25082510
mode =
25092511
Write#write{tail_info = {NextOffset,

src/osiris_log_manifest.erl

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,10 +9,7 @@
99
-type event() :: {segment_opened,
1010
OldSegment :: file:filename_all() | undefined,
1111
NewSegment :: file:filename_all()} |
12-
{chunk_written, osiris:offset(), osiris:timestamp(),
13-
osiris:epoch(), Pos :: non_neg_integer(),
14-
Size :: non_neg_integer(), NumRecords :: non_neg_integer(),
15-
Chunk :: iodata()}.
12+
{chunk_written, #chunk_info{}}.
1613

1714
-export_type([state/0, event/0]).
1815

0 commit comments

Comments
 (0)