Skip to content

Commit fc3521e

Browse files
Kostassoidedaniels
authored andcommitted
Track bytesReadSuccesfully in oggreader
1 parent 1bb9fa9 commit fc3521e

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

pkg/media/oggreader/oggreader.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -189,6 +189,8 @@ func (o *OggReader) ParseNextPage() ([]byte, *OggPageHeader, error) {
189189
}
190190
}
191191

192+
o.bytesReadSuccesfully += int64(len(h) + len(sizeBuffer) + len(payload))
193+
192194
return payload, pageHeader, nil
193195
}
194196

pkg/media/oggreader/oggreader_test.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,10 +46,12 @@ func TestOggReader_ParseNextPage(t *testing.T) {
4646
reader, _, err := NewWith(ogg)
4747
assert.NoError(t, err)
4848
assert.NotNil(t, reader)
49+
assert.Equal(t, int64(47), reader.bytesReadSuccesfully)
4950

5051
payload, _, err := reader.ParseNextPage()
5152
assert.Equal(t, []byte{0x98, 0x36, 0xbe, 0x88, 0x9e}, payload)
5253
assert.NoError(t, err)
54+
assert.Equal(t, int64(80), reader.bytesReadSuccesfully)
5355

5456
_, _, err = reader.ParseNextPage()
5557
assert.Equal(t, err, io.EOF)

0 commit comments

Comments
 (0)