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

better repairer logging (#2006)

Browse Source 
* logging and delete only repairs with no errors

* removing delete logi~c
This commit is contained in:
Bill Thorp 2019-05-20 18:05:28 -04:00 committed by littleskunk
parent 46ab933363
commit 6522579ecb
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/datarepair/repairer/repairer.go
View File

@ -116,6 +116,7 @@ func (service *Service) Run(ctx context.Context) (err error) {
func (service *Service) process(ctx context.Context) error {
for {
seg, err := service.queue.Select(ctx)
zap.L().Info("Dequeued segment from repair queue", zap.String("segment", seg.GetPath()))
if err != nil {
if storage.ErrEmptyQueue.Has(err) {
return nil
@ -124,10 +125,12 @@ func (service *Service) process(ctx context.Context) error {
}
service.Limiter.Go(ctx, func() {
zap.L().Info("Limiter running repair on segment", zap.String("segment", seg.GetPath()))
err := service.repairer.Repair(ctx, seg.GetPath())
if err != nil {
zap.L().Error("repair failed", zap.Error(err))
}
zap.L().Info("Deleting segment from repair queue", zap.String("segment", seg.GetPath()))
err = service.queue.Delete(ctx, seg)
if err != nil {
zap.L().Error("repair delete failed", zap.Error(err))