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

pkg/datarepair/checker: Fix doc comments (#2401)

Browse Source
This commit is contained in:
Ivan Fraixedes 2019-07-01 18:13:18 +02:00 committed by GitHub
parent 385c046723
commit b6ae6a4e2c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/datarepair/checker/checker.go
View File

@ -183,7 +183,7 @@ func (checker *Checker) updateSegmentStatus(ctx context.Context, pointer *pb.Poi
numHealthy := int32(len(pieces) - len(missingPieces)) numHealthy := int32(len(pieces) - len(missingPieces))
redundancy := pointer.Remote.Redundancy redundancy := pointer.Remote.Redundancy
// we repair when the number of healthy files is less than or equal to the repair threshold // we repair when the number of healthy pieces is less than or equal to the repair threshold
// except for the case when the repair and success thresholds are the same (a case usually seen during testing) // except for the case when the repair and success thresholds are the same (a case usually seen during testing)
if numHealthy > redundancy.MinReq && numHealthy <= redundancy.RepairThreshold && numHealthy < redundancy.SuccessThreshold { if numHealthy > redundancy.MinReq && numHealthy <= redundancy.RepairThreshold && numHealthy < redundancy.SuccessThreshold {
if len(missingPieces) == 0 { if len(missingPieces) == 0 {
@ -237,7 +237,8 @@ func (checker *Checker) updateSegmentStatus(ctx context.Context, pointer *pb.Poi
return nil return nil
} }
// IrreparableProcess picks items from irrepairabledb and spawns a repair worker // IrreparableProcess picks items from irrepairabledb and add them to the repair
// worker queue if they, now, can be repaired.
func (checker *Checker) IrreparableProcess(ctx context.Context) (err error) { func (checker *Checker) IrreparableProcess(ctx context.Context) (err error) {
defer mon.Task()(&ctx)(&err) defer mon.Task()(&ctx)(&err)