diff --git a/pkg/pusher/pusher.go b/pkg/pusher/pusher.go index 9011e86c7f6..c4b85620add 100644 --- a/pkg/pusher/pusher.go +++ b/pkg/pusher/pusher.go @@ -381,7 +381,7 @@ func (s *Service) checkReceipt(receipt *pushsync.Receipt, loggerV1 log.Logger) e if po < d && s.attempts.try(addr) { s.metrics.ShallowReceiptDepth.WithLabelValues(strconv.Itoa(int(po))).Inc() s.metrics.ShallowReceipt.Inc() - return fmt.Errorf("pusher: shallow receipt depth %d, want at least %d: %w", po, d, ErrShallowReceipt) + return fmt.Errorf("pusher: shallow receipt depth %d, want at least %d, chunk_address %s: %w", po, d, addr, ErrShallowReceipt) } loggerV1.Debug("chunk pushed", "chunk_address", addr, "peer_address", peer, "proximity_order", po) s.metrics.ReceiptDepth.WithLabelValues(strconv.Itoa(int(po))).Inc() diff --git a/pkg/sharky/shard.go b/pkg/sharky/shard.go index edb2faa8fee..11af6b6d8cf 100644 --- a/pkg/sharky/shard.go +++ b/pkg/sharky/shard.go @@ -172,8 +172,11 @@ func (sh *shard) offset(slot uint32) int64 { // read reads loc.Length bytes to the buffer from the blob slot loc.Slot func (sh *shard) read(r read) error { - _, err := sh.file.ReadAt(r.buf, sh.offset(r.slot)) - return err + n, err := sh.file.ReadAt(r.buf, sh.offset(r.slot)) + if err != nil { + return fmt.Errorf("read %d: %w", n, err) + } + return nil } // write writes loc.Length bytes to the buffer from the blob slot loc.Slot