|
@ -116,7 +116,6 @@ func (fsStatus *FilesystemStatus) parseFile(indexBucket, picksBucket *bolt.Bucke |
|
|
|
|
|
|
|
|
defer func() { |
|
|
defer func() { |
|
|
bar.Increment() |
|
|
bar.Increment() |
|
|
fsStatusWG.Done() |
|
|
|
|
|
}() |
|
|
}() |
|
|
|
|
|
|
|
|
pick = picksBucket.Get([]byte(p)) |
|
|
pick = picksBucket.Get([]byte(p)) |
|
@ -126,6 +125,7 @@ func (fsStatus *FilesystemStatus) parseFile(indexBucket, picksBucket *bolt.Bucke |
|
|
fsStatusWG.Wait() |
|
|
fsStatusWG.Wait() |
|
|
fsStatusWG.Add(1) |
|
|
fsStatusWG.Add(1) |
|
|
fsStatus.PickedFiles = append(fsStatus.PickedFiles, p) |
|
|
fsStatus.PickedFiles = append(fsStatus.PickedFiles, p) |
|
|
|
|
|
fsStatusWG.Done() |
|
|
return |
|
|
return |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
@ -145,6 +145,7 @@ func (fsStatus *FilesystemStatus) parseFile(indexBucket, picksBucket *bolt.Bucke |
|
|
fsStatusWG.Wait() |
|
|
fsStatusWG.Wait() |
|
|
fsStatusWG.Add(1) |
|
|
fsStatusWG.Add(1) |
|
|
fsStatus.ModifiedFiles = append(fsStatus.ModifiedFiles, p) |
|
|
fsStatus.ModifiedFiles = append(fsStatus.ModifiedFiles, p) |
|
|
|
|
|
fsStatusWG.Done() |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
return |
|
|
return |
|
@ -153,6 +154,7 @@ func (fsStatus *FilesystemStatus) parseFile(indexBucket, picksBucket *bolt.Bucke |
|
|
fsStatusWG.Wait() |
|
|
fsStatusWG.Wait() |
|
|
fsStatusWG.Add(1) |
|
|
fsStatusWG.Add(1) |
|
|
fsStatus.NewFiles = append(fsStatus.NewFiles, p) |
|
|
fsStatus.NewFiles = append(fsStatus.NewFiles, p) |
|
|
|
|
|
fsStatusWG.Done() |
|
|
|
|
|
|
|
|
return |
|
|
return |
|
|
} |
|
|
} |
|
|