Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

wal decoder: report file & offset in case of CRC mismatch.

Browse Source 
Signed-off-by: Piotr Tabor <ptab@google.com>
This commit is contained in:
Piotr Tabor 2022-12-23 11:41:18 +01:00
parent bcd5b54e7f
commit 498619bdda
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/storage/wal/decoder.go
View File

@ -109,9 +109,9 @@ func (d *decoder) decodeRecord(rec *walpb.Record) error {
d.crc.Write(rec.Data) d.crc.Write(rec.Data)
if err := rec.Validate(d.crc.Sum32()); err != nil { if err := rec.Validate(d.crc.Sum32()); err != nil {
if d.isTornEntry(data) { if d.isTornEntry(data) {
return io.ErrUnexpectedEOF return fmt.Errorf("%w: in file '%s' at position: %d", io.ErrUnexpectedEOF, fileBufReader.FileInfo().Name(), d.lastValidOff)
} }
return err return fmt.Errorf("%w: in file '%s' at position: %d", err, fileBufReader.FileInfo().Name(), d.lastValidOff)
} }
} }
// record decoded as valid; point last valid offset to end of record // record decoded as valid; point last valid offset to end of record