From 498619bdda58a0c0a4c69fa738c36affdf03a397 Mon Sep 17 00:00:00 2001 From: Piotr Tabor Date: Fri, 23 Dec 2022 11:41:18 +0100 Subject: [PATCH] wal decoder: report file & offset in case of CRC mismatch. Signed-off-by: Piotr Tabor --- server/storage/wal/decoder.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/storage/wal/decoder.go b/server/storage/wal/decoder.go index dde15ed07..e1864cdca 100644 --- a/server/storage/wal/decoder.go +++ b/server/storage/wal/decoder.go @@ -109,9 +109,9 @@ func (d *decoder) decodeRecord(rec *walpb.Record) error { d.crc.Write(rec.Data) if err := rec.Validate(d.crc.Sum32()); err != nil { 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