JakeHillion/storj
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Moving verbose info logging to debug (#2346)

Browse Source
This commit is contained in:
Philip Hutchins 2019-06-26 03:14:25 -06:00 committed by Kaloyan Raev
parent ae36979804
commit 11016b5067
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/storage/ec/client.go
View File

@ -87,7 +87,7 @@ func (ec *ecClient) Put(ctx context.Context, limits []*pb.AddressedOrderLimit, r
return nil, nil, Error.New("duplicated nodes are not allowed") return nil, nil, Error.New("duplicated nodes are not allowed")
} }
zap.S().Infof("Uploading to storage nodes using ErasureShareSize: %d StripeSize: %d RepairThreshold: %d OptimalThreshold: %d", zap.S().Debugf("Uploading to storage nodes using ErasureShareSize: %d StripeSize: %d RepairThreshold: %d OptimalThreshold: %d",
rs.ErasureShareSize(), rs.StripeSize(), rs.RepairThreshold(), rs.OptimalThreshold()) rs.ErasureShareSize(), rs.StripeSize(), rs.RepairThreshold(), rs.OptimalThreshold())
padded := eestream.PadReader(ioutil.NopCloser(data), rs.StripeSize()) padded := eestream.PadReader(ioutil.NopCloser(data), rs.StripeSize())
@ -149,12 +149,12 @@ func (ec *ecClient) Put(ctx context.Context, limits []*pb.AddressedOrderLimit, r
elapsed := time.Since(start) elapsed := time.Since(start)
more := elapsed * 3 / 2 more := elapsed * 3 / 2
zap.S().Infof("Repair threshold (%d nodes) passed in %.2f s. Starting a timer for %.2f s for reaching the success threshold (%d nodes)...", zap.S().Debugf("Repair threshold (%d nodes) passed in %.2f s. Starting a timer for %.2f s for reaching the success threshold (%d nodes)...",
rs.RepairThreshold(), elapsed.Seconds(), more.Seconds(), rs.OptimalThreshold()) rs.RepairThreshold(), elapsed.Seconds(), more.Seconds(), rs.OptimalThreshold())
timer = time.AfterFunc(more, func() { timer = time.AfterFunc(more, func() {
if ctx.Err() != context.Canceled { if ctx.Err() != context.Canceled {
zap.S().Infof("Timer expired. Successfully uploaded to %d nodes. Canceling the long tail...", atomic.LoadInt32(&successfulCount)) zap.S().Debugf("Timer expired. Successfully uploaded to %d nodes. Canceling the long tail...", atomic.LoadInt32(&successfulCount))
cancel() cancel()
} }
}) })
@ -333,7 +333,7 @@ func (ec *ecClient) putPiece(ctx, parent context.Context, limit *pb.AddressedOrd
if parent.Err() == context.Canceled { if parent.Err() == context.Canceled {
zap.S().Infof("Upload to node %s canceled by user.", storageNodeID) zap.S().Infof("Upload to node %s canceled by user.", storageNodeID)
} else { } else {
zap.S().Infof("Node %s cut from upload due to slow connection.", storageNodeID) zap.S().Debugf("Node %s cut from upload due to slow connection.", storageNodeID)
} }
err = context.Canceled err = context.Canceled
} else if err != nil { } else if err != nil {