From 43be00ea1b9ca988ae2d0b641ca931fe855a17c0 Mon Sep 17 00:00:00 2001 From: Krishna Srinivas <634494+krishnasrinivas@users.noreply.github.com> Date: Wed, 1 May 2019 21:46:00 -0700 Subject: [PATCH] Remove logs from bitrot-streaming.go as erasure layer is already logging (#7603) --- cmd/bitrot-streaming.go | 22 +++++----------------- 1 file changed, 5 insertions(+), 17 deletions(-) diff --git a/cmd/bitrot-streaming.go b/cmd/bitrot-streaming.go index e653d2848..2dc7b707c 100644 --- a/cmd/bitrot-streaming.go +++ b/cmd/bitrot-streaming.go @@ -41,13 +41,11 @@ func (b *streamingBitrotWriter) Write(p []byte) (int, error) { b.h.Reset() b.h.Write(p) hashBytes := b.h.Sum(nil) - n, err := b.iow.Write(hashBytes) - if n != len(hashBytes) { - logger.LogIf(context.Background(), err) + _, err := b.iow.Write(hashBytes) + if err != nil { return 0, err } - n, err = b.iow.Write(p) - return n, err + return b.iow.Write(p) } func (b *streamingBitrotWriter) Close() error { @@ -75,11 +73,6 @@ func newStreamingBitrotWriter(disk StorageAPI, volume, filePath string, length i totalFileSize = bitrotSumsTotalSize + length } err := disk.CreateFile(volume, filePath, totalFileSize, r) - if err != nil { - reqInfo := (&logger.ReqInfo{}).AppendTags("storageDisk", disk.String()) - ctx := logger.SetReqInfo(context.Background(), reqInfo) - logger.LogIf(ctx, err) - } r.CloseWithError(err) close(bw.canClose) }() @@ -110,7 +103,7 @@ func (b *streamingBitrotReader) ReadAt(buf []byte, offset int64) (int, error) { var err error if offset%b.shardSize != 0 { // Offset should always be aligned to b.shardSize - logger.LogIf(context.Background(), errUnexpected) + // Can never happen unless there are programmer bugs return 0, errUnexpected } if b.rc == nil { @@ -119,25 +112,20 @@ func (b *streamingBitrotReader) ReadAt(buf []byte, offset int64) (int, error) { streamOffset := (offset/b.shardSize)*int64(b.h.Size()) + offset b.rc, err = b.disk.ReadFileStream(b.volume, b.filePath, streamOffset, b.tillOffset-streamOffset) if err != nil { - reqInfo := (&logger.ReqInfo{}).AppendTags("storageDisk", b.disk.String()) - ctx := logger.SetReqInfo(context.Background(), reqInfo) - logger.LogIf(ctx, err) return 0, err } } if offset != b.currOffset { - logger.LogIf(context.Background(), errUnexpected) + // Can never happen unless there are programmer bugs return 0, errUnexpected } b.h.Reset() _, err = io.ReadFull(b.rc, b.hashBytes) if err != nil { - logger.LogIf(context.Background(), err) return 0, err } _, err = io.ReadFull(b.rc, buf) if err != nil { - logger.LogIf(context.Background(), err) return 0, err } b.h.Write(buf)