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

properly check last iteration of checker (#2040)

Browse Source
This commit is contained in:
Maximillian von Briesen 2019-05-23 12:14:08 -04:00 committed by littleskunk
parent 69cf6caa62
commit da91d22376
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -100,10 +100,9 @@ func (checker *Checker) IdentifyInjuredSegments(ctx context.Context) (err error)
it.Next(&nextItem)
// start at the next item in the next call
checker.lastChecked = nextItem.Key.String()
// if keys are equal, start from the beginning in the next call
if nextItem.Key.String() == item.Key.String() {
checker.lastChecked = ""
// if we have finished iterating, send and reset durability stats
if checker.lastChecked == "" {
// send durability stats
mon.IntVal("remote_files_checked").Observe(checker.durabilityStats.remoteFilesChecked)
mon.IntVal("remote_segments_checked").Observe(checker.durabilityStats.remoteSegmentsChecked)